com.netflix.genie.agent.rpc

Class GRpcAutoConfiguration

java.lang.Object

com.netflix.genie.agent.rpc.GRpcAutoConfiguration

@Configuration
public class GRpcAutoConfiguration
extends java.lang.Object

Spring auto configuration for gRPC components.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
GRpcAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
io.grpc.ManagedChannel	channel(ArgumentDelegates.ServerArguments serverArguments) Provide a lazy ManagedChannel bean if none was already defined for communicating with the Genie server.
com.netflix.genie.agent.rpc.ChannelLoggingInterceptor	channelLoggingInterceptor() Provide a lazy ChannelLoggingInterceptor bean.
com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub	fileStreamClient(io.grpc.ManagedChannel channel) Provide a prototype bean definition for a FileStreamServiceGrpc.FileStreamServiceStub.
com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub	heartBeatClient(io.grpc.ManagedChannel channel) Provide a prototype bean definition for a HeartBeatServiceGrpc.HeartBeatServiceStub.
com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub	jobClient(io.grpc.ManagedChannel channel) Provide a prototype bean definition for a JobServiceGrpc.JobServiceFutureStub.
com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub	jobKillClient(io.grpc.ManagedChannel channel) Provide a prototype bean definition for a JobKillServiceGrpc.JobKillServiceFutureStub.
com.netflix.genie.proto.PingServiceGrpc.PingServiceFutureStub	pingServiceClient(io.grpc.ManagedChannel channel) Provide a prototype bean definition for a PingServiceGrpc.PingServiceFutureStub.

Methods inherited from class java.lang.Object

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

Constructor Detail

GRpcAutoConfiguration

public GRpcAutoConfiguration()

Method Detail

channelLoggingInterceptor

@Bean
 @Lazy
public com.netflix.genie.agent.rpc.ChannelLoggingInterceptor channelLoggingInterceptor()

Provide a lazy ChannelLoggingInterceptor bean.

Returns:

A ChannelLoggingInterceptor instance

channel

@Bean
 @Lazy
 @ConditionalOnMissingBean(value=io.grpc.ManagedChannel.class)
public io.grpc.ManagedChannel channel(ArgumentDelegates.ServerArguments serverArguments)

Provide a lazy ManagedChannel bean if none was already defined for communicating with the Genie server.

Parameters:

serverArguments - The server arguments to use

Returns:

A ManagedChannel instance configured to use plain text over the wire

pingServiceClient

@Bean
 @Scope(value="prototype")
public com.netflix.genie.proto.PingServiceGrpc.PingServiceFutureStub pingServiceClient(io.grpc.ManagedChannel channel)

Provide a prototype bean definition for a PingServiceGrpc.PingServiceFutureStub.

Parameters:

channel - The managed channel to use to connect to the Genie server

Returns:

A PingServiceGrpc.PingServiceFutureStub instance per use

jobClient

@Bean
 @Scope(value="prototype")
public com.netflix.genie.proto.JobServiceGrpc.JobServiceFutureStub jobClient(io.grpc.ManagedChannel channel)

Provide a prototype bean definition for a JobServiceGrpc.JobServiceFutureStub.

Parameters:

channel - The managed channel to use to connect to the Genie server

Returns:

A JobServiceGrpc.JobServiceFutureStub instance per use

heartBeatClient

@Bean
 @Scope(value="prototype")
public com.netflix.genie.proto.HeartBeatServiceGrpc.HeartBeatServiceStub heartBeatClient(io.grpc.ManagedChannel channel)

Provide a prototype bean definition for a HeartBeatServiceGrpc.HeartBeatServiceStub.

Parameters:

channel - The managed channel to use to connect to the Genie server

Returns:

A HeartBeatServiceGrpc.HeartBeatServiceStub instance per use

jobKillClient

@Bean
 @Scope(value="prototype")
public com.netflix.genie.proto.JobKillServiceGrpc.JobKillServiceFutureStub jobKillClient(io.grpc.ManagedChannel channel)

Provide a prototype bean definition for a JobKillServiceGrpc.JobKillServiceFutureStub.

Parameters:

channel - The managed channel to use to connect to the Genie server

Returns:

A JobKillServiceGrpc.JobKillServiceFutureStub instance per use

fileStreamClient

@Bean
 @Scope(value="prototype")
public com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub fileStreamClient(io.grpc.ManagedChannel channel)

Provide a prototype bean definition for a FileStreamServiceGrpc.FileStreamServiceStub.

Parameters:

channel - The managed channel to use to connect to the Genie server

Returns:

A FileStreamServiceGrpc.FileStreamServiceStub instance per use