com.netflix.genie.common.internal.dtos.v4.converters

Class JobServiceProtoConverter

java.lang.Object

com.netflix.genie.common.internal.dtos.v4.converters.JobServiceProtoConverter

public class JobServiceProtoConverter
extends java.lang.Object

Converter of proto messages for the JobServiceGrpc.JobServiceImplBase service to and from V4 DTO POJO's.

Since:

4.0.0

See Also:

com.netflix.genie.common.internal.dtos.v4, com.netflix.genie.proto

Constructor Summary

Constructors

Constructor and Description
JobServiceProtoConverter()

Method Summary

Modifier and Type	Method and Description
AgentClientMetadata	toAgentClientMetadataDto(com.netflix.genie.proto.AgentMetadata agentMetadata) Convert a proto AgentMetadata to an AgentClientMetadata.
com.netflix.genie.proto.ChangeJobArchiveStatusRequest	toChangeJobStatusArchiveRequestProto(java.lang.String jobId, ArchiveStatus archiveStatus) Creates a request to change the remote job archive status.
com.netflix.genie.proto.ChangeJobStatusRequest	toChangeJobStatusRequestProto(@NotBlank java.lang.String jobId, JobStatus currentJobStatus, JobStatus newJobStatus, java.lang.String message) Convert parameters into ChangeJobStatusRequest for the server.
com.netflix.genie.proto.ClaimJobRequest	toClaimJobRequestProto(java.lang.String jobId, AgentClientMetadata agentClientMetadata) Convert agent metadata and job id into a ClaimJobRequest for the server.
com.netflix.genie.proto.ConfigureRequest	toConfigureRequestProto(AgentClientMetadata agentClientMetadata) Convert parameters into ConfigureRequest for the server.
com.netflix.genie.proto.DryRunJobSpecificationRequest	toDryRunJobSpecificationRequestProto(AgentJobRequest jobRequest) Convert a V4 Job Request DTO into a gRPC dry run resolve job specification request to be sent to the server.
com.netflix.genie.proto.GetJobStatusRequest	toGetJobStatusRequestProto(java.lang.String jobId) Creates a request to fetch the job status currently seen by the server.
com.netflix.genie.proto.HandshakeRequest	toHandshakeRequestProto(AgentClientMetadata agentClientMetadata) Convert parameters into HandshakeRequest for the server.
JobRequest	toJobRequestDto(com.netflix.genie.proto.DryRunJobSpecificationRequest request) Convert a gRPC request to dry run a job specification resolution into a JobRequest for use within Genie server codebase.
JobRequest	toJobRequestDto(com.netflix.genie.proto.ReserveJobIdRequest request) Convert a gRPC reserve job id request into a V4 Job Request DTO for use within Genie codebase.
JobSpecification	toJobSpecificationDto(com.netflix.genie.proto.JobSpecification protoSpec) Convert a response from server into a Job Specification DTO which can be used in the codebase free of gRPC.
com.netflix.genie.proto.JobSpecification	toJobSpecificationProto(JobSpecification jobSpecification) Convert a Job Specification DTO to a protobuf message representation.
com.netflix.genie.proto.JobSpecificationRequest	toJobSpecificationRequestProto(java.lang.String id) Generate a JobSpecificationRequest from the given job id.
com.netflix.genie.proto.JobSpecificationResponse	toJobSpecificationResponseProto(JobSpecification jobSpecification) Build a JobSpecificationResponse out of the given JobSpecification.
com.netflix.genie.proto.ReserveJobIdRequest	toReserveJobIdRequestProto(AgentJobRequest jobRequest, AgentClientMetadata agentClientMetadata) Convert a V4 Job Request DTO into a gRPC reserve job id request to be sent to the server.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobServiceProtoConverter

public JobServiceProtoConverter()

Method Detail

toReserveJobIdRequestProto

public com.netflix.genie.proto.ReserveJobIdRequest toReserveJobIdRequestProto(AgentJobRequest jobRequest,
                                                                              AgentClientMetadata agentClientMetadata)
                                                                       throws GenieConversionException

Convert a V4 Job Request DTO into a gRPC reserve job id request to be sent to the server.

Parameters:

jobRequest - The job request to convert

agentClientMetadata - The metadata about the agent

Returns:

The request that should be sent to the server for a new Job Specification given the parameters

Throws:

GenieConversionException - if conversion fails

toJobSpecificationRequestProto

public com.netflix.genie.proto.JobSpecificationRequest toJobSpecificationRequestProto(java.lang.String id)

Generate a JobSpecificationRequest from the given job id.

Parameters:

id - The job id to generate the request for

Returns:

The request instance

toJobRequestDto

public JobRequest toJobRequestDto(com.netflix.genie.proto.ReserveJobIdRequest request)
                           throws GenieConversionException

Convert a gRPC reserve job id request into a V4 Job Request DTO for use within Genie codebase.

Parameters:

request - The request to convert

Returns:

The job request

Throws:

GenieConversionException - if conversion fails

toDryRunJobSpecificationRequestProto

public com.netflix.genie.proto.DryRunJobSpecificationRequest toDryRunJobSpecificationRequestProto(AgentJobRequest jobRequest)
                                                                                           throws GenieConversionException

Convert a V4 Job Request DTO into a gRPC dry run resolve job specification request to be sent to the server.

Parameters:

jobRequest - The job request to convert

Returns:

The request that should be sent to the server for a new Job Specification given the parameters

Throws:

GenieConversionException - if conversion fails

toJobRequestDto

public JobRequest toJobRequestDto(com.netflix.genie.proto.DryRunJobSpecificationRequest request)
                           throws GenieConversionException

Convert a gRPC request to dry run a job specification resolution into a JobRequest for use within Genie server codebase.

Parameters:

request - The request to convert

Returns:

The job request

Throws:

GenieConversionException - if conversion fails

toAgentClientMetadataDto

public AgentClientMetadata toAgentClientMetadataDto(com.netflix.genie.proto.AgentMetadata agentMetadata)

Convert a proto AgentMetadata to an AgentClientMetadata.

Parameters:

agentMetadata - The metadata to convert

Returns:

The immutable DTO representation

toJobSpecificationResponseProto

public com.netflix.genie.proto.JobSpecificationResponse toJobSpecificationResponseProto(JobSpecification jobSpecification)

Build a JobSpecificationResponse out of the given JobSpecification.

Parameters:

jobSpecification - The job specification to serialize

Returns:

The response instance

toJobSpecificationDto

public JobSpecification toJobSpecificationDto(com.netflix.genie.proto.JobSpecification protoSpec)

Convert a response from server into a Job Specification DTO which can be used in the codebase free of gRPC.

Parameters:

protoSpec - The protobuf specification message

Returns:

A job specification DTO

toJobSpecificationProto

public com.netflix.genie.proto.JobSpecification toJobSpecificationProto(JobSpecification jobSpecification)

Convert a Job Specification DTO to a protobuf message representation.

Parameters:

jobSpecification - The JobSpecification to convert

Returns:

A JobSpecification instance

toClaimJobRequestProto

public com.netflix.genie.proto.ClaimJobRequest toClaimJobRequestProto(java.lang.String jobId,
                                                                      AgentClientMetadata agentClientMetadata)

Convert agent metadata and job id into a ClaimJobRequest for the server.

Parameters:

jobId - job id

agentClientMetadata - agent metadata

Returns:

a ClaimJobRequest

toChangeJobStatusRequestProto

public com.netflix.genie.proto.ChangeJobStatusRequest toChangeJobStatusRequestProto(@NotBlank
                                                                                    @NotBlank java.lang.String jobId,
                                                                                    JobStatus currentJobStatus,
                                                                                    JobStatus newJobStatus,
                                                                                    @Nullable
                                                                                    java.lang.String message)

Convert parameters into ChangeJobStatusRequest for the server.

Parameters:

jobId - job id

currentJobStatus - the expected current status on the server

newJobStatus - the new current status for this job

message - an optional message to record with the state change

Returns:

a ChangeJobStatusRequest

toHandshakeRequestProto

public com.netflix.genie.proto.HandshakeRequest toHandshakeRequestProto(AgentClientMetadata agentClientMetadata)
                                                                 throws GenieConversionException

Convert parameters into HandshakeRequest for the server.

Parameters:

agentClientMetadata - agent client metadata

Returns:

a HandshakeRequest

Throws:

GenieConversionException - if the inputs are invalid

toConfigureRequestProto

public com.netflix.genie.proto.ConfigureRequest toConfigureRequestProto(AgentClientMetadata agentClientMetadata)
                                                                 throws GenieConversionException

Convert parameters into ConfigureRequest for the server.

Parameters:

agentClientMetadata - agent client metadata

Returns:

a ConfigureRequest

Throws:

GenieConversionException - if the inputs are invalid

toGetJobStatusRequestProto

public com.netflix.genie.proto.GetJobStatusRequest toGetJobStatusRequestProto(java.lang.String jobId)

Creates a request to fetch the job status currently seen by the server.

Parameters:

jobId - the job id

Returns:

A GetJobStatusRequest message instance

toChangeJobStatusArchiveRequestProto

public com.netflix.genie.proto.ChangeJobArchiveStatusRequest toChangeJobStatusArchiveRequestProto(java.lang.String jobId,
                                                                                                  ArchiveStatus archiveStatus)

Creates a request to change the remote job archive status.

Parameters:

jobId - the job id

archiveStatus - the new archive status

Returns:

a ChangeJobArchiveStatusRequest message instance