com.netflix.genie.agent.execution.services.impl.grpc

Class GRpcServicesAutoConfiguration

java.lang.Object

com.netflix.genie.agent.execution.services.impl.grpc.GRpcServicesAutoConfiguration

@Configuration
 @EnableConfigurationProperties(value=AgentProperties.class)
public class GRpcServicesAutoConfiguration
extends java.lang.Object

Spring auto configuration for the various gRPC services required for an agent to communicate with the Genie server.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
GRpcServicesAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
GRpcAgentFileStreamServiceImpl	agentFileStreamService(com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamServiceStub, org.springframework.scheduling.TaskScheduler taskScheduler, JobDirectoryManifestProtoConverter jobDirectoryManifestProtoConverter, JobDirectoryManifestCreatorService jobDirectoryManifestCreatorService, AgentProperties agentProperties) Provide a lazy gRPC agent file stream service if one isn't already defined.
com.netflix.genie.agent.execution.services.impl.grpc.GrpcAgentHeartBeatServiceImpl	agentHeartBeatService(com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatServiceStub, org.springframework.scheduling.TaskScheduler taskScheduler, AgentProperties agentProperties) Provide a lazy gRPC agent heart beat service if one isn't already defined.
GRpcAgentJobKillServiceImpl	agentJobKillService(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillServiceFutureStub, KillService killService, org.springframework.scheduling.TaskScheduler taskScheduler, AgentProperties agentProperties) Provide a lazy gRPC agent job kill service bean if one isn't already defined.
com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobServiceImpl	agentJobService(com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub jobServiceFutureStub, JobServiceProtoConverter jobServiceProtoConverter) Provide a lazy gRPC agent job service bean if one isn't already defined.

Methods inherited from class java.lang.Object

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

Constructor Detail

GRpcServicesAutoConfiguration

public GRpcServicesAutoConfiguration()

Method Detail

agentHeartBeatService

@Bean
 @Lazy
 @ConditionalOnMissingBean(value=AgentHeartBeatService.class)
public com.netflix.genie.agent.execution.services.impl.grpc.GrpcAgentHeartBeatServiceImpl agentHeartBeatService(com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatServiceStub,
                                                                                                                                                                                           @Qualifier(value="heartBeatServiceTaskScheduler")
                                                                                                                                                                                           org.springframework.scheduling.TaskScheduler taskScheduler,
                                                                                                                                                                                           AgentProperties agentProperties)

Provide a lazy gRPC agent heart beat service if one isn't already defined.

Parameters:

heartBeatServiceStub - The heart beat service stub to use

taskScheduler - The task scheduler to use

agentProperties - The agent properties

Returns:

A GrpcAgentHeartBeatServiceImpl instance

agentJobKillService

@Bean
 @Lazy
 @ConditionalOnMissingBean(value=AgentJobKillService.class)
public GRpcAgentJobKillServiceImpl agentJobKillService(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillServiceFutureStub,
                                                                                                                                KillService killService,
                                                                                                                                @Qualifier(value="sharedAgentTaskScheduler")
                                                                                                                                org.springframework.scheduling.TaskScheduler taskScheduler,
                                                                                                                                AgentProperties agentProperties)

Provide a lazy gRPC agent job kill service bean if one isn't already defined.

Parameters:

jobKillServiceFutureStub - The future stub to use for the service communication with the server

killService - The kill service to use to terminate this agent gracefully

taskScheduler - The task scheduler to use

agentProperties - The agent properties

Returns:

A GRpcAgentJobKillServiceImpl instance

agentJobService

@Bean
 @Lazy
 @ConditionalOnMissingBean(value=AgentJobService.class)
public com.netflix.genie.agent.execution.services.impl.grpc.GRpcAgentJobServiceImpl agentJobService(com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub jobServiceFutureStub,
                                                                                                                                                                         JobServiceProtoConverter jobServiceProtoConverter)

Provide a lazy gRPC agent job service bean if one isn't already defined.

Parameters:

jobServiceFutureStub - The future stub to use for communication with the server

jobServiceProtoConverter - The converter to use between DTO and Proto instances

Returns:

A GRpcAgentJobServiceImpl instance

agentFileStreamService

@Bean
 @Lazy
 @ConditionalOnMissingBean(value=AgentFileStreamService.class)
public GRpcAgentFileStreamServiceImpl agentFileStreamService(com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamServiceStub,
                                                                                                                                         @Qualifier(value="sharedAgentTaskScheduler")
                                                                                                                                         org.springframework.scheduling.TaskScheduler taskScheduler,
                                                                                                                                         JobDirectoryManifestProtoConverter jobDirectoryManifestProtoConverter,
                                                                                                                                         JobDirectoryManifestCreatorService jobDirectoryManifestCreatorService,
                                                                                                                                         AgentProperties agentProperties)

Provide a lazy gRPC agent file stream service if one isn't already defined.

Parameters:

fileStreamServiceStub - The stub to use for communications with the server

taskScheduler - The task scheduler to use

jobDirectoryManifestProtoConverter - The converter to serialize manifests into messages

jobDirectoryManifestCreatorService - The job directory manifest service

agentProperties - The agent properties

Returns:

A AgentFileStreamService instance