org.apache.beam.sdk.fn.channel

Class ManagedChannelFactory

java.lang.Object

org.apache.beam.sdk.fn.channel.ManagedChannelFactory

Direct Known Subclasses:

InProcessManagedChannelFactory

public abstract class ManagedChannelFactory
extends java.lang.Object

A Factory which creates an underlying ManagedChannel implementation.

Constructor Summary

Constructors

Constructor and Description
ManagedChannelFactory()

Method Summary

Modifier and Type	Method and Description
protected abstract org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannelBuilder<?>	builderFor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor descriptor) Create a ManagedChannelBuilder for the provided Endpoints.ApiServiceDescriptor.
static ManagedChannelFactory	createDefault()
static ManagedChannelFactory	createEpoll()
org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannel	forDescriptor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)
ManagedChannelFactory	withInterceptors(java.util.List<org.apache.beam.vendor.grpc.v1.io.grpc.ClientInterceptor> interceptors) Returns a ManagedChannelFactory like this one, but which will apply the provided ClientInterceptors to any channel it creates.

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagedChannelFactory

public ManagedChannelFactory()

Method Detail

createDefault

public static ManagedChannelFactory createDefault()

createEpoll

public static ManagedChannelFactory createEpoll()

forDescriptor

public org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannel forDescriptor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor apiServiceDescriptor)

builderFor

protected abstract org.apache.beam.vendor.grpc.v1.io.grpc.ManagedChannelBuilder<?> builderFor(org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor descriptor)

Create a ManagedChannelBuilder for the provided Endpoints.ApiServiceDescriptor.

withInterceptors

public ManagedChannelFactory withInterceptors(java.util.List<org.apache.beam.vendor.grpc.v1.io.grpc.ClientInterceptor> interceptors)

Returns a ManagedChannelFactory like this one, but which will apply the provided ClientInterceptors to any channel it creates.