Package com.netflix.genie.agent.execution.services.impl.grpc

Class GRpcAgentJobKillServiceImpl

java.lang.Object

com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobKillServiceImpl

All Implemented Interfaces:

AgentJobKillService

public class GRpcAgentJobKillServiceImpl
extends Object
implements AgentJobKillService

Implementation of the AgentJobKillService that listens for kill signals from the server using event listeners.

This implementation works by sending a unary gRPC request to the server, which holds the response until it has a kill signal to send or until the request times out. It attaches event listeners to the response future, which automatically process the response when it arrives. If a request fails, a periodic task with exponential backoff is used to retry creating a new request. The implementation properly handles request cancellation during shutdown.

Note: this implementation still suffers from a limitation: because it uses unary gRPC calls, the server will never realize the client is gone if the connection is broken. This can lead to an accumulation of parked calls on the server if clients disconnect abnormally. A protocol based on bidirectional streaming would be necessary to fully solve this problem.

Since:

4.0.0

Constructor Summary

Constructors

Constructor	Description
GRpcAgentJobKillServiceImpl(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub client, KillService killService, org.springframework.scheduling.TaskScheduler taskScheduler, JobKillServiceProperties properties)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	start(@NotBlank(message="Job id cannot be blank") String requestedJobId)	Start listening for job termination notification.
void	stop()	Stop the service.

Methods inherited from class java.lang.Object

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

Constructor Details

GRpcAgentJobKillServiceImpl

public GRpcAgentJobKillServiceImpl(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub client,
 KillService killService,
 org.springframework.scheduling.TaskScheduler taskScheduler,
 JobKillServiceProperties properties)

Constructor.

Parameters:

client - The gRPC client to use to call the server

killService - KillService for killing the agent

taskScheduler - A task scheduler

properties - The service properties

Method Details

start

public void start(@NotBlank(message="Job id cannot be blank")
 @NotBlank(message="Job id cannot be blank") String requestedJobId)

Start listening for job termination notification.

Specified by:

start in interface AgentJobKillService

Parameters:

requestedJobId - job id

stop

public void stop()

Stop the service.

Specified by:

stop in interface AgentJobKillService