@Configuration
public class GRpcServicesAutoConfiguration
extends java.lang.Object
Constructor and Description |
---|
GRpcServicesAutoConfiguration() |
Modifier and Type | Method and Description |
---|---|
AgentFileStreamService |
agentFileStreamService(com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamServiceStub,
org.springframework.scheduling.TaskScheduler taskScheduler,
JobDirectoryManifestProtoConverter jobDirectoryManifestProtoConverter,
JobDirectoryManifestService jobDirectoryManifestService)
Provide a lazy gRPC agent file stream service if one isn't already defined.
|
AgentHeartBeatService |
agentHeartBeatService(com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatServiceStub,
org.springframework.scheduling.TaskScheduler taskScheduler)
Provide a lazy gRPC agent heart beat service if one isn't already defined.
|
AgentJobKillService |
agentJobKillService(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillServiceFutureStub,
KillService killService,
org.springframework.core.task.TaskExecutor taskExecutor)
Provide a lazy gRPC agent job kill service bean if one isn't already defined.
|
AgentJobService |
agentJobService(com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub jobServiceFutureStub,
JobServiceProtoConverter jobServiceProtoConverter)
Provide a lazy gRPC agent job service bean if one isn't already defined.
|
@Bean @Lazy @ConditionalOnMissingBean(value=AgentHeartBeatService.class) public AgentHeartBeatService agentHeartBeatService(com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatServiceStub, @Qualifier(value="heartBeatServiceTaskScheduler") org.springframework.scheduling.TaskScheduler taskScheduler)
heartBeatServiceStub
- The heart beat service stub to usetaskScheduler
- The task scheduler to useGrpcAgentHeartBeatServiceImpl
instance@Bean @Lazy @ConditionalOnMissingBean(value=AgentJobKillService.class) public AgentJobKillService agentJobKillService(com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillServiceFutureStub, KillService killService, @Qualifier(value="sharedAgentTaskExecutor") org.springframework.core.task.TaskExecutor taskExecutor)
jobKillServiceFutureStub
- The future stub to use for the service communication with the serverkillService
- The kill service to use to terminate this agent gracefullytaskExecutor
- The task executor to useGRpcAgentJobKillServiceImpl
instance@Bean @Lazy @ConditionalOnMissingBean(value=AgentJobService.class) public AgentJobService agentJobService(com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub jobServiceFutureStub, JobServiceProtoConverter jobServiceProtoConverter)
jobServiceFutureStub
- The future stub to use for communication with the serverjobServiceProtoConverter
- The converter to use between DTO and Proto instancesGRpcAgentJobServiceImpl
instance@Bean @Lazy @ConditionalOnMissingBean(value=AgentFileStreamService.class) public AgentFileStreamService agentFileStreamService(com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamServiceStub, @Qualifier(value="sharedAgentTaskScheduler") org.springframework.scheduling.TaskScheduler taskScheduler, JobDirectoryManifestProtoConverter jobDirectoryManifestProtoConverter, JobDirectoryManifestService jobDirectoryManifestService)
fileStreamServiceStub
- The stub to use for communications with the servertaskScheduler
- The task scheduler to usejobDirectoryManifestProtoConverter
- The converter to serialize manifests into messagesjobDirectoryManifestService
- The job directory manifest serviceAgentFileStreamService
instance