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

Class GRpcJobServiceImpl

java.lang.Object

com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

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

All Implemented Interfaces:

io.grpc.BindableService

@ConditionalOnProperty(value="genie.grpc.server.enabled",
                       havingValue="true")
 @GrpcService(value=com.netflix.genie.proto.JobServiceGrpc.class,
             interceptors=SimpleLoggingInterceptor.class)
public class GRpcJobServiceImpl
extends com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Extension of JobServiceGrpc.JobServiceImplBase to provide functionality for resolving and fetching specifications for jobs to be run by the Genie Agent.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
GRpcJobServiceImpl(AgentJobService agentJobService, JobServiceProtoConverter jobServiceProtoConverter, com.netflix.genie.web.rpc.grpc.services.impl.v4.JobServiceProtoErrorComposer protoErrorComposer) Constructor.

Method Summary

Modifier and Type	Method and Description
void	changeJobStatus(com.netflix.genie.proto.ChangeJobStatusRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.ChangeJobStatusResponse> responseObserver) When the agent wants to tell the system that the status of a job is changed this API is called.
void	claimJob(com.netflix.genie.proto.ClaimJobRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.ClaimJobResponse> responseObserver) When an agent is claiming responsibility and ownership for a job this API is called.
void	getJobSpecification(com.netflix.genie.proto.JobSpecificationRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver) Assuming a specification has already been resolved the agent will call this API with a job id to fetch the specification.
void	handshake(com.netflix.genie.proto.HandshakeRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.HandshakeResponse> responseObserver) This API gives the server a chance to reject a client/agent based on its metadata (version, location, ...).
void	reserveJobId(com.netflix.genie.proto.ReserveJobIdRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.ReserveJobIdResponse> responseObserver) This API will reserve a job id using the supplied metadata in the request and return the reserved job id.
void	resolveJobSpecification(com.netflix.genie.proto.JobSpecificationRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver) This API will take a request to resolve a Job Specification and given the inputs figure out all the details needed to flesh out a job specification for the Agent to run.
void	resolveJobSpecificationDryRun(com.netflix.genie.proto.DryRunJobSpecificationRequest request, io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver) The agent requests that a job specification be resolved without impacting any state in the database.

Methods inherited from class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

GRpcJobServiceImpl

public GRpcJobServiceImpl(AgentJobService agentJobService,
                          JobServiceProtoConverter jobServiceProtoConverter,
                          com.netflix.genie.web.rpc.grpc.services.impl.v4.JobServiceProtoErrorComposer protoErrorComposer)

Constructor.

Parameters:

agentJobService - The implementation of the AgentJobService to use

jobServiceProtoConverter - DTO/Proto converter

protoErrorComposer - proto error message composer

Method Detail

handshake

public void handshake(com.netflix.genie.proto.HandshakeRequest request,
                      io.grpc.stub.StreamObserver<com.netflix.genie.proto.HandshakeResponse> responseObserver)

This API gives the server a chance to reject a client/agent based on its metadata (version, location, ...).

Overrides:

handshake in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing client metadata

responseObserver - To send the response

reserveJobId

public void reserveJobId(com.netflix.genie.proto.ReserveJobIdRequest request,
                         io.grpc.stub.StreamObserver<com.netflix.genie.proto.ReserveJobIdResponse> responseObserver)

This API will reserve a job id using the supplied metadata in the request and return the reserved job id.

Overrides:

reserveJobId in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing all the metadata necessary to reserve a job id in the system

responseObserver - To send the response

resolveJobSpecification

public void resolveJobSpecification(com.netflix.genie.proto.JobSpecificationRequest request,
                                    io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver)

This API will take a request to resolve a Job Specification and given the inputs figure out all the details needed to flesh out a job specification for the Agent to run. The request parameters will be stored in the database.

Overrides:

resolveJobSpecification in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request information

responseObserver - How to send a response

getJobSpecification

public void getJobSpecification(com.netflix.genie.proto.JobSpecificationRequest request,
                                io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver)

Assuming a specification has already been resolved the agent will call this API with a job id to fetch the specification.

Overrides:

getJobSpecification in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing the job id to return the specification for

responseObserver - How to send a response

resolveJobSpecificationDryRun

public void resolveJobSpecificationDryRun(com.netflix.genie.proto.DryRunJobSpecificationRequest request,
                                          io.grpc.stub.StreamObserver<com.netflix.genie.proto.JobSpecificationResponse> responseObserver)

The agent requests that a job specification be resolved without impacting any state in the database. This operation is completely transient and just reflects what the job specification would look like given the current state of the system and the input parameters.

Overrides:

resolveJobSpecificationDryRun in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing all the metadata required to resolve a job specification

responseObserver - The observer to send a response with

claimJob

public void claimJob(com.netflix.genie.proto.ClaimJobRequest request,
                     io.grpc.stub.StreamObserver<com.netflix.genie.proto.ClaimJobResponse> responseObserver)

When an agent is claiming responsibility and ownership for a job this API is called.

Overrides:

claimJob in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing the job id being claimed and other pertinent metadata

responseObserver - The observer to send a response with

changeJobStatus

public void changeJobStatus(com.netflix.genie.proto.ChangeJobStatusRequest request,
                            io.grpc.stub.StreamObserver<com.netflix.genie.proto.ChangeJobStatusResponse> responseObserver)

When the agent wants to tell the system that the status of a job is changed this API is called.

Overrides:

changeJobStatus in class com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase

Parameters:

request - The request containing the necessary metadata to change job status for a given job

responseObserver - The observer to send a response with