public class GRpcJobKillServiceImpl extends com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase implements JobKillServiceV4
Constructor and Description |
---|
GRpcJobKillServiceImpl(JobSearchService jobSearchService)
Constructor.
|
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.
|
public GRpcJobKillServiceImpl(JobSearchService jobSearchService)
jobSearchService
- Job search servicepublic void registerForKillNotification(com.netflix.genie.proto.JobKillRegistrationRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobKillRegistrationResponse> responseObserver)
registerForKillNotification
in class com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase
request
- Request to register for getting notified when server gets a job kill request.responseObserver
- The response observerpublic 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
killJob
in interface JobKillServiceV4
jobId
- id of job to killreason
- brief reason for requesting the job be killedGenieServerException
- in case there is no response observer
found to communicate with the agentGenieException
- if there is an error