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

Class GRpcServicesAutoConfiguration

java.lang.Object
com.netflix.genie.agent.execution.services.impl.grpc.GRpcServicesAutoConfiguration
@Configuration @EnableConfigurationProperties(AgentProperties.class) public class GRpcServicesAutoConfiguration extends Object
Spring auto configuration for the various gRPC services required for an agent to communicate with the Genie server.
Since:
4.0.0

  • Constructor Details

    • GRpcServicesAutoConfiguration

      public GRpcServicesAutoConfiguration()

  • Method Details

    • agentHeartBeatService

      @Bean @Lazy @ConditionalOnMissingBean(AgentHeartBeatService.class) public com.netflix.genie.agent.execution.services.impl.grpc.GrpcAgentHeartBeatServiceImpl agentHeartBeatService(com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatServiceStub, @Qualifier("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(AgentJobKillService.class) public GRpcAgentJobKillServiceImpl agentJobKillService(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillServiceFutureStub, KillService killService, @Qualifier("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(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(AgentFileStreamService.class) public GRpcAgentFileStreamServiceImpl agentFileStreamService(com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamServiceStub, @Qualifier("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