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

Class GRpcServicesAutoConfiguration

  • @Configuration
@EnableConfigurationProperties(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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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(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