Package com.netflix.genie.web.agent.apis.rpc.v4.endpoints

Class GRpcHeartBeatServiceImpl

java.lang.Object

com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase

com.netflix.genie.web.agent.apis.rpc.v4.endpoints.GRpcHeartBeatServiceImpl

All Implemented Interfaces:

com.netflix.genie.proto.HeartBeatServiceGrpc.AsyncService, io.grpc.BindableService

public class GRpcHeartBeatServiceImpl
extends com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase

An edge gRPC service that uses bi-directional streaming. This is useful to reliably track which connection is handled by which server and to detect disconnections on both ends.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
GRpcHeartBeatServiceImpl(AgentConnectionTrackingService agentConnectionTrackingService, HeartBeatProperties properties, org.springframework.scheduling.TaskScheduler taskScheduler, io.micrometer.core.instrument.MeterRegistry registry)	Constructor.

Method Summary

Modifier and Type	Method	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.

Methods inherited from class com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GRpcHeartBeatServiceImpl

public GRpcHeartBeatServiceImpl(AgentConnectionTrackingService agentConnectionTrackingService,
 HeartBeatProperties properties,
 org.springframework.scheduling.TaskScheduler taskScheduler,
 io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

agentConnectionTrackingService - The AgentRoutingService implementation to use

properties - The service properties

taskScheduler - The TaskScheduler instance to use

registry - The meter registry

Method Details

shutdown

@PreDestroy
public void shutdown()

Shutdown this service.

heartbeat

public io.grpc.stub.StreamObserver<com.netflix.genie.proto.AgentHeartBeat> heartbeat(io.grpc.stub.StreamObserver<com.netflix.genie.proto.ServerHeartBeat> responseObserver)