public static final class InstantiatingGrpcChannelProvider . Builder
Methods
build()
public InstantiatingGrpcChannelProvider build ()
getChannelConfigurator()
public ApiFunction<ManagedChannelBuilder , ManagedChannelBuilder > getChannelConfigurator ()
Returns Type Description ApiFunction <io.grpc.ManagedChannelBuilder ,io.grpc.ManagedChannelBuilder >
getEndpoint()
public String getEndpoint ()
getKeepAliveTime()
public Duration getKeepAliveTime ()
The time without read activity before sending a keepalive ping.
Returns Type Description org.threeten.bp.Duration
getKeepAliveTimeout()
public Duration getKeepAliveTimeout ()
The time without read activity after sending a keepalive ping.
Returns Type Description org.threeten.bp.Duration
getKeepAliveWithoutCalls()
public Boolean getKeepAliveWithoutCalls ()
Whether keepalive will be performed when there are no outstanding RPCs.
getMaxInboundMessageSize()
public Integer getMaxInboundMessageSize ()
The maximum message size allowed to be received on the channel.
public Integer getMaxInboundMetadataSize ()
Beta
The surface for maximum metadata size is not stable yet and may change in the future.
This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.
The maximum metadata size allowed to be received on the channel.
getPoolSize() (deprecated)
Returns Type Description int
setAllowNonDefaultServiceAccount(boolean allowNonDefaultServiceAccount)
public InstantiatingGrpcChannelProvider . Builder setAllowNonDefaultServiceAccount ( boolean allowNonDefaultServiceAccount )
Internal Only : This feature is not stable for application use.
For internal use by google-cloud-java clients only
Whether allow non-default service account for DirectPath.
Parameter Name Description allowNonDefaultServiceAccount
boolean
setAttemptDirectPath(boolean attemptDirectPath)
public InstantiatingGrpcChannelProvider . Builder setAttemptDirectPath ( boolean attemptDirectPath )
Internal Only : This feature is not stable for application use.
For internal use by google-cloud-java clients only
Whether attempt DirectPath.
Parameter Name Description attemptDirectPath
boolean
setAttemptDirectPathXds()
public InstantiatingGrpcChannelProvider . Builder setAttemptDirectPathXds ()
Internal Only : This feature is not stable for application use.
For internal use by google-cloud-java clients only
Use DirectPath xDS. Only valid if DirectPath is attempted.
setChannelConfigurator(ApiFunction<ManagedChannelBuilder,ManagedChannelBuilder> channelConfigurator)
public InstantiatingGrpcChannelProvider . Builder setChannelConfigurator ( ApiFunction<ManagedChannelBuilder , ManagedChannelBuilder > channelConfigurator )
Beta
Surface for advanced channel configuration is not yet stable
This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.
Add a callback that can intercept channel creation.
This can be used for advanced configuration like setting the netty event loop. The
callback will be invoked with a fully configured channel builder, which the callback can
augment or replace.
Parameter Name Description channelConfigurator
ApiFunction <io.grpc.ManagedChannelBuilder ,io.grpc.ManagedChannelBuilder >
setChannelPoolSettings(ChannelPoolSettings settings)
public InstantiatingGrpcChannelProvider . Builder setChannelPoolSettings ( ChannelPoolSettings settings )
Beta
Channel pool sizing api is not yet stable
This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.
setChannelPrimer(ChannelPrimer channelPrimer)
public InstantiatingGrpcChannelProvider . Builder setChannelPrimer ( ChannelPrimer channelPrimer )
Internal Only : This feature is not stable for application use.
For internal use by google-cloud-java clients only
By setting a channelPrimer, the ChannelPool created by the provider will be refreshing
ChannelPool. channelPrimer will be invoked periodically when the channels are refreshed
This is public only for technical reasons, for advanced usage.
Parameter Name Description channelPrimer
ChannelPrimer
invoked when the channels are refreshed
setChannelsPerCpu(double multiplier) (deprecated)
public InstantiatingGrpcChannelProvider . Builder setChannelsPerCpu ( double multiplier )
Parameter Name Description multiplier
double
setChannelsPerCpu(double multiplier, int maxChannels) (deprecated)
public InstantiatingGrpcChannelProvider . Builder setChannelsPerCpu ( double multiplier , int maxChannels )
Parameters Name Description multiplier
double
maxChannels
int
setCredentials(Credentials credentials)
public InstantiatingGrpcChannelProvider . Builder setCredentials ( Credentials credentials )
Parameter Name Description credentials
com.google.auth.Credentials
setDirectPathServiceConfig(Map<String,?> serviceConfig)
public InstantiatingGrpcChannelProvider . Builder setDirectPathServiceConfig ( Map<String , ? > serviceConfig )
Internal Only : This feature is not stable for application use.
For internal use by google-cloud-java clients only
Sets a service config for direct path. If direct path is not enabled, the provided service
config will be ignored.
See
the service config proto definition for more details.
Parameter Name Description serviceConfig
Map <String ,? >
setEndpoint(String endpoint)
public InstantiatingGrpcChannelProvider . Builder setEndpoint ( String endpoint )
Sets the endpoint used to reach the service, eg "localhost:8080".
Parameter Name Description endpoint
String
setExecutor(Executor executor)
public InstantiatingGrpcChannelProvider . Builder setExecutor ( Executor executor )
Sets the Executor for this TransportChannelProvider.
This is optional; if it is not provided, needsExecutor() will return true, meaning that an
Executor must be provided when getChannel is called on the constructed
TransportChannelProvider instance. Note: GrpcTransportProvider will automatically provide its
own Executor in this circumstance when it calls getChannel.
Parameter Name Description executor
Executor
setExecutorProvider(ExecutorProvider executorProvider) (deprecated)
public InstantiatingGrpcChannelProvider . Builder setExecutorProvider ( ExecutorProvider executorProvider )
public InstantiatingGrpcChannelProvider . Builder setHeaderProvider ( HeaderProvider headerProvider )
Sets the HeaderProvider for this TransportChannelProvider.
This is optional; if it is not provided, needsHeaders() will return true, meaning that
headers must be provided when getChannel is called on the constructed
TransportChannelProvider instance.
setInterceptorProvider(GrpcInterceptorProvider interceptorProvider)
public InstantiatingGrpcChannelProvider . Builder setInterceptorProvider ( GrpcInterceptorProvider interceptorProvider )
Sets the GrpcInterceptorProvider for this TransportChannelProvider.
The provider will be called once for each underlying gRPC ManagedChannel that is created.
It is recommended to return a new list of new interceptors on each call so that interceptors
are not shared among channels, but this is not required.
setKeepAliveTime(Duration duration)
public InstantiatingGrpcChannelProvider . Builder setKeepAliveTime ( Duration duration )
The time without read activity before sending a keepalive ping.
Parameter Name Description duration
org.threeten.bp.Duration
setKeepAliveTimeout(Duration duration)
public InstantiatingGrpcChannelProvider . Builder setKeepAliveTimeout ( Duration duration )
The time without read activity after sending a keepalive ping.
Parameter Name Description duration
org.threeten.bp.Duration
setKeepAliveWithoutCalls(Boolean keepalive)
public InstantiatingGrpcChannelProvider . Builder setKeepAliveWithoutCalls ( Boolean keepalive )
Whether keepalive will be performed when there are no outstanding RPCs.
Parameter Name Description keepalive
Boolean
setMaxInboundMessageSize(Integer max)
public InstantiatingGrpcChannelProvider . Builder setMaxInboundMessageSize ( Integer max )
The maximum message size allowed to be received on the channel.
public InstantiatingGrpcChannelProvider . Builder setMaxInboundMetadataSize ( Integer max )
Beta
The surface for maximum metadata size is not stable yet and may change in the future.
This feature is covered by the Pre-GA Offerings Terms of the Terms of Service. Pre-GA libraries might have limited support, and changes to pre-GA libraries might not be compatible with other pre-GA versions. For more information, see the launch stage descriptions.
The maximum metadata size allowed to be received on the channel.
setPoolSize(int poolSize) (deprecated)
public InstantiatingGrpcChannelProvider . Builder setPoolSize ( int poolSize )
Parameter Name Description poolSize
int