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 java.lang.Object
implements AgentJobKillService

Implementation of the AgentJobKillService.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
GRpcAgentJobKillServiceImpl(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub client, KillService killService, org.springframework.core.task.TaskExecutor killTaskExecutor) Constructor.

Method Summary

Modifier and Type	Method and Description
void	start(@NotBlank(message="Job id cannot be blank") java.lang.String jobId) 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 Detail

GRpcAgentJobKillServiceImpl

public GRpcAgentJobKillServiceImpl(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub client,
                                   KillService killService,
                                   org.springframework.core.task.TaskExecutor killTaskExecutor)

Constructor.

Parameters:

client - The gRPC client to use to call the server

killService - KillService for killing the agent

killTaskExecutor - A task executor to execute killing the agent

Method Detail

start

public void start(@NotBlank(message="Job id cannot be blank")
                  @NotBlank(message="Job id cannot be blank") java.lang.String jobId)

Description copied from interface: AgentJobKillService

Start listening for job termination notification.

Specified by:

start in interface AgentJobKillService

Parameters:

jobId - job id

stop

public void stop()

Description copied from interface: AgentJobKillService

Stop the service.

Specified by:

stop in interface AgentJobKillService