com.netflix.genie.web.rpc.grpc.services.impl.v4

Class GRpcJobKillServiceImpl

java.lang.Object

com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase

com.netflix.genie.web.rpc.grpc.services.impl.v4.GRpcJobKillServiceImpl

All Implemented Interfaces:

JobKillServiceV4, io.grpc.BindableService

@GrpcService(value=com.netflix.genie.proto.JobKillServiceGrpc.class,
             interceptors=SimpleLoggingInterceptor.class)
public class GRpcJobKillServiceImpl
extends com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase
implements JobKillServiceV4

Service to kill agent jobs. TODO Register with HeartBeatService to listen for agent stream to become inactive and clean it up.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
GRpcJobKillServiceImpl(JobSearchService jobSearchService) Constructor.

Method Summary

Modifier and Type	Method and Description
void	killJob(@NotBlank(message="No job id entered. Unable to kill job.") java.lang.String jobId, @NotBlank(message="No reason provided.") java.lang.String reason) Kill the job with the given id if possible.
void	registerForKillNotification(com.netflix.genie.proto.JobKillRegistrationRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobKillRegistrationResponse> responseObserver) Register to be notified when a kill request for the job is received.

Methods inherited from class com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

GRpcJobKillServiceImpl

public GRpcJobKillServiceImpl(JobSearchService jobSearchService)

Constructor.

Parameters:

jobSearchService - Job search service

Method Detail

registerForKillNotification

public void registerForKillNotification(com.netflix.genie.proto.JobKillRegistrationRequest request,
                                        io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobKillRegistrationResponse> responseObserver)

Register to be notified when a kill request for the job is received.

Overrides:

registerForKillNotification in class com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase

Parameters:

request - Request to register for getting notified when server gets a job kill request.

responseObserver - The response observer

killJob

public void killJob(@NotBlank(message="No job id entered. Unable to kill job.")
                    @NotBlank(message="No job id entered. Unable to kill job.") java.lang.String jobId,
                    @NotBlank(message="No reason provided.")
                    @NotBlank(message="No reason provided.") java.lang.String reason)
             throws GenieException

Kill the job with the given id if possible.

Specified by:

killJob in interface JobKillServiceV4

Parameters:

jobId - id of job to kill

reason - brief reason for requesting the job be killed

Throws:

GenieServerException - in case there is no response observer found to communicate with the agent

GenieException - if there is an error