public class GRpcHeartBeatServiceImpl
extends com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase
Constructor and Description |
---|
GRpcHeartBeatServiceImpl(AgentRoutingService agentRoutingService,
org.springframework.scheduling.TaskScheduler taskScheduler)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
io.grpc.stub.StreamObserver<com.netflix.genie.proto.AgentHeartBeat> |
heartbeat(io.grpc.stub.StreamObserver<com.netflix.genie.proto.ServerHeartBeat> responseObserver) |
void |
shutdown()
Shutdown this service.
|
public GRpcHeartBeatServiceImpl(AgentRoutingService agentRoutingService, org.springframework.scheduling.TaskScheduler taskScheduler)
agentRoutingService
- The AgentRoutingService
implementation to usetaskScheduler
- The TaskScheduler
instance to use@PreDestroy public void shutdown()
public io.grpc.stub.StreamObserver<com.netflix.genie.proto.AgentHeartBeat> heartbeat(io.grpc.stub.StreamObserver<com.netflix.genie.proto.ServerHeartBeat> responseObserver)
heartbeat
in class com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase