T
- The concrete type of this builder.public abstract class AbstractManagedChannelImplBuilder<T extends AbstractManagedChannelImplBuilder<T>> extends ManagedChannelBuilder<T>
Modifier and Type | Field and Description |
---|---|
protected TransportTracer.Factory |
transportTracerFactory |
Modifier | Constructor and Description |
---|---|
protected |
AbstractManagedChannelImplBuilder(SocketAddress directServerAddress,
String authority) |
protected |
AbstractManagedChannelImplBuilder(String target) |
Modifier and Type | Method and Description |
---|---|
ManagedChannel |
build() |
protected abstract ClientTransportFactory |
buildTransportFactory()
Subclasses should override this method to provide the
ClientTransportFactory
appropriate for this channel. |
protected String |
checkAuthority(String authority)
Verifies the authority is valid.
|
T |
compressorRegistry(CompressorRegistry registry) |
T |
decompressorRegistry(DecompressorRegistry registry) |
T |
defaultLoadBalancingPolicy(String policy) |
T |
defaultServiceConfig(Map<String,?> serviceConfig) |
T |
directExecutor() |
T |
disableRetry() |
T |
disableServiceConfigLookUp() |
T |
enableFullStreamDecompression() |
T |
enableRetry() |
T |
executor(Executor executor) |
static ManagedChannelBuilder<?> |
forAddress(String name,
int port) |
static ManagedChannelBuilder<?> |
forTarget(String target) |
protected int |
getDefaultPort()
Subclasses can override this method to provide a default port to
NameResolver for use
in cases where the target string doesn't include a port. |
T |
idleTimeout(long value,
TimeUnit unit) |
T |
intercept(ClientInterceptor... interceptors) |
T |
intercept(List<ClientInterceptor> interceptors) |
T |
maxHedgedAttempts(int maxHedgedAttempts) |
protected int |
maxInboundMessageSize() |
T |
maxInboundMessageSize(int max)
Sets the maximum message size allowed for a single gRPC frame.
|
T |
maxRetryAttempts(int maxRetryAttempts) |
T |
maxTraceEvents(int maxTraceEvents) |
T |
nameResolverFactory(NameResolver.Factory resolverFactory) |
T |
overrideAuthority(String authority) |
protected T |
overrideCensusStatsModule(CensusStatsModule censusStats)
Override the default stats implementation.
|
T |
perRpcBufferLimit(long bytes) |
T |
proxyDetector(ProxyDetector proxyDetector) |
T |
retryBufferSize(long bytes) |
T |
setBinaryLog(BinaryLog binlog) |
protected void |
setStatsEnabled(boolean value)
Disable or enable stats features.
|
protected void |
setStatsRecordFinishedRpcs(boolean value)
Disable or enable stats recording for RPC completions.
|
protected void |
setStatsRecordRealTimeMetrics(boolean value)
Disable or enable real-time metrics recording.
|
protected void |
setStatsRecordStartedRpcs(boolean value)
Disable or enable stats recording for RPC upstarts.
|
protected void |
setTracingEnabled(boolean value)
Disable or enable tracing features.
|
T |
userAgent(String userAgent) |
keepAliveTime, keepAliveTimeout, keepAliveWithoutCalls, maxInboundMetadataSize, usePlaintext, usePlaintext, useTransportSecurity
protected TransportTracer.Factory transportTracerFactory
protected AbstractManagedChannelImplBuilder(String target)
protected AbstractManagedChannelImplBuilder(SocketAddress directServerAddress, String authority)
public static ManagedChannelBuilder<?> forAddress(String name, int port)
public static ManagedChannelBuilder<?> forTarget(String target)
public T maxInboundMessageSize(int max)
maxInboundMessageSize
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
protected final int maxInboundMessageSize()
public final T directExecutor()
directExecutor
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T executor(Executor executor)
executor
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T intercept(List<ClientInterceptor> interceptors)
intercept
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T intercept(ClientInterceptor... interceptors)
intercept
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T nameResolverFactory(NameResolver.Factory resolverFactory)
nameResolverFactory
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T defaultLoadBalancingPolicy(String policy)
defaultLoadBalancingPolicy
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T enableFullStreamDecompression()
enableFullStreamDecompression
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T decompressorRegistry(DecompressorRegistry registry)
decompressorRegistry
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T compressorRegistry(CompressorRegistry registry)
compressorRegistry
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T userAgent(@Nullable String userAgent)
userAgent
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T overrideAuthority(String authority)
overrideAuthority
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T idleTimeout(long value, TimeUnit unit)
idleTimeout
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T maxRetryAttempts(int maxRetryAttempts)
maxRetryAttempts
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T maxHedgedAttempts(int maxHedgedAttempts)
maxHedgedAttempts
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T retryBufferSize(long bytes)
retryBufferSize
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T perRpcBufferLimit(long bytes)
perRpcBufferLimit
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T disableRetry()
disableRetry
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T enableRetry()
enableRetry
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public final T setBinaryLog(BinaryLog binlog)
setBinaryLog
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public T maxTraceEvents(int maxTraceEvents)
maxTraceEvents
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
protected final T overrideCensusStatsModule(CensusStatsModule censusStats)
public T proxyDetector(@Nullable ProxyDetector proxyDetector)
proxyDetector
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public T defaultServiceConfig(@Nullable Map<String,?> serviceConfig)
defaultServiceConfig
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
public T disableServiceConfigLookUp()
disableServiceConfigLookUp
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
protected void setStatsEnabled(boolean value)
For the current release, calling setStatsEnabled(true)
may have a side effect that
disables retry.
protected void setStatsRecordStartedRpcs(boolean value)
setStatsEnabled(boolean)
is set to true. Enabled by default.protected void setStatsRecordFinishedRpcs(boolean value)
setStatsEnabled(boolean)
is set to true. Enabled by default.protected void setStatsRecordRealTimeMetrics(boolean value)
setStatsEnabled(boolean)
is
set to true. Disabled by default.protected void setTracingEnabled(boolean value)
For the current release, calling setTracingEnabled(true)
may have a side effect that
disables retry.
protected String checkAuthority(String authority)
public ManagedChannel build()
build
in class ManagedChannelBuilder<T extends AbstractManagedChannelImplBuilder<T>>
protected abstract ClientTransportFactory buildTransportFactory()
ClientTransportFactory
appropriate for this channel. This method is meant for Transport implementors and should not
be used by normal users.protected int getDefaultPort()
NameResolver
for use
in cases where the target string doesn't include a port. The default implementation returns
GrpcUtil.DEFAULT_PORT_SSL
.Copyright © 2019. All rights reserved.