com.netflix.genie.web.spring.autoconfigure.agent.apis.rpc.v4.endpoints

Class AgentRpcEndpointsAutoConfiguration

java.lang.Object

com.netflix.genie.web.spring.autoconfigure.agent.apis.rpc.v4.endpoints.AgentRpcEndpointsAutoConfiguration

@Configuration
public class AgentRpcEndpointsAutoConfiguration
extends java.lang.Object

Configures various gRPC services and related beans if gRPC functionality is enabled.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
AgentRpcEndpointsAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
GRpcAgentFileStreamServiceImpl	gRpcAgentFileStreamService(JobDirectoryManifestProtoConverter converter, org.springframework.scheduling.TaskScheduler taskScheduler) Provide an implementation of FileStreamServiceGrpc.FileStreamServiceImplBase if no other is provided.
GRpcHeartBeatServiceImpl	gRpcHeartBeatService(AgentRoutingService agentRoutingService, org.springframework.scheduling.TaskScheduler taskScheduler) Provide an implementation of HeartBeatServiceGrpc.HeartBeatServiceImplBase if no other is provided.
GRpcJobKillServiceImpl	gRpcJobKillService(JobSearchService jobSearchService) Provide an implementation of JobKillServiceGrpc.JobKillServiceImplBase if no other is provided.
GRpcJobServiceImpl	gRpcJobService(AgentJobService agentJobService, JobServiceProtoConverter jobServiceProtoConverter, JobServiceProtoErrorComposer protoErrorComposer) Provide an implementation of JobServiceGrpc.JobServiceImplBase if no other is provided.
GRpcPingServiceImpl	gRpcPingService(GenieHostInfo genieHostInfo) Provide an implementation of PingServiceGrpc.PingServiceImplBase if no other is provided.
org.springframework.scheduling.TaskScheduler	heartBeatServiceTaskScheduler() Get the task scheduler used by the HeartBeat Service.
JobServiceProtoErrorComposer	jobServiceProtoErrorComposer() Bean for converting errors in the job service to gRPC messages.

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentRpcEndpointsAutoConfiguration

public AgentRpcEndpointsAutoConfiguration()

Method Detail

heartBeatServiceTaskScheduler

@Bean
 @ConditionalOnMissingBean(name="heartBeatServiceTaskScheduler")
public org.springframework.scheduling.TaskScheduler heartBeatServiceTaskScheduler()

Get the task scheduler used by the HeartBeat Service.

Returns:

The task scheduler

jobServiceProtoErrorComposer

@Bean
 @ConditionalOnMissingBean(value=JobServiceProtoErrorComposer.class)
public JobServiceProtoErrorComposer jobServiceProtoErrorComposer()

Bean for converting errors in the job service to gRPC messages.

Returns:

An instance of JobServiceProtoErrorComposer

gRpcAgentFileStreamService

@Bean
 @ConditionalOnMissingBean(value=com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceImplBase.class)
public GRpcAgentFileStreamServiceImpl gRpcAgentFileStreamService(JobDirectoryManifestProtoConverter converter,
                                                                                                                                                                                       @Qualifier(value="genieTaskScheduler")
                                                                                                                                                                                       org.springframework.scheduling.TaskScheduler taskScheduler)

Provide an implementation of FileStreamServiceGrpc.FileStreamServiceImplBase if no other is provided.

Parameters:

converter - The JobDirectoryManifestProtoConverter instance to use

taskScheduler - The TaskScheduler to use to schedule tasks

Returns:

An instance of GRpcAgentFileStreamServiceImpl

gRpcHeartBeatService

@Bean
 @ConditionalOnMissingBean(value=com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceImplBase.class)
public GRpcHeartBeatServiceImpl gRpcHeartBeatService(AgentRoutingService agentRoutingService,
                                                                                                                                                                         @Qualifier(value="heartBeatServiceTaskScheduler")
                                                                                                                                                                         org.springframework.scheduling.TaskScheduler taskScheduler)

Provide an implementation of HeartBeatServiceGrpc.HeartBeatServiceImplBase if no other is provided.

Parameters:

agentRoutingService - The AgentRoutingService implementation to use

taskScheduler - The TaskScheduler instance to use

Returns:

A GRpcHeartBeatServiceImpl instance

gRpcJobKillService

@Bean
 @ConditionalOnMissingBean(value=com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceImplBase.class)
public GRpcJobKillServiceImpl gRpcJobKillService(JobSearchService jobSearchService)

Provide an implementation of JobKillServiceGrpc.JobKillServiceImplBase if no other is provided.

Parameters:

jobSearchService - The JobSearchService instance to use

Returns:

A GRpcJobKillServiceImpl instance

gRpcJobService

@Bean
 @ConditionalOnMissingBean(value=com.netflix.genie.proto.JobServiceGrpc.JobServiceImplBase.class)
public GRpcJobServiceImpl gRpcJobService(AgentJobService agentJobService,
                                                                                                                                                 JobServiceProtoConverter jobServiceProtoConverter,
                                                                                                                                                 JobServiceProtoErrorComposer protoErrorComposer)

Provide an implementation of JobServiceGrpc.JobServiceImplBase if no other is provided.

Parameters:

agentJobService - The AgentJobService instance to use

jobServiceProtoConverter - The JobServiceProtoConverter instance to use

protoErrorComposer - The JobServiceProtoErrorComposer instance to use

Returns:

A GRpcJobServiceImpl instance

gRpcPingService

@Bean
 @ConditionalOnMissingBean(value=com.netflix.genie.proto.PingServiceGrpc.PingServiceImplBase.class)
public GRpcPingServiceImpl gRpcPingService(GenieHostInfo genieHostInfo)

Provide an implementation of PingServiceGrpc.PingServiceImplBase if no other is provided.

Parameters:

genieHostInfo - The information about the Genie host

Returns:

Instance of GRpcPingServiceImpl