Package com.netflix.genie.agent.rpc

Class GRpcAutoConfiguration

java.lang.Object
com.netflix.genie.agent.rpc.GRpcAutoConfiguration
@Configuration public class GRpcAutoConfiguration extends Object
Spring auto configuration for gRPC components.
Since:
4.0.0

  • Constructor Summary

    Constructors
    Constructor
    Description
    GRpcAutoConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.grpc.ManagedChannel
    channel(ArgumentDelegates.ServerArguments serverArguments, List<io.grpc.ClientInterceptor> clientInterceptors)
    Provide a lazy ManagedChannel bean if none was already defined for communicating with the Genie server.
    com.netflix.genie.proto.FileStreamServiceGrpc.FileStreamServiceStub
    fileStreamClient(io.grpc.ManagedChannel channel)
    Provide a prototype bean definition for a FileStreamServiceGrpc.FileStreamServiceStub.
    io.grpc.ClientInterceptor
    genieGrpcTracingClientInterceptor(brave.Tracing tracing)
    Provide a ClientInterceptor which adds tracing information to gRPC calls.
    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 Details

    • GRpcAutoConfiguration

      public GRpcAutoConfiguration()

  • Method Details

    • channel

      @Bean @Lazy @ConditionalOnMissingBean(io.grpc.ManagedChannel.class) public io.grpc.ManagedChannel channel(ArgumentDelegates.ServerArguments serverArguments, List<io.grpc.ClientInterceptor> clientInterceptors)
      Provide a lazy ManagedChannel bean if none was already defined for communicating with the Genie server.
      Parameters:
      serverArguments - The server arguments to use
      clientInterceptors - The list of available client interceptors that should be added to the generated channel
      Returns:
      A ManagedChannel instance configured to use plain text over the wire

    • pingServiceClient

      @Bean @Scope("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("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("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("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("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

    • genieGrpcTracingClientInterceptor

      @Bean @ConditionalOnMissingBean(name="genieGrpcTracingClientInterceptor") @Lazy public io.grpc.ClientInterceptor genieGrpcTracingClientInterceptor(brave.Tracing tracing)
      Provide a ClientInterceptor which adds tracing information to gRPC calls.
      Parameters:
      tracing - The Brave Tracing instance
      Returns:
      A ClientInterceptor for trace propagation