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.health.v1 io.grpc.inprocess The in-process transport which is for when a server is in the same process as the client.io.grpc.lb.v1 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.reflection.v1 io.grpc.reflection.v1alpha 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 gRPC 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 gRPC 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 classAttributesAn immutable type-safe container of attributes.classBinaryLogA binary log that can be installed on a channel or server.classChannelLoggerA Channel-specific logger provided by GRPC library toLoadBalancerimplementations.classClientStreamTracerStreamTracerfor the client-side.static classClientStreamTracer.StreamInfoInformation about a stream.classClientTransportFilterListens on the client transport life-cycle events.interfaceCodecEncloses classes related to the compression and decompression of messages.classCompositeCallCredentialsUses multipleCallCredentialsas if they were one.interfaceCompressorRepresents a message compressor.classCompressorRegistryEncloses classes related to the compression and decompression of messages.classConnectivityStateThe connectivity states.classConnectivityStateInfoA tuple of aConnectivityStateand its associatedStatus.interfaceDecompressorRepresents a message decompressor.classDecompressorRegistryEncloses classes related to the compression and decompression of messages.classEquivalentAddressGroupA group ofSocketAddresses that are considered equivalent when channel makes connections.static interfaceEquivalentAddressGroup.AttrAnnotation forEquivalentAddressGroup's attributes.static interfaceGrpc.TransportAttrAnnotation for transport attributes.classLoadBalancerA pluggable component that receives resolved addresses fromNameResolverand provides the channel a usable subchannel when asked.static classLoadBalancer.CreateSubchannelArgsArguments for creating aLoadBalancer.Subchannel.static classLoadBalancer.CreateSubchannelArgs.Builderstatic classLoadBalancer.CreateSubchannelArgs.Key<T>Key for a key-value pair.static classLoadBalancer.FactoryFactory to createLoadBalancerinstance.static classLoadBalancer.HelperProvides essentials for LoadBalancer implementations.static classLoadBalancer.PickResultA balancing decision made bySubchannelPickerfor an RPC.static classLoadBalancer.PickSubchannelArgsProvides arguments for aLoadBalancer.SubchannelPicker.pickSubchannel( LoadBalancer.PickSubchannelArgs).static classLoadBalancer.ResolvedAddressesRepresents a combination of the resolved server address, associated attributes and a load balancing policy config.static classLoadBalancer.ResolvedAddresses.BuilderBuilder forLoadBalancer.ResolvedAddresses.static classLoadBalancer.SubchannelA logical connection to a server, or a group of equivalent servers represented by anEquivalentAddressGroup.static classLoadBalancer.SubchannelPickerThe main balancing logic.classLoadBalancerProviderProvider ofLoadBalancers.classLoadBalancerRegistryRegistry ofLoadBalancerProviders.static interfaceMetadata.BinaryStreamMarshaller<T>Marshaller for metadata values that are serialized to an InputStream.static interfaceMethodDescriptor.PrototypeMarshaller<T>A marshaller that uses a fixed instance of the type it produces.static interfaceMethodDescriptor.ReflectableMarshaller<T>A marshaller that supports retrieving its type parameterTat runtime.classNameResolverA pluggable component that resolves a targetURIand return addresses to the caller.static classNameResolver.ArgsInformation that aNameResolver.Factoryuses to create aNameResolver.static classNameResolver.ConfigOrErrorRepresents 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 classNameResolver.FactoryFactory that createsNameResolverinstances.static interfaceNameResolver.ListenerReceives address updates.static classNameResolver.Listener2Receives address updates.static classNameResolver.ResolutionResultRepresents the results from a Name Resolver.static classNameResolver.ResolutionResult.BuilderA builder forNameResolver.ResolutionResult.static interfaceNameResolver.ResolutionResultAttrAnnotation for name resolution result attributes.static classNameResolver.ServiceConfigParserParses and validates service configuration.classNameResolverProviderProvider of name resolvers for name agnostic consumption.classNameResolverRegistryRegistry ofNameResolverProviders.classSecurityLevelThe level of security guarantee in communications.interfaceServerCallExecutorSupplierDefines what executor handles the server call, based on each RPC call information at runtime.classServerStreamTracerListens to events on a stream to collect metrics.classServerTransportFilterListens on server transport life-cycle events, with the capability to read and/or change transport attributes.classStatusOr<T>Either a Status or a value.classStreamTracerListens 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_OVERRIDEThe authority to be used when constructing Subchannels for this EquivalentAddressGroup.static Attributes.Key<String>NameResolver. ATTR_BACKEND_SERVICEstatic Attributes.Key<SocketAddress>Grpc. TRANSPORT_ATTR_LOCAL_ADDRAttribute key for the local address of a transport.static Attributes.Key<SocketAddress>Grpc. TRANSPORT_ATTR_REMOTE_ADDRAttribute key for the remote address of a transport.static Attributes.Key<SSLSession>Grpc. TRANSPORT_ATTR_SSL_SESSIONAttribute key for SSL session of a transport.Methods in io.grpc with annotations of type ExperimentalApi Modifier and Type Method Description TServerBuilder. addStreamTracerFactory(ServerStreamTracer.Factory factory)Adds aServerStreamTracer.Factoryto measure server-side traffic.TManagedChannelBuilder. addTransportFilter(ClientTransportFilter filter)Adds aClientTransportFilter.TServerBuilder. addTransportFilter(ServerTransportFilter filter)Adds aServerTransportFilter.TServerBuilder. callExecutor(ServerCallExecutorSupplier executorSupplier)Allows for defining a way to provide a custom executor to handle the server call.CallOptionsCallOptions. clearOnReadyThreshold()Resets to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.abstract TManagedChannelBuilder. compressorRegistry(CompressorRegistry registry)Set the compression registry for use in the channel.abstract TServerBuilder. compressorRegistry(CompressorRegistry registry)Set the compression registry for use in the channel.abstract TManagedChannelBuilder. decompressorRegistry(DecompressorRegistry registry)Set the decompression registry for use in the channel.abstract TServerBuilder. decompressorRegistry(DecompressorRegistry registry)Set the decompression registry for use in the channel.TManagedChannelBuilder. defaultLoadBalancingPolicy(String policy)Sets the default load-balancing policy that will be used if the service config doesn't specify one.TManagedChannelBuilder. defaultServiceConfig(Map<String,?> serviceConfig)Provides a service config to the channel.TManagedChannelBuilder. disableServiceConfigLookUp()Disables service config look-up from the naming system, which is enabled by default.<T> voidMetadata. discardAll(Metadata.Key<T> key)Remove all values for the given key without returning them.voidManagedChannel. 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 StringMethodDescriptor. 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.AttributesClientCall. getAttributes()Returns additional properties of the call.AttributesServerCall. getAttributes()Returns properties of a single call.StringCallOptions. getAuthority()Override the HTTP/2 authority the channel claims to be connecting to.StringLoadBalancer.PickResult. getAuthorityOverride()Returns the authority override if any.StringMethodDescriptor. getBareMethodName()A convenience method forextractBareMethodName(getFullMethodName()).ChannelLoggerNameResolver.Args. getChannelLogger()Returns theChannelLoggerfor 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.IntegerCallOptions. getMaxInboundMessageSize()Gets the maximum allowed message size acceptable from the remote peer.IntegerCallOptions. 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.IntegerCallOptions. getOnReadyThreshold()Returns to the default number of bytes that must be queued before the call will leave the 'wait for ready' state.<T> TCallOptions. getOption(CallOptions.Key<T> key)Get the value for a custom option or its inherent default.StringNameResolver.Args. getOverrideAuthority()Returns the overrideAuthority from channelManagedChannelBuilder.overrideAuthority(java.lang.String).ScheduledExecutorServiceNameResolver.Args. getScheduledExecutorService()Returns aScheduledExecutorServicefor scheduling delayed tasks.ObjectServiceDescriptor. getSchemaDescriptor()Returns the schema descriptor for this service.SecurityLevelServerCall. getSecurityLevel()Returns the level of security guarantee in communicationsStringMethodDescriptor. getServiceName()A convenience method forextractFullServiceName(getFullMethodName()).List<ServerServiceDefinition>HandlerRegistry. getServices()Returns theServerServiceDefinitions 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.ConnectivityStateManagedChannel. getState(boolean requestConnection)Gets the current connectivity state.List<ClientStreamTracer.Factory>CallOptions. getStreamTracerFactories()Returns an immutable list ofClientStreamTracerFactorys.abstract TManagedChannelBuilder. idleTimeout(long value, TimeUnit unit)Set the duration without ongoing RPCs before going to idle mode.voidLoadBalancer.Helper. ignoreRefreshNameResolutionCheck()Deprecated.Warning has been removedTServerBuilder. keepAliveTime(long keepAliveTime, TimeUnit timeUnit)Sets the time without read activity before sending a keepalive ping.TServerBuilder. keepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit)Sets a time waiting for read activity after sending a keepalive ping.TServerBuilder. maxConnectionAge(long maxConnectionAge, TimeUnit timeUnit)Sets the maximum connection age, connections lasting longer than which will be gracefully terminated.TServerBuilder. maxConnectionAgeGrace(long maxConnectionAgeGrace, TimeUnit timeUnit)Sets the grace time for the graceful connection termination.TServerBuilder. maxConnectionIdle(long maxConnectionIdle, TimeUnit timeUnit)Sets the maximum connection idle time, connections being idle for longer than which will be gracefully terminated.TManagedChannelBuilder. maxHedgedAttempts(int maxHedgedAttempts)Sets the maximum number of hedged attempts that may be configured by the service config.TManagedChannelBuilder. maxRetryAttempts(int maxRetryAttempts)Sets the maximum number of retry attempts that may be configured by the service config.TManagedChannelBuilder. maxTraceEvents(int maxTraceEvents)Sets the maximum number of channel trace events to keep in the tracer for each channel or subchannel.abstract TManagedChannelBuilder. nameResolverFactory(NameResolver.Factory resolverFactory)Deprecated.Most usages should use a globally-registeredNameResolverProviderinstead, with either the SPI mechanism orNameResolverRegistry.register(io.grpc.NameResolverProvider).voidManagedChannel. 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.TServerBuilder. permitKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)Specify the most aggressive keep-alive time clients are permitted to configure.TServerBuilder. 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.TManagedChannelBuilder. perRpcBufferLimit(long bytes)Sets the per RPC buffer limit in bytes used for retry.voidManagedChannel. resetConnectBackoff()For subchannels that are in TRANSIENT_FAILURE state, short-circuit the backoff timer and make them reconnect immediately.TManagedChannelBuilder. retryBufferSize(long bytes)Sets the retry buffer size in bytes.SynchronizationContext.ScheduledHandleSynchronizationContext. schedule(Runnable task, Duration delay, ScheduledExecutorService timerService)SynchronizationContext.ScheduledHandleSynchronizationContext. scheduleWithFixedDelay(Runnable task, Duration initialDelay, Duration delay, ScheduledExecutorService timerService)TManagedChannelBuilder. setBinaryLog(BinaryLog binaryLog)Sets the BinaryLog object that this channel should log to.TServerBuilder. setBinaryLog(BinaryLog binaryLog)Sets the BinaryLog object that this server should log to.NameResolver.Args.BuilderNameResolver.Args.Builder. setChannelLogger(ChannelLogger channelLogger)ServiceDescriptor.BuilderServiceDescriptor.Builder. setName(String name)Sets the name.<X> TManagedChannelBuilder. setNameResolverArg(NameResolver.Args.Key<X> key, X value)Provides a "custom" argument for theNameResolver, if applicable, replacing any 'value' previously provided for 'key'.voidServerCall. setOnReadyThreshold(int numBytes)A hint to the call that specifies how many bytes must be queued beforeServerCall.isReady()will return false.NameResolver.Args.BuilderNameResolver.Args.Builder. setOverrideAuthority(String authority)NameResolver.Args.BuilderNameResolver.Args.Builder. setScheduledExecutorService(ScheduledExecutorService scheduledExecutorService)static StatusContexts. statusFromCancelled(Context context)Returns theStatusof a cancelled context ornullif the context is not cancelled.voidCallCredentials. thisUsesUnstableApi()Deprecated.static ServerServiceDefinitionServerInterceptors. useInputStreamMessages(ServerServiceDefinition serviceDef)Create a newServerServiceDefinitionwhoseMethodDescriptorserializes to and from InputStream for all methods.static <ReqT,RespT>
ServerServiceDefinitionServerInterceptors. useMarshalledMessages(ServerServiceDefinition serviceDef, MethodDescriptor.Marshaller<ReqT> requestMarshaller, MethodDescriptor.Marshaller<RespT> responseMarshaller)Create a newServerServiceDefinitionwithMethodDescriptorfor deserializing requests and separateMethodDescriptorfor serializing responses.static <T> ServerServiceDefinitionServerInterceptors. useMarshalledMessages(ServerServiceDefinition serviceDef, MethodDescriptor.Marshaller<T> marshaller)Create a newServerServiceDefinitionwhoseMethodDescriptorserializes to and from T for all methods.CallOptionsCallOptions. withAuthority(String authority)Override the HTTP/2 authority the channel claims to be connecting to.CallOptionsCallOptions. withDeadlineAfter(Duration duration)CallOptionsCallOptions. withMaxInboundMessageSize(int maxSize)Sets the maximum allowed message size acceptable from the remote peer.CallOptionsCallOptions. withMaxOutboundMessageSize(int maxSize)Sets the maximum allowed message size acceptable sent to the remote peer.CallOptionsCallOptions. withOnReadyThreshold(int numBytes)Specifies how many bytes must be queued before the call is considered not ready to send more messages.CallOptionsCallOptions. withStreamTracerFactory(ClientStreamTracer.Factory factory)Returns a newCallOptionswith aClientStreamTracerFactoryin addition to the existing factories.static LoadBalancer.PickResultLoadBalancer.PickResult. withSubchannel(LoadBalancer.Subchannel subchannel, ClientStreamTracer.Factory streamTracerFactory, String authorityOverride)Same aswithSubchannel(subchannel, streamTracerFactory)but with an authority name to override in the host header. -
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 classCsmObservabilityThe entrypoint for GCP's CSM OpenTelemetry metrics functionality in gRPC.static classCsmObservability.BuilderBuilder for configuringCsmObservability. -
Uses of ExperimentalApi in io.grpc.grpclb
Classes in io.grpc.grpclb with annotations of type ExperimentalApi Modifier and Type Class Description classGrpclbConstantsConstants for the GRPCLB load-balancer. -
Uses of ExperimentalApi in io.grpc.health.v1
Methods in io.grpc.health.v1 with annotations of type ExperimentalApi Modifier and Type Method Description BlockingClientCall<?,HealthCheckResponse>HealthGrpc.HealthBlockingV2Stub. watch(HealthCheckRequest request)Performs a watch for the serving status of the requested service. -
Uses of ExperimentalApi in io.grpc.inprocess
Classes in io.grpc.inprocess with annotations of type ExperimentalApi Modifier and Type Class Description classAnonymousInProcessSocketAddressCustom SocketAddress class forInProcessTransport, for a server which can only be referenced via this address instance.classInProcessChannelBuilderBuilder for a channel that issues in-process requests.classInProcessServerBuilderBuilder for a server that services in-process requests. -
Uses of ExperimentalApi in io.grpc.lb.v1
Methods in io.grpc.lb.v1 with annotations of type ExperimentalApi Modifier and Type Method Description BlockingClientCall<LoadBalanceRequest,LoadBalanceResponse>LoadBalancerGrpc.LoadBalancerBlockingV2Stub. balanceLoad()Bidirectional rpc to get a list of servers. -
Uses of ExperimentalApi in io.grpc.netty
Classes in io.grpc.netty with annotations of type ExperimentalApi Modifier and Type Class Description classGrpcSslContextsUtility for configuring SslContext for gRPC.classInsecureFromHttp1ChannelCredentialsAn insecure credential that upgrades from HTTP/1 to HTTP/2.classNegotiationTypeIdentifies the negotiation used for starting up HTTP/2.classNettyChannelBuilderA builder to help simplify construction of channels using the Netty transport.static classNettyChannelBuilder.LocalSocketPickerThis class is meant to be overriden with a custom implementation ofNettyChannelBuilder.LocalSocketPicker.createSocketAddress(java.net.SocketAddress, io.grpc.Attributes).classNettyServerBuilderA builder to help simplify the construction of a Netty-based GRPC server.classNettySslContextChannelCredentialsA credential that performs TLS with Netty's SslContext as configuration.classNettySslContextServerCredentialsA 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 SslContextBuilderGrpcSslContexts. 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 classOkHttpChannelBuilderConvenience class for building channels with the OkHttp transport.classOkHttpServerBuilderBuild servers with the OkHttp transport.classSslSocketFactoryChannelCredentialsA credential with full control over the SSLSocketFactory.classSslSocketFactoryServerCredentialsA 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 classGrpcTraceBinContextPropagatorATextMapPropagatorfor transmitting "grpc-trace-bin" span context.Methods in io.grpc.opentelemetry with annotations of type ExperimentalApi Modifier and Type Method Description voidGrpcOpenTelemetry. 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 classStatusProtoUtility methods for working withStatus. -
Uses of ExperimentalApi in io.grpc.protobuf.lite
Classes in io.grpc.protobuf.lite with annotations of type ExperimentalApi Modifier and Type Class Description classProtoLiteUtilsUtility methods for using protobuf with grpc. -
Uses of ExperimentalApi in io.grpc.protobuf.services
Classes in io.grpc.protobuf.services with annotations of type ExperimentalApi Modifier and Type Class Description classBinaryLogsinterfaceBinaryLogSinkA class that accepts binary log messages.classChannelzServiceThe channelz service provides stats about a running gRPC process.classHealthCheckingLoadBalancerUtilUtility for enabling client-side health checking forLoadBalancers.classHealthStatusManagerAHealthStatusManagerobject manages a health check service.classProtoReflectionServiceProvides a reflection service for Protobuf services (including the reflection service itself).classProtoReflectionServiceV1Provides a reflection service for Protobuf services (including the reflection service itself). -
Uses of ExperimentalApi in io.grpc.reflection.v1
Methods in io.grpc.reflection.v1 with annotations of type ExperimentalApi Modifier and Type Method Description BlockingClientCall<ServerReflectionRequest,ServerReflectionResponse>ServerReflectionGrpc.ServerReflectionBlockingV2Stub. serverReflectionInfo()The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server. -
Uses of ExperimentalApi in io.grpc.reflection.v1alpha
Methods in io.grpc.reflection.v1alpha with annotations of type ExperimentalApi Modifier and Type Method Description BlockingClientCall<ServerReflectionRequest,ServerReflectionResponse>ServerReflectionGrpc.ServerReflectionBlockingV2Stub. serverReflectionInfo()The reflection service is structured as a bidirectional stream, ensuring all related requests go to a single server. -
Uses of ExperimentalApi in io.grpc.services
Classes in io.grpc.services with annotations of type ExperimentalApi Modifier and Type Class Description classAdminInterfaceAdmin Interface provides a class of services for exposing the overall state of gRPC activity in a given binary.classCallMetricRecorderUtility to record call metrics for load-balancing.classChannelzServiceDeprecated.UseChannelzServiceinstead.classHealthStatusManagerDeprecated.UseHealthStatusManagerinstead.classMetricRecorderImplements the service/APIs for Out-of-Band metrics reporting, only for utilization metrics.classMetricReportA 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 classGrpcServletA simple servlet backed by a gRPC server.classServletAdapterAn adapter that transformsHttpServletRequestinto gRPC request and lets a gRPC server process it, and transforms the gRPC response intoHttpServletResponse.classServletServerBuilderBuilder 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 classGrpcServletA simple servlet backed by a gRPC server.classServletAdapterAn adapter that transformsHttpServletRequestinto gRPC request and lets a gRPC server process it, and transforms the gRPC response intoHttpServletResponse.classServletServerBuilderBuilder 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 classBlockingClientCall<ReqT,RespT>Represents a bidirectional streaming call from a client.classCallStreamObserver<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.Methods in io.grpc.stub with annotations of type ExperimentalApi Modifier and Type Method Description static <ReqT,RespT>
BlockingClientCall<ReqT,RespT>ClientCalls. blockingBidiStreamingCall(Channel channel, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)Initiate a bidirectional-streamingClientCalland returning a stream object (BlockingClientCall) which can be used by the client to send and receive messages over the grpc channel.static <ReqT,RespT>
BlockingClientCall<ReqT,RespT>ClientCalls. blockingClientStreamingCall(Channel channel, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions)Initiates a server streaming call and sends the specified request to the server.static <ReqT,RespT>
BlockingClientCall<ReqT,RespT>ClientCalls. blockingV2ServerStreamingCall(Channel channel, MethodDescriptor<ReqT,RespT> method, CallOptions callOptions, ReqT req)Initiates a client streaming call over the specified channel.static <V> voidStreamObservers. copyWithFlowControl(Iterable<V> source, CallStreamObserver<V> target)Deprecated.Of questionable utility and generally not used.static <V> voidStreamObservers. copyWithFlowControl(Iterator<V> source, CallStreamObserver<V> target)Deprecated.Of questionable utility and generally not used.static ServerInterceptorMetadataUtils. newAttachMetadataServerInterceptor(Metadata extras)Returns a ServerInterceptor that adds the specified Metadata to every response stream, one way or another.static <T> voidStreamObservers. nextAndComplete(StreamObserver<T> responseObserver, T response)Utility method to callStreamObserver.onNext(Object)andStreamObserver.onCompleted()on the specified responseObserver.voidServerCallStreamObserver. setOnCloseHandler(Runnable onCloseHandler)Sets aRunnableto 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.voidServerCallStreamObserver. setOnReadyThreshold(int numBytes)A hint to the call that specifies how many bytes must be queued beforeServerCallStreamObserver.isReady()will return false.SAbstractStub. withDeadlineAfter(Duration duration)SAbstractStub. withMaxInboundMessageSize(int maxSize)Returns a new stub that limits the maximum acceptable message size from a remote peer.SAbstractStub. withMaxOutboundMessageSize(int maxSize)Returns a new stub that limits the maximum acceptable message size to send a remote peer.SAbstractStub. withOnReadyThreshold(int numBytes)Returns a new stub that limits the maximum number of bytes per stream in the queue.<T> SAbstractStub. withOption(CallOptions.Key<T> key, T value)Sets a custom option to be passed to client interceptors on the channelClientInterceptorvia 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 classStreamRecorder<T>Deprecated.Not for public useclassTestUtilsCommon utility functions useful for writing tests.classTlsTestingConvenience 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 classCertificateUtilsContains certificate/key PEM file utility method(s).classForwardingClientStreamTracerclassForwardingLoadBalancerclassForwardingLoadBalancerHelperclassForwardingSubchannelclassGracefulSwitchLoadBalancerA load balancer that gracefully swaps to a new lb policy.classTransmitStatusRuntimeExceptionInterceptorA class that intercepts uncaught exceptions of typeStatusRuntimeExceptionand 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.voidAdvancedTlsX509KeyManager. updateIdentityCredentials(PrivateKey key, X509Certificate[] certs)voidAdvancedTlsX509KeyManager. updateIdentityCredentialsFromFile(File keyFile, File certFile)Deprecated.AdvancedTlsX509KeyManager.CloseableAdvancedTlsX509KeyManager. updateIdentityCredentialsFromFile(File keyFile, File certFile, long period, TimeUnit unit, ScheduledExecutorService executor)voidAdvancedTlsX509TrustManager. updateTrustCredentialsFromFile(File trustCertFile)Deprecated.AdvancedTlsX509TrustManager.CloseableAdvancedTlsX509TrustManager. 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 classRingHashOptionsUtility class that provides a way to configure ring hash size limits.classXdsChannelCredentialsclassXdsServerBuilderA version ofServerBuilderto create xDS managed servers.classXdsServerCredentialsMethods in io.grpc.xds with annotations of type ExperimentalApi Modifier and Type Method Description static longRingHashOptions. getRingSizeCap()Get the global limit for min and max ring hash sizes.static voidRingHashOptions. 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 classOrcaMetricReportingServerInterceptorAServerInterceptorthat intercepts aServerCallby running server-side RPC handling under aContextthat 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).classOrcaOobUtilUtility class that provides method forLoadBalancerto install listeners to receive out-of-band backend metrics in the format of Open Request Cost Aggregation (ORCA).classOrcaPerRequestUtilUtility class that provides method forLoadBalancerto install listeners to receive per-request backend cost metrics in the format of Open Request Cost Aggregation (ORCA).classOrcaServiceImplImplements aBindableServicethat generates Out-Of-Band server metrics.
-