Uses of Class
io.grpc.ExperimentalApi
-
Packages that use ExperimentalApi Package Description io.grpc The gRPC core public API.io.grpc.gcp.csm.observability io.grpc.grpclb io.grpc.inprocess The in-process transport which is for when a server is in the same process as the client.io.grpc.netty The main transport implementation based on Netty, for both the client and the server.io.grpc.okhttp A lightweight transport based on OkHttp, mainly for use on Android (client-only).io.grpc.opentelemetry io.grpc.protobuf API for gRPC over Protocol Buffers, including tools for serializing and de-serializing protobuf messages.io.grpc.protobuf.lite API for gRPC over Protocol Buffers with proto message classes generated by the Lite Runtime library.io.grpc.protobuf.services Service definitions and utilities with protobuf dependency for the pre-defined gRPC services.io.grpc.services Service definitions and utilities for the pre-defined gRPC services.io.grpc.servlet API that implements gRPC server as a servlet.io.grpc.servlet.jakarta API that implements gRPC server as a servlet.io.grpc.stub API for the Stub layer.io.grpc.testing API that is useful for testing gRPC.io.grpc.util Utilities with advanced features in the core layer that user can optionally use.io.grpc.xds Library for gPRC proxyless service mesh using Envoy xDS protocol.io.grpc.xds.orca -
Packages with annotations of type ExperimentalApi Package Description io.grpc.servlet.jakarta API that implements gRPC server as a servlet.io.grpc.servlet API that implements gRPC server as a servlet.io.grpc.xds Library for gPRC proxyless service mesh using Envoy xDS protocol. -
-
Uses of ExperimentalApi in io.grpc
Classes in io.grpc with annotations of type ExperimentalApi Modifier and Type Class Description class
Attributes
An immutable type-safe container of attributes.class
BinaryLog
A binary log that can be installed on a channel or server.class
ChannelLogger
A Channel-specific logger provided by GRPC library toLoadBalancer
implementations.class
ClientStreamTracer
StreamTracer
for the client-side.static class
ClientStreamTracer.StreamInfo
Information about a stream.class
ClientTransportFilter
Listens on the client transport life-cycle events.interface
Codec
Encloses classes related to the compression and decompression of messages.class
CompositeCallCredentials
Uses multipleCallCredentials
as if they were one.interface
Compressor
Represents a message compressor.class
CompressorRegistry
Encloses classes related to the compression and decompression of messages.class
ConnectivityState
The connectivity states.class
ConnectivityStateInfo
A tuple of aConnectivityState
and its associatedStatus
.interface
Decompressor
Represents a message decompressor.class
DecompressorRegistry
Encloses classes related to the compression and decompression of messages.class
EquivalentAddressGroup
A group ofSocketAddress
es that are considered equivalent when channel makes connections.static interface
EquivalentAddressGroup.Attr
Annotation forEquivalentAddressGroup
's attributes.static interface
Grpc.TransportAttr
Annotation for transport attributes.class
LoadBalancer
A pluggable component that receives resolved addresses fromNameResolver
and provides the channel a usable subchannel when asked.static class
LoadBalancer.CreateSubchannelArgs
Arguments for creating aLoadBalancer.Subchannel
.static class
LoadBalancer.CreateSubchannelArgs.Builder
static class
LoadBalancer.CreateSubchannelArgs.Key<T>
Key for a key-value pair.static class
LoadBalancer.Factory
Factory to createLoadBalancer
instance.static class
LoadBalancer.Helper
Provides essentials for LoadBalancer implementations.static class
LoadBalancer.PickResult
A balancing decision made bySubchannelPicker
for an RPC.static class
LoadBalancer.PickSubchannelArgs
Provides arguments for aLoadBalancer.SubchannelPicker.pickSubchannel( LoadBalancer.PickSubchannelArgs)
.static class
LoadBalancer.ResolvedAddresses
Represents a combination of the resolved server address, associated attributes and a load balancing policy config.static class
LoadBalancer.ResolvedAddresses.Builder
Builder forLoadBalancer.ResolvedAddresses
.static class
LoadBalancer.Subchannel
A logical connection to a server, or a group of equivalent servers represented by anEquivalentAddressGroup
.static class
LoadBalancer.SubchannelPicker
The main balancing logic.class
LoadBalancerProvider
Provider ofLoadBalancer
s.class
LoadBalancerRegistry
Registry ofLoadBalancerProvider
s.static interface
Metadata.BinaryStreamMarshaller<T>
Marshaller for metadata values that are serialized to an InputStream.static interface
MethodDescriptor.PrototypeMarshaller<T>
A marshaller that uses a fixed instance of the type it produces.static interface
MethodDescriptor.ReflectableMarshaller<T>
A marshaller that supports retrieving its type parameterT
at runtime.class
NameResolver
A pluggable component that resolves a targetURI
and return addresses to the caller.static class
NameResolver.Args
Information that aNameResolver.Factory
uses to create aNameResolver
.static class
NameResolver.ConfigOrError
Represents either a successfully parsed service config, containing all necessary parts to be later applied by the channel, or a Status containing the error encountered while parsing.static class
NameResolver.Factory
Factory that createsNameResolver
instances.static interface
NameResolver.Listener
Receives address updates.static class
NameResolver.Listener2
Receives address updates.static class
NameResolver.ResolutionResult
Represents the results from a Name Resolver.static class
NameResolver.ResolutionResult.Builder
A builder forNameResolver.ResolutionResult
.static interface
NameResolver.ResolutionResultAttr
Annotation for name resolution result attributes.static class
NameResolver.ServiceConfigParser
Parses and validates service configuration.class
NameResolverProvider
Provider of name resolvers for name agnostic consumption.class
NameResolverRegistry
Registry ofNameResolverProvider
s.class
SecurityLevel
The level of security guarantee in communications.interface
ServerCallExecutorSupplier
Defines what executor handles the server call, based on each RPC call information at runtime.class
ServerStreamTracer
Listens to events on a stream to collect metrics.class
ServerTransportFilter
Listens on server transport life-cycle events, with the capability to read and/or change transport attributes.class
StatusOr<T>
Either a Status or a value.class
StreamTracer
Listens to events on a stream to collect metrics.Fields in io.grpc with annotations of type ExperimentalApi Modifier and Type Field Description static Attributes.Key<String>
EquivalentAddressGroup. ATTR_AUTHORITY_OVERRIDE
The authority to be used when constructing Subchannels for this EquivalentAddressGroup.static Attributes.Key<SocketAddress>
Grpc. TRANSPORT_ATTR_LOCAL_ADDR
Attribute key for the local address of a transport.static Attributes.Key<SocketAddress>
Grpc. TRANSPORT_ATTR_REMOTE_ADDR
Attribute key for the remote address of a transport.static Attributes.Key<SSLSession>
Grpc. TRANSPORT_ATTR_SSL_SESSION
Attribute key for SSL session of a transport.Methods in io.grpc with annotations of type ExperimentalApi Modifier and Type Method Description T
ServerBuilder. addStreamTracerFactory(ServerStreamTracer.Factory factory)
Adds aServerStreamTracer.Factory
to measure server-side traffic.T
ManagedChannelBuilder. addTransportFilter(ClientTransportFilter filter)
Adds aClientTransportFilter
.T
ServerBuilder. addTransportFilter(ServerTransportFilter filter)
Adds aServerTransportFilter
.T
ServerBuilder. callExecutor(ServerCallExecutorSupplier executorSupplier)
Allows for defining a way to provide a custom executor to handle the server call.CallOptions
CallOptions. clearOnReadyThreshold()
Resets to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.abstract T
ManagedChannelBuilder. compressorRegistry(CompressorRegistry registry)
Set the compression registry for use in the channel.abstract T
ServerBuilder. compressorRegistry(CompressorRegistry registry)
Set the compression registry for use in the channel.abstract T
ManagedChannelBuilder. decompressorRegistry(DecompressorRegistry registry)
Set the decompression registry for use in the channel.abstract T
ServerBuilder. decompressorRegistry(DecompressorRegistry registry)
Set the decompression registry for use in the channel.T
ManagedChannelBuilder. defaultLoadBalancingPolicy(String policy)
Sets the default load-balancing policy that will be used if the service config doesn't specify one.T
ManagedChannelBuilder. defaultServiceConfig(Map<String,?> serviceConfig)
Provides a service config to the channel.T
ManagedChannelBuilder. disableServiceConfigLookUp()
Disables service config look-up from the naming system, which is enabled by default.<T> void
Metadata. discardAll(Metadata.Key<T> key)
Remove all values for the given key without returning them.void
ManagedChannel. enterIdle()
Invoking this method moves the channel into the IDLE state and triggers tear-down of the channel's name resolver and load balancer, while still allowing on-going RPCs on the channel to continue.static String
MethodDescriptor. extractBareMethodName(String fullMethodName)
Extract the method name out of a fully qualified method name.Set<String>
DecompressorRegistry. getAdvertisedMessageEncodings()
Provides a list of all message encodings that have decompressors available and should be advertised.Attributes
ClientCall. getAttributes()
Returns additional properties of the call.Attributes
ServerCall. getAttributes()
Returns properties of a single call.String
CallOptions. getAuthority()
Override the HTTP/2 authority the channel claims to be connecting to.String
MethodDescriptor. getBareMethodName()
A convenience method forextractBareMethodName(getFullMethodName())
.ChannelLogger
NameResolver.Args. getChannelLogger()
Returns theChannelLogger
for the Channel served by this NameResolver.List<ServerServiceDefinition>
Server. getImmutableServices()
Returns immutable services registered with the server, or an empty list if not supported by the implementation.Integer
CallOptions. getMaxInboundMessageSize()
Gets the maximum allowed message size acceptable from the remote peer.Integer
CallOptions. getMaxOutboundMessageSize()
Gets the maximum allowed message size acceptable to send the remote peer.List<ServerServiceDefinition>
Server. getMutableServices()
Returns mutable services registered with the server, or an empty list if not supported by the implementation.Integer
CallOptions. getOnReadyThreshold()
Returns to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.<T> T
CallOptions. getOption(CallOptions.Key<T> key)
Get the value for a custom option or its inherent default.String
NameResolver.Args. getOverrideAuthority()
Returns the overrideAuthority from channelManagedChannelBuilder.overrideAuthority(java.lang.String)
.ScheduledExecutorService
NameResolver.Args. getScheduledExecutorService()
Returns aScheduledExecutorService
for scheduling delayed tasks.Object
ServiceDescriptor. getSchemaDescriptor()
Returns the schema descriptor for this service.SecurityLevel
ServerCall. getSecurityLevel()
Returns the level of security guarantee in communicationsString
MethodDescriptor. getServiceName()
A convenience method forextractFullServiceName(getFullMethodName())
.List<ServerServiceDefinition>
HandlerRegistry. getServices()
Returns theServerServiceDefinition
s provided by the registry, or an empty list if not supported by the implementation.List<ServerServiceDefinition>
Server. getServices()
Returns all services registered with the server, or an empty list if not supported by the implementation.ConnectivityState
ManagedChannel. getState(boolean requestConnection)
Gets the current connectivity state.List<ClientStreamTracer.Factory>
CallOptions. getStreamTracerFactories()
Returns an immutable list ofClientStreamTracerFactory
s.abstract T
ManagedChannelBuilder. idleTimeout(long value, TimeUnit unit)
Set the duration without ongoing RPCs before going to idle mode.void
LoadBalancer.Helper. ignoreRefreshNameResolutionCheck()
Deprecated.Warning has been removedT
ServerBuilder. keepAliveTime(long keepAliveTime, TimeUnit timeUnit)
Sets the time without read activity before sending a keepalive ping.T
ServerBuilder. keepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit)
Sets a time waiting for read activity after sending a keepalive ping.T
ServerBuilder. maxConnectionAge(long maxConnectionAge, TimeUnit timeUnit)
Sets the maximum connection age, connections lasting longer than which will be gracefully terminated.T
ServerBuilder. maxConnectionAgeGrace(long maxConnectionAgeGrace, TimeUnit timeUnit)
Sets the grace time for the graceful connection termination.T
ServerBuilder. maxConnectionIdle(long maxConnectionIdle, TimeUnit timeUnit)
Sets the maximum connection idle time, connections being idle for longer than which will be gracefully terminated.T
ManagedChannelBuilder. maxHedgedAttempts(int maxHedgedAttempts)
Sets the maximum number of hedged attempts that may be configured by the service config.T
ManagedChannelBuilder. maxRetryAttempts(int maxRetryAttempts)
Sets the maximum number of retry attempts that may be configured by the service config.T
ManagedChannelBuilder. maxTraceEvents(int maxTraceEvents)
Sets the maximum number of channel trace events to keep in the tracer for each channel or subchannel.abstract T
ManagedChannelBuilder. nameResolverFactory(NameResolver.Factory resolverFactory)
Deprecated.Most usages should use a globally-registeredNameResolverProvider
instead, with either the SPI mechanism orNameResolverRegistry.register(io.grpc.NameResolverProvider)
.void
ManagedChannel. notifyWhenStateChanged(ConnectivityState source, Runnable callback)
Registers a one-off callback that will be run if the connectivity state of the channel diverges from the givensource
, which is typically what has just been returned byManagedChannel.getState(boolean)
.static <T> CallOptions.Key<T>
CallOptions.Key. of(String debugString, T defaultValue)
Deprecated.static <T> Metadata.Key<T>
Metadata.Key. of(String name, Metadata.BinaryStreamMarshaller<T> marshaller)
Creates a key for a binary header, serializing to input streams.T
ServerBuilder. permitKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)
Specify the most aggressive keep-alive time clients are permitted to configure.T
ServerBuilder. permitKeepAliveWithoutCalls(boolean permit)
Sets whether to allow clients to send keep-alive HTTP/2 PINGs even if there are no outstanding RPCs on the connection.T
ManagedChannelBuilder. perRpcBufferLimit(long bytes)
Sets the per RPC buffer limit in bytes used for retry.void
ManagedChannel. resetConnectBackoff()
For subchannels that are in TRANSIENT_FAILURE state, short-circuit the backoff timer and make them reconnect immediately.T
ManagedChannelBuilder. retryBufferSize(long bytes)
Sets the retry buffer size in bytes.T
ManagedChannelBuilder. setBinaryLog(BinaryLog binaryLog)
Sets the BinaryLog object that this channel should log to.T
ServerBuilder. setBinaryLog(BinaryLog binaryLog)
Sets the BinaryLog object that this server should log to.NameResolver.Args.Builder
NameResolver.Args.Builder. setChannelLogger(ChannelLogger channelLogger)
ServiceDescriptor.Builder
ServiceDescriptor.Builder. setName(String name)
Sets the name.void
ServerCall. setOnReadyThreshold(int numBytes)
A hint to the call that specifies how many bytes must be queued beforeServerCall.isReady()
will return false.NameResolver.Args.Builder
NameResolver.Args.Builder. setOverrideAuthority(String authority)
NameResolver.Args.Builder
NameResolver.Args.Builder. setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)
static Status
Contexts. statusFromCancelled(Context context)
Returns theStatus
of a cancelled context ornull
if the context is not cancelled.void
CallCredentials. thisUsesUnstableApi()
Deprecated.static ServerServiceDefinition
ServerInterceptors. useInputStreamMessages(ServerServiceDefinition serviceDef)
Create a newServerServiceDefinition
whoseMethodDescriptor
serializes to and from InputStream for all methods.static <ReqT,RespT>
ServerServiceDefinitionServerInterceptors. useMarshalledMessages(ServerServiceDefinition serviceDef, MethodDescriptor.Marshaller<ReqT> requestMarshaller, MethodDescriptor.Marshaller<RespT> responseMarshaller)
Create a newServerServiceDefinition
withMethodDescriptor
for deserializing requests and separateMethodDescriptor
for serializing responses.static <T> ServerServiceDefinition
ServerInterceptors. useMarshalledMessages(ServerServiceDefinition serviceDef, MethodDescriptor.Marshaller<T> marshaller)
Create a newServerServiceDefinition
whoseMethodDescriptor
serializes to and from T for all methods.CallOptions
CallOptions. withAuthority(String authority)
Override the HTTP/2 authority the channel claims to be connecting to.CallOptions
CallOptions. withMaxInboundMessageSize(int maxSize)
Sets the maximum allowed message size acceptable from the remote peer.CallOptions
CallOptions. withMaxOutboundMessageSize(int maxSize)
Sets the maximum allowed message size acceptable sent to the remote peer.CallOptions
CallOptions. withOnReadyThreshold(int numBytes)
Specifies how many bytes must be queued before the call is considered not ready to send more messages.CallOptions
CallOptions. withStreamTracerFactory(ClientStreamTracer.Factory factory)
Returns a newCallOptions
with aClientStreamTracerFactory
in addition to the existing factories. -
Uses of ExperimentalApi in io.grpc.gcp.csm.observability
Classes in io.grpc.gcp.csm.observability with annotations of type ExperimentalApi Modifier and Type Class Description class
CsmObservability
The entrypoint for GCP's CSM OpenTelemetry metrics functionality in gRPC.static class
CsmObservability.Builder
Builder for configuringCsmObservability
. -
Uses of ExperimentalApi in io.grpc.grpclb
Classes in io.grpc.grpclb with annotations of type ExperimentalApi Modifier and Type Class Description class
GrpclbConstants
Constants for the GRPCLB load-balancer. -
Uses of ExperimentalApi in io.grpc.inprocess
Classes in io.grpc.inprocess with annotations of type ExperimentalApi Modifier and Type Class Description class
AnonymousInProcessSocketAddress
Custom SocketAddress class forInProcessTransport
, for a server which can only be referenced via this address instance.class
InProcessChannelBuilder
Builder for a channel that issues in-process requests.class
InProcessServerBuilder
Builder for a server that services in-process requests. -
Uses of ExperimentalApi in io.grpc.netty
Classes in io.grpc.netty with annotations of type ExperimentalApi Modifier and Type Class Description class
GrpcSslContexts
Utility for configuring SslContext for gRPC.class
InsecureFromHttp1ChannelCredentials
An insecure credential that upgrades from HTTP/1 to HTTP/2.class
NegotiationType
Identifies the negotiation used for starting up HTTP/2.class
NettyChannelBuilder
A builder to help simplify construction of channels using the Netty transport.static class
NettyChannelBuilder.LocalSocketPicker
This class is meant to be overriden with a custom implementation ofNettyChannelBuilder.LocalSocketPicker.createSocketAddress(java.net.SocketAddress, io.grpc.Attributes)
.class
NettyServerBuilder
A builder to help simplify the construction of a Netty-based GRPC server.class
NettySslContextChannelCredentials
A credential that performs TLS with Netty's SslContext as configuration.class
NettySslContextServerCredentials
A credential that performs TLS with Netty's SslContext as configuration.Methods in io.grpc.netty with annotations of type ExperimentalApi Modifier and Type Method Description static SslContextBuilder
GrpcSslContexts. configure(SslContextBuilder builder, SslProvider provider)
Set ciphers and APN appropriate for gRPC. -
Uses of ExperimentalApi in io.grpc.okhttp
Classes in io.grpc.okhttp with annotations of type ExperimentalApi Modifier and Type Class Description class
OkHttpChannelBuilder
Convenience class for building channels with the OkHttp transport.class
OkHttpServerBuilder
Build servers with the OkHttp transport.class
SslSocketFactoryChannelCredentials
A credential with full control over the SSLSocketFactory.class
SslSocketFactoryServerCredentials
A credential with full control over the SSLSocketFactory. -
Uses of ExperimentalApi in io.grpc.opentelemetry
Classes in io.grpc.opentelemetry with annotations of type ExperimentalApi Modifier and Type Class Description class
GrpcTraceBinContextPropagator
ATextMapPropagator
for transmitting "grpc-trace-bin" span context.Methods in io.grpc.opentelemetry with annotations of type ExperimentalApi Modifier and Type Method Description void
GrpcOpenTelemetry. registerGlobal()
Registers GrpcOpenTelemetry globally, applying its configuration to all subsequently created gRPC channels and servers. -
Uses of ExperimentalApi in io.grpc.protobuf
Classes in io.grpc.protobuf with annotations of type ExperimentalApi Modifier and Type Class Description class
StatusProto
Utility methods for working withStatus
.Methods in io.grpc.protobuf with annotations of type ExperimentalApi Modifier and Type Method Description static <T extends Message>
MethodDescriptor.Marshaller<T>ProtoUtils. marshallerWithRecursionLimit(T defaultInstance, int recursionLimit)
Creates aMethodDescriptor.Marshaller
for protos of the same type asdefaultInstance
and a custom limit for the recursion depth. -
Uses of ExperimentalApi in io.grpc.protobuf.lite
Classes in io.grpc.protobuf.lite with annotations of type ExperimentalApi Modifier and Type Class Description class
ProtoLiteUtils
Utility methods for using protobuf with grpc.Methods in io.grpc.protobuf.lite with annotations of type ExperimentalApi Modifier and Type Method Description static <T extends MessageLite>
MethodDescriptor.Marshaller<T>ProtoLiteUtils. marshallerWithRecursionLimit(T defaultInstance, int recursionLimit)
Creates aMethodDescriptor.Marshaller
for protos of the same type asdefaultInstance
and a custom limit for the recursion depth. -
Uses of ExperimentalApi in io.grpc.protobuf.services
Classes in io.grpc.protobuf.services with annotations of type ExperimentalApi Modifier and Type Class Description class
BinaryLogs
interface
BinaryLogSink
A class that accepts binary log messages.class
ChannelzService
The channelz service provides stats about a running gRPC process.class
HealthCheckingLoadBalancerUtil
Utility for enabling client-side health checking forLoadBalancer
s.class
HealthStatusManager
AHealthStatusManager
object manages a health check service.class
ProtoReflectionService
Provides a reflection service for Protobuf services (including the reflection service itself).class
ProtoReflectionServiceV1
Provides a reflection service for Protobuf services (including the reflection service itself). -
Uses of ExperimentalApi in io.grpc.services
Classes in io.grpc.services with annotations of type ExperimentalApi Modifier and Type Class Description class
AdminInterface
Admin Interface provides a class of services for exposing the overall state of gRPC activity in a given binary.class
CallMetricRecorder
Utility to record call metrics for load-balancing.class
ChannelzService
Deprecated.UseChannelzService
instead.class
HealthStatusManager
Deprecated.UseHealthStatusManager
instead.class
MetricRecorder
Implements the service/APIs for Out-of-Band metrics reporting, only for utilization metrics.class
MetricReport
A gRPC object of orca load report. -
Uses of ExperimentalApi in io.grpc.servlet
Classes in io.grpc.servlet with annotations of type ExperimentalApi Modifier and Type Class Description class
GrpcServlet
A simple servlet backed by a gRPC server.class
ServletAdapter
An adapter that transformsHttpServletRequest
into gRPC request and lets a gRPC server process it, and transforms the gRPC response intoHttpServletResponse
.class
ServletServerBuilder
Builder to build a gRPC server that can run as a servlet. -
Uses of ExperimentalApi in io.grpc.servlet.jakarta
Classes in io.grpc.servlet.jakarta with annotations of type ExperimentalApi Modifier and Type Class Description class
GrpcServlet
A simple servlet backed by a gRPC server.class
ServletAdapter
An adapter that transformsHttpServletRequest
into gRPC request and lets a gRPC server process it, and transforms the gRPC response intoHttpServletResponse
.class
ServletServerBuilder
Builder to build a gRPC server that can run as a servlet. -
Uses of ExperimentalApi in io.grpc.stub
Classes in io.grpc.stub with annotations of type ExperimentalApi Modifier and Type Class Description class
CallStreamObserver<V>
A refinement of StreamObserver provided by the GRPC runtime to the application (the client or the server) that allows for more complex interactions with call behavior.class
StreamObservers
Deprecated.Of questionable utility and generally not used.Methods in io.grpc.stub with annotations of type ExperimentalApi Modifier and Type Method Description static ServerInterceptor
MetadataUtils. newAttachMetadataServerInterceptor(Metadata extras)
Returns a ServerInterceptor that adds the specified Metadata to every response stream, one way or another.void
ServerCallStreamObserver. setOnCloseHandler(Runnable onCloseHandler)
Sets aRunnable
to be executed when the call is closed cleanly from the server's point of view: eitherStreamObserver.onCompleted()
orStreamObserver.onError(Throwable)
has been called, all the messages and trailing metadata have been sent and the stream has been closed.void
ServerCallStreamObserver. setOnReadyThreshold(int numBytes)
A hint to the call that specifies how many bytes must be queued beforeServerCallStreamObserver.isReady()
will return false.S
AbstractStub. withMaxInboundMessageSize(int maxSize)
Returns a new stub that limits the maximum acceptable message size from a remote peer.S
AbstractStub. withMaxOutboundMessageSize(int maxSize)
Returns a new stub that limits the maximum acceptable message size to send a remote peer.S
AbstractStub. withOnReadyThreshold(int numBytes)
Returns a new stub that limits the maximum number of bytes per stream in the queue.<T> S
AbstractStub. withOption(CallOptions.Key<T> key, T value)
Sets a custom option to be passed to client interceptors on the channelClientInterceptor
via the CallOptions parameter. -
Uses of ExperimentalApi in io.grpc.testing
Classes in io.grpc.testing with annotations of type ExperimentalApi Modifier and Type Class Description class
StreamRecorder<T>
Deprecated.Not for public useclass
TestUtils
Common utility functions useful for writing tests.class
TlsTesting
Convenience utilities for using TLS in tests. -
Uses of ExperimentalApi in io.grpc.util
Classes in io.grpc.util with annotations of type ExperimentalApi Modifier and Type Class Description class
CertificateUtils
Contains certificate/key PEM file utility method(s).class
ForwardingClientStreamTracer
class
ForwardingLoadBalancer
class
ForwardingLoadBalancerHelper
class
ForwardingSubchannel
class
GracefulSwitchLoadBalancer
A load balancer that gracefully swaps to a new lb policy.class
TransmitStatusRuntimeExceptionInterceptor
A class that intercepts uncaught exceptions of typeStatusRuntimeException
and handles them by closing theServerCall
, and transmitting the exception's status and metadata to the client.Methods in io.grpc.util with annotations of type ExperimentalApi Modifier and Type Method Description List<ServerServiceDefinition>
MutableHandlerRegistry. getServices()
Note: This does not necessarily return a consistent view of the map.void
AdvancedTlsX509KeyManager. updateIdentityCredentials(PrivateKey key, X509Certificate[] certs)
void
AdvancedTlsX509KeyManager. updateIdentityCredentialsFromFile(File keyFile, File certFile)
Deprecated.AdvancedTlsX509KeyManager.Closeable
AdvancedTlsX509KeyManager. updateIdentityCredentialsFromFile(File keyFile, File certFile, long period, TimeUnit unit, ScheduledExecutorService executor)
void
AdvancedTlsX509TrustManager. updateTrustCredentialsFromFile(File trustCertFile)
Deprecated.AdvancedTlsX509TrustManager.Closeable
AdvancedTlsX509TrustManager. updateTrustCredentialsFromFile(File trustCertFile, long period, TimeUnit unit, ScheduledExecutorService executor)
-
Uses of ExperimentalApi in io.grpc.xds
Classes in io.grpc.xds with annotations of type ExperimentalApi Modifier and Type Class Description class
RingHashOptions
Utility class that provides a way to configure ring hash size limits.class
XdsChannelCredentials
class
XdsServerBuilder
A version ofServerBuilder
to create xDS managed servers.class
XdsServerCredentials
Methods in io.grpc.xds with annotations of type ExperimentalApi Modifier and Type Method Description static long
RingHashOptions. getRingSizeCap()
Get the global limit for min and max ring hash sizes.static void
RingHashOptions. setRingSizeCap(long ringSizeCap)
Set the global limit for the min and max number of ring hash entries per ring. -
Uses of ExperimentalApi in io.grpc.xds.orca
Classes in io.grpc.xds.orca with annotations of type ExperimentalApi Modifier and Type Class Description class
OrcaMetricReportingServerInterceptor
AServerInterceptor
that intercepts aServerCall
by running server-side RPC handling under aContext
that records custom per-request metrics provided by server applications and sends to client side along with the response in the format of Open Request Cost Aggregation (ORCA).class
OrcaOobUtil
Utility class that provides method forLoadBalancer
to install listeners to receive out-of-band backend metrics in the format of Open Request Cost Aggregation (ORCA).class
OrcaPerRequestUtil
Utility class that provides method forLoadBalancer
to install listeners to receive per-request backend cost metrics in the format of Open Request Cost Aggregation (ORCA).class
OrcaServiceImpl
Implements aBindableService
that generates Out-Of-Band server metrics.
-