Index

A B C D E F G H I J K L M N O P Q R S T U V W X Z 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ABORTED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode
Aborted, typically due to a concurrency issue (think CAS).
AbstractCloseableIterable<T> - Class in io.servicetalk.concurrent.internal
An abstract implementation of CloseableIterable that wraps an Iterable.
AbstractCloseableIterable(Iterable<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIterable
New instance.
AbstractCloseableIteratorAsInputStream<T> - Class in io.servicetalk.concurrent.internal
Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
AbstractCloseableIteratorAsInputStream(CloseableIterator<T>) - Constructor for class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
Create a new instance.
accept(int, int) - Method in interface io.servicetalk.dns.discovery.netty.ServiceDiscovererUtils.TwoIntsConsumer
Performs this operation on the given arguments.
accept(long, long) - Method in interface io.servicetalk.concurrent.api.LongBinaryConsumer
Evaluates this consumer on the given arguments.
accept(ConnectionContext) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
Deprecated.
Evaluate the passed ConnectionContext to accept or reject.
accept(ConnectionContext) - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
accept(ConnectionInfo) - Method in interface io.servicetalk.transport.api.EarlyConnectionAcceptor
Accept or reject an incoming connection.
accept(ConnectionInfo) - Method in interface io.servicetalk.transport.api.LateConnectionAcceptor
Accept or reject an incoming connection.
accept(Void, Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
 
accept(Payload) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
accept(State, Payload) - Method in interface io.servicetalk.http.api.TrailersTransformer
accept(X, Y, Z) - Method in interface io.servicetalk.concurrent.api.TriConsumer
Performs this operation on the given arguments.
ACCEPT - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept"
ACCEPT_ALL - Static variable in interface io.servicetalk.transport.api.ConnectionAcceptor
Deprecated.
ACCEPT all connections.
ACCEPT_CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-charset"
ACCEPT_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-encoding"
ACCEPT_LANGUAGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-language"
ACCEPT_PATCH - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-patch"
ACCEPT_RANGES - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"accept-ranges"
acceptConnections(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
acceptConnections(boolean) - Method in interface io.servicetalk.transport.api.ServerListenContext
Toggles the server's ability to accept new connections.
acceptConnections(boolean) - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
accepted() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
accepted() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
accepted() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.ACCEPTED response.
Accepted - Enum constant in enum class io.servicetalk.client.api.internal.RequestConcurrencyController.Result
Deprecated.
Selecting the resource succeeded.
Accepted - Enum constant in enum class io.servicetalk.client.api.RequestConcurrencyController.Result
Selecting the resource succeeded.
ACCEPTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
202 Accepted
acceptInsecureConnections() - Method in class io.servicetalk.tcp.netty.internal.ReadOnlyTcpServerConfig
Returns true if non-TLS connections should also be accepted on TLS-enabled sockets.
acceptInsecureConnections() - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
 
ACCESS_CONTROL_ALLOW_CREDENTIALS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-credentials"
ACCESS_CONTROL_ALLOW_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-headers"
ACCESS_CONTROL_ALLOW_METHODS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-methods"
ACCESS_CONTROL_ALLOW_ORIGIN - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-allow-origin"
ACCESS_CONTROL_EXPOSE_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-expose-headers"
ACCESS_CONTROL_MAX_AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-max-age"
ACCESS_CONTROL_REQUEST_HEADERS - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-request-headers"
ACCESS_CONTROL_REQUEST_METHOD - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"access-control-request-method"
accumulate(T) - Method in interface io.servicetalk.concurrent.api.BufferStrategy.Accumulator
Adds the passed item to this BufferStrategy.Accumulator.
accumulate(T) - Method in interface io.servicetalk.concurrent.api.ReplayAccumulator
Called on each PublisherSource.Subscriber.onNext(Object) and intended to accumulate the signal so that new PublisherSource.Subscribers will see this value via ReplayAccumulator.deliverAccumulation(Consumer).
accumulatorSupplier() - Method in interface io.servicetalk.concurrent.api.ReplayStrategy
Get a Supplier that provides the ReplayAccumulator on each upstream subscribe.
ackTimeout() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig.KeepAlivePolicy
Duration to wait for acknowledgment from the peer after a ping is sent.
ackTimeout(Duration) - Method in class io.servicetalk.http.netty.H2KeepAlivePolicies.KeepAlivePolicyBuilder
Set the maximum Duration to wait for an acknowledgment of a previously sent ping.
activate(Span) - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
 
activateSpan(Span) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
activeSpan() - Method in class io.servicetalk.opentracing.asynccontext.AsyncContextInMemoryScopeManager
 
activeSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryScopeManager
 
activeSpan() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
 
activeSpan() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
adaptor() - Method in interface io.servicetalk.http.api.HttpApiConversions.ServiceAdapterHolder
Deprecated.
StreamingHttpService that adapts another service to the streaming programming model.
add(PartitionAttributes) - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
Deprecated.
 
add(PartitionAttributes) - Method in interface io.servicetalk.client.api.partition.PartitionMap
Deprecated.
Add a new PartitionAttributes that is absolutely specified.
add(PartitionAttributes.Key<T>, T) - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
Deprecated.
 
add(PartitionAttributes.Key<T>, T) - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder
Deprecated.
Add a key/value pair to this builder.
add(BufferDecoder) - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder
Add a new BufferDecoder to the BufferDecoderGroup built by this builder.
add(BufferDecoder, boolean) - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder
Add a new BufferDecoder to the BufferDecoderGroup built by this builder.
add(HttpHeaders) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds all header names and values of headers to this object.
add(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a new header with the specified name and value.
add(CharSequence, CharSequence...) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, CharSequence...) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(CharSequence, Iterable<? extends CharSequence>) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, Iterable<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(CharSequence, Iterator<? extends CharSequence>) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
add(CharSequence, Iterator<? extends CharSequence>) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds new headers with the specified name and values.
add(T) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Adds an item to this holder.
add(T) - Method in interface io.servicetalk.concurrent.api.PublisherProcessorSignalsHolder
Adds an item to this holder.
addBlockingRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRequestStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingRequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingRoute to this factory.
addBlockingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingRoute(String, Class<?>, String, GrpcRoutes.BlockingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingService(Health.BlockingHealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
addBlockingStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBlockingStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.BlockingStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.BlockingStreamingRoute to this factory.
addBlockingStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBlockingStreamingRoute(String, Class<?>, String, GrpcRoutes.BlockingStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addBuffer(Buffer) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Add the given Buffer to this buffer and increment the writerIndex.
addBuffer(Buffer, boolean) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Add the given Buffer to this buffer.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addCookie(HttpCookiePair) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a cookie.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a cookie.
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponse
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addCookie(HttpCookiePair) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a cookie with the specified name and value.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a cookie with the specified name and value.
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a new header with the specified name and value.
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addHeader(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds all header names and values of headers object.
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addHeaders(HttpHeaders) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addIfAbsent(Channel) - Method in class io.servicetalk.transport.netty.internal.ChannelSet
Add a Channel to this ChannelSet, if it is not already present.
addListener(InMemorySpanEventListener) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
Add a trace event listener.
addOption(Map<ChannelOption, Object>, SocketOption<T>, T) - Static method in class io.servicetalk.transport.netty.internal.SocketOptionUtils
Convert and add the given SocketOption and value to the ChannelOptions Map.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds a new query parameter with the specified key and value, which will be percent-encoded if needed.
addQueryParameter(String, String) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds new query parameters with the specified key and values.
addQueryParameters(String, Iterable<String>) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequest
 
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Adds new query parameters with the specified key and values.
addQueryParameters(String, String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addReference(String, SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
addReference(String, InMemorySpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
addRequestStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.RequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addRequestStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.RequestStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.RequestStreamingRoute to this factory.
addRequestStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addRequestStreamingRoute(String, Class<?>, String, GrpcRoutes.RequestStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addResponseStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.ResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
addResponseStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.ResponseStreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.ResponseStreamingRoute to this factory.
addResponseStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addResponseStreamingRoute(String, Class<?>, String, GrpcRoutes.ResponseStreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
address() - Method in class io.servicetalk.client.api.DefaultGroupKey
 
address() - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
 
address() - Method in interface io.servicetalk.client.api.GroupKey
Get the address to use when looking for or creating a new client.
address() - Method in interface io.servicetalk.client.api.ServiceDiscovererEvent
Get the resolved address which is the subject of this event.
address() - Method in interface io.servicetalk.http.api.ProxyConfig
Address of the proxy.
address() - Method in class io.servicetalk.loadbalancer.RichServiceDiscovererEvent
 
addRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.Route<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.Route to this factory.
addRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.Route<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.Route to this factory.
addRoute(String, GrpcExecutionStrategy, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addRoute(String, Class<?>, String, GrpcRoutes.Route<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addService(Health.BlockingHealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
addService(Health.HealthService) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addSetCookie(HttpSetCookie) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a set-cookie.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a set-cookie.
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponse
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addSetCookie(HttpSetCookie) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
addSetCookie(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Adds a set-cookie with the specified name and value.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpMetaData
Adds a set-cookie with the specified name and value.
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
addSetCookie(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
addStreamingRoute(GrpcExecutionStrategy, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.StreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.StreamingRoute to this factory.
addStreamingRoute(Class<?>, MethodDescriptor<Req, Resp>, BufferDecoderGroup, List<BufferEncoder>, GrpcRoutes.StreamingRoute<Req, Resp>) - Method in class io.servicetalk.grpc.api.GrpcRoutes
Adds a GrpcRoutes.StreamingRoute to this factory.
addStreamingRoute(String, GrpcExecutionStrategy, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addStreamingRoute(String, Class<?>, String, GrpcRoutes.StreamingRoute<Req, Resp>, Class<Req>, Class<Resp>, GrpcSerializationProvider) - Method in class io.servicetalk.grpc.api.GrpcRoutes
addSuppressed(Throwable, Throwable) - Static method in class io.servicetalk.utils.internal.ThrowableUtils
Adds suppressed exception avoiding self-suppression.
addTrailer(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.HttpOutputStream
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpRequest
 
addTrailer(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpResponse
 
addTrailers(HttpHeaders) - Method in class io.servicetalk.http.api.HttpOutputStream
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpPayloadWriter
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpRequest
 
addTrailers(HttpHeaders) - Method in interface io.servicetalk.http.api.HttpResponse
 
addWithOverflowProtection(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Adds two positive ints and returns Integer.MAX_VALUE if overflow occurs.
addWithOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Adds two positive longs and returns Long.MAX_VALUE if overflow occurs.
addWithOverflowProtectionIfGtEqNegativeOne(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is >=-1 this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfNotNegative(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfNotNegative(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is non-negative this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithOverflowProtectionIfPositive(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(int, int).
addWithOverflowProtectionIfPositive(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
If x is positive this method behaves the same as FlowControlUtils.addWithOverflowProtection(long, long).
addWithUnderOverflowProtection(int, int) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Add two longs and prevent [under|over]flow which is defined as if both x and y have the same sign but the result of x + y has a different sign.
addWithUnderOverflowProtection(long, long) - Static method in class io.servicetalk.concurrent.internal.FlowControlUtils
Add two longs and prevent [under|over]flow which is defined as if both x and y have the same sign but the result of x + y has a different sign.
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
advanceCookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator
advertisedMessageEncoding() - Method in interface io.servicetalk.encoding.api.BufferDecoderGroup
Get the combined encoding to advertise.
advertisedMessageEncoding() - Method in class io.servicetalk.encoding.api.EmptyBufferDecoderGroup
 
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Completable.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for PublisherSource.Subscriptions of the returned Publisher.
afterCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onCancel Runnable argument after Cancellable.cancel() is called for Subscriptions of the returned Single.
afterFinally() - Method in interface io.servicetalk.concurrent.api.ScanLifetimeMapper
afterFinally() - Method in interface io.servicetalk.concurrent.api.ScanWithLifetimeMapper
Deprecated.
afterFinally(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the corresponding method on afterFinally TerminalSignalConsumer argument after any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() CompletableSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
afterFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Single
Invokes the corresponding method on afterFinally TerminalSignalConsumer argument after any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes TerminalSignalConsumer.onComplete() SingleSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the whenFinally Runnable argument after any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() CompletableSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the afterFinally Runnable argument after any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() PublisherSource.Subscriber.onError(Throwable) Cancellable.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
afterFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the whenFinally Runnable argument after any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
afterOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onComplete Runnable argument after CompletableSource.Subscriber.onComplete() is called for CompletableSource.Subscribers of the returned Completable.
afterOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onComplete Runnable argument after PublisherSource.Subscriber.onComplete() is called for PublisherSource.Subscribers of the returned Publisher.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onError Consumer argument after CompletableSource.Subscriber.onError(Throwable) is called for CompletableSource.Subscribers of the returned Completable.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onError Consumer argument after PublisherSource.Subscriber.onError(Throwable) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onError Consumer argument after SingleSource.Subscriber.onError(Throwable) is called for SingleSource.Subscribers of the returned Single.
afterOnNext(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onNext Consumer argument after PublisherSource.Subscriber.onNext(Object) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnSubscribe(Consumer<? super PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onSubscribe Consumer argument after PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) is called for PublisherSource.Subscribers of the returned Publisher.
afterOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onSubscribe Consumer argument after CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
afterOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSubscribe Consumer argument after SingleSource.Subscriber.onSubscribe(Cancellable) is called for SingleSource.Subscribers of the returned Single.
afterOnSuccess(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSuccess Consumer argument after SingleSource.Subscriber.onSuccess(Object) is called for SingleSource.Subscribers of the returned Single.
afterRequest(LongConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onRequest LongConsumer argument after PublisherSource.Subscription.request(long) is called for PublisherSource.Subscriptions of the returned Publisher.
afterSubscriber(Supplier<? extends CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new CompletableSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the CompletableSource.Subscriber methods after the CompletableSource.Subscribers of the returned Completable.
afterSubscriber(Supplier<? extends PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscriber (via the subscriberSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscriber methods after the PublisherSource.Subscribers of the returned Publisher.
afterSubscriber(Supplier<? extends SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new SingleSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the SingleSource.Subscriber methods after the SingleSource.Subscribers of the returned Single.
afterSubscription(Supplier<? extends PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscription (via the subscriptionSupplier argument) for each new subscribe and invokes all the PublisherSource.Subscription methods after the PublisherSource.Subscriptions of the returned Publisher.
AGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"age"
AimdCapacityLimiterBuilder - Class in io.servicetalk.capacity.limiter.api
Builder for the AimdCapacityLimiter capacity limiter.
AimdCapacityLimiterBuilder.StateObserver - Interface in io.servicetalk.capacity.limiter.api
A state observer for AIMD CapacityLimiter to monitor internal limit and consumption.
algorithmId() - Method in interface io.servicetalk.transport.api.CertificateCompressionAlgorithm
Get the unique identifier for this algorithm.
allocateMemory(long) - Static method in class io.servicetalk.utils.internal.PlatformDependent
Allocates direct memory.
allocator - Variable in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
 
ALLOW - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"allow"
allowAll() - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
Returns a NO-OP CapacityLimiter that has no logic around acquiring or releasing a permit for a request; thus it allows everything to go through, similarly to a non-existing CapacityLimiter.
allowDropRequestTrailers(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
allowDropRequestTrailers(boolean) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Provide a hint if request trailers are allowed to be dropped.
allowDropResponseTrailers(boolean) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
allowDropResponseTrailers(boolean) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Provide a hint if response trailers are allowed to be dropped.
allowedMethods() - Method in interface io.servicetalk.http.api.RedirectConfig
HttpRequestMethods that are allowed to follow redirects.
allowedMethods(HttpRequestMethod...) - Method in class io.servicetalk.http.api.RedirectConfigBuilder
Sets HttpRequestMethods that are allowed to follow redirects.
allowedStatuses() - Method in interface io.servicetalk.http.api.RedirectConfig
HttpResponseStatuses that are allowed to follow redirects.
allowedStatuses(HttpResponseStatus...) - Method in class io.servicetalk.http.api.RedirectConfigBuilder
Sets HttpResponseStatuses that are allowed to follow redirects.
allowLFWithoutCR() - Method in class io.servicetalk.http.netty.H1SpecExceptions
Allow LF without a proceeding CR as described in HTTP/1.x Message Parsing Robustness:
allowLFWithoutCR(boolean) - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder
Allow LF without a proceeding CR as described in HTTP/1.x Message Parsing Robustness:
allowNonRelativeRedirects() - Method in interface io.servicetalk.http.api.RedirectConfig
Tells if redirection should follow non-relative redirects (if supported by the underlying client implementation).
allowNonRelativeRedirects(boolean) - Method in class io.servicetalk.http.api.RedirectConfigBuilder
Allows non-relative redirects (if supported by the underlying client implementation).
allowPrematureClosureBeforePayloadBody() - Method in class io.servicetalk.http.netty.H1SpecExceptions
Allows interpreting connection closures as the end of HTTP/1.1 messages if the receiver did not receive any part of the payload body before the connection closure.
allowPrematureClosureBeforePayloadBody(boolean) - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder
Allows interpreting connection closures as the end of HTTP/1.1 messages if the receiver did not receive any part of the payload body before the connection closure.
alpnId() - Method in interface io.servicetalk.http.api.HttpProtocolConfig
TLS Application-Layer Protocol Negotiation (ALPN) Protocol ID of the protocol this configuration is for.
alpnId() - Method in interface io.servicetalk.http.netty.H1ProtocolConfig
 
alpnId() - Method in interface io.servicetalk.http.netty.H2ProtocolConfig
 
alpnProtocols() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
 
alpnProtocols() - Method in interface io.servicetalk.transport.api.SslConfig
Get the TLS ALPN protocols.
alpnProtocols(String...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the TLS ALPN protocols.
alpnProtocols(List<String>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the TLS ALPN protocols.
ALREADY_EXISTS - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode
Some entity that we attempted to create already exists.
ALREADY_REPORTED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
208 Already Reported
alreadyReported() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
alreadyReported() - Method in interface io.servicetalk.http.api.HttpResponseFactory
alreadyReported() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
amb(Completable...) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
amb(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
amb(Iterable<Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
amb(Iterable<Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
ambWith(Completable) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of either this Completable or the passed other Completable, whichever terminates first.
ambWith(Single<T>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of either this Single or the passed other Single, whichever terminates first.
and(BiPredicate<ConnectionContext, StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches StreamingHttpRequest and ConnectionContext with a user-specified predicate.
and(Predicate<StreamingHttpRequest>) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches StreamingHttpRequests with a user-specified predicate.
andCookie(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a CookieMatcher that matches against HttpSetCookies with the name name.
andHeader(CharSequence) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the name headers.
andIsNotSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests that are not over SSL/TLS.
andIsSsl() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests that are over SSL/TLS.
andMethod(HttpRequestMethod) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the HttpRequestMethod is method.
andMethodIsOneOf(HttpRequestMethod...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the HttpRequestMethod is one of the methods.
andPathEquals(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path is equal to path.
andPathIsOneOf(String...) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path is equal to any of the specified paths.
andPathMatches(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathMatches(Pattern) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path matches the regex pathRegex.
andPathStartsWith(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route such that it matches requests where the path starts with pathPrefix.
andQueryParam(String) - Method in interface io.servicetalk.http.router.predicate.dsl.RouteContinuation
Extends the current route with a StringMultiValueMatcher that matches against the value(s) of the request parameter name.
andThen(ChannelInitializer) - Method in interface io.servicetalk.transport.netty.internal.ChannelInitializer
Returns a new ChannelInitializer which will first invoke this initializer and then after.
anyOf(Completable...) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
anyOf(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
anyOf(Iterable<Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Creates a new Completable that terminates with the result (either success or error) of whichever amongst the passed completables that terminates first.
anyOf(Iterable<Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Creates a new Single that terminates with the result (either success or error) of whichever amongst the passed singles that terminates first.
append(ConnectionFactoryFilter<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter
Deprecated.
consider using higher level client builders to append filters.
append(GrpcClientBuilder.HttpInitializer<U, R>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.HttpInitializer
Appends the passed GrpcClientBuilder.HttpInitializer to this GrpcClientBuilder.HttpInitializer such that this instance is applied first and then the argument's GrpcClientBuilder.HttpInitializer.
append(GrpcServerBuilder.HttpInitializer) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder.HttpInitializer
Appends the passed GrpcServerBuilder.HttpInitializer to this GrpcServerBuilder.HttpInitializer such that this instance is applied first and then the argument's GrpcServerBuilder.HttpInitializer.
append(HttpExecutionStrategyInfluencer) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
Append another HttpExecutionStrategyInfluencer to this chain.
append(MultiAddressHttpClientBuilder.SingleAddressInitializer<U, R>) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder.SingleAddressInitializer
append(PartitionedHttpClientBuilder.SingleAddressInitializer<U, R>) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder.SingleAddressInitializer
Deprecated.
append(PartitionHttpClientBuilderConfigurator<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator
Deprecated.
append(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
Deprecated.
Returns a composed ConnectionAcceptor that first applies this ConnectionAcceptor, and if this is successful then applies after ConnectionAcceptor.
append(ConnectionAcceptorFactory) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory
Deprecated.
Returns a composed function that first applies the before function to its input, and then applies this function to the result.
append(ExecutionStrategyInfluencer<?>) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
Append another ExecutionStrategyInfluencer to this chain.
append(T) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends the passed AsyncCloseable with this CompositeCloseable such that when this CompositeCloseable is closed, all of the previously registered AsyncCloseables are closed too.
appendAll(AsyncCloseable...) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendAll(Iterable<? extends AsyncCloseable>) - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Appends all the passed AsyncCloseables with this CompositeCloseable such that when this CompositeCloseable is closed, all of these AsyncCloseables are closed too.
appendClientFilter(StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
appendClientFilter(StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the HttpClient created by this builder.
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
appendClientFilter(Predicate<StreamingHttpRequest>, StreamingHttpClientFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the HttpClient created by this builder, for every request that passes the provided Predicate.
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendConnectionAcceptorFilter(ConnectionAcceptorFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
appendConnectionFactoryFilter(ConnectionFactoryFilter<R, FilterableStreamingHttpConnection>) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the ConnectionFactory used by this builder.
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
appendConnectionFilter(StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpConnection created by this builder.
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
appendConnectionFilter(Predicate<StreamingHttpRequest>, StreamingHttpConnectionFilterFactory) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpConnection created by this builder, for every request that passes the provided Predicate.
appendEarlyConnectionAcceptor(EarlyConnectionAcceptor) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendEarlyConnectionAcceptor(EarlyConnectionAcceptor) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends the EarlyConnectionAcceptor to be called when a new connection has been created.
appendIfInfluencer(Object) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
If the passed mayBeInfluencer is an ExecutionStrategyInfluencer then add it to this chain.
appendLateConnectionAcceptor(LateConnectionAcceptor) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendLateConnectionAcceptor(LateConnectionAcceptor) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends the LateConnectionAcceptor to be called when a new connection has been created.
appendNonOffloadingServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendNonOffloadingServiceFilter(StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends a non-offloading filter to the chain of filters used to decorate the StreamingHttpService used by this builder.
appendNonOffloadingServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendNonOffloadingServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends a non-offloading filter to the chain of filters used to decorate the StreamingHttpService used by this builder, for every request that passes the provided Predicate.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequest
 
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Appends segments to the current HttpRequestMetaData.path(), performing encoding of each segment (including ('/') characters) according to percent-encoding.
appendPathSegments(String...) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
appendServiceFilter(StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendServiceFilter(StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder.
appendServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
appendServiceFilter(Predicate<StreamingHttpRequest>, StreamingHttpServiceFilterFactory) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Appends the filter to the chain of filters used to decorate the StreamingHttpService used by this builder, for every request that passes the provided Predicate.
APPLICATION_GRPC - Static variable in class io.servicetalk.grpc.api.GrpcHeaderValues
application/grpc value for content-type header.
APPLICATION_GRPC_PROTO - Static variable in class io.servicetalk.grpc.api.GrpcHeaderValues
application/grpc+proto value for content-type header.
APPLICATION_JSON - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/json"
APPLICATION_X_PROTOBUF - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes
"application/x-protobuf".
APPLICATION_X_PROTOBUF - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-protobuf"
APPLICATION_X_PROTOBUF_TYPE - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes
"application/x-protobuf".
APPLICATION_X_PROTOBUF_VAR_INT - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes
"application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
APPLICATION_X_PROTOBUF_VAR_INT - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
APPLICATION_X_PROTOBUF_VAR_INT_TYPE - Static variable in class io.servicetalk.data.protobuf.jersey.ProtobufMediaTypes
"application/x-protobuf-var-int" base 128 VarInt protobuf encoding.
APPLICATION_X_WWW_FORM_URLENCODED - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-www-form-urlencoded"
APPLICATION_X_WWW_FORM_URLENCODED_UTF_8 - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"application/x-www-form-urlencoded; charset=UTF-8"
applicationStatus() - Method in exception io.servicetalk.grpc.api.GrpcStatusException
Returns the status details if any was included or null.
apply(boolean, StreamingHttpRequest, StreamingHttpResponse, StreamingHttpRequest) - Method in interface io.servicetalk.http.api.RedirectConfig.RedirectRequestTransformer
Applies transformations for the pre-initialized redirect request.
apply(int, T) - Method in interface io.servicetalk.concurrent.api.BiIntFunction
Evaluates this function on the given arguments.
apply(PartitionAttributes, ServiceDiscoverer<U, R, ServiceDiscovererEvent<R>>) - Method in interface io.servicetalk.client.api.internal.DefaultPartitionedClientGroup.PartitionedClientFactory
Deprecated.
Create a partitioned client.
apply(CompletableSource.Subscriber) - Method in interface io.servicetalk.concurrent.api.CompletableOperator
Implementation of this operator.
apply(PublisherSource.Subscriber<? super Iterable<T>>) - Method in class io.servicetalk.serializer.utils.FramedDeserializerOperator
 
apply(PublisherSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherOperator
Implementation of this operator.
apply(SingleSource.Subscriber<? super StreamingHttpResponse>) - Method in class io.servicetalk.http.utils.BeforeFinallyHttpOperator
 
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.PublisherToSingleOperator
Implementation of this operator.
apply(SingleSource.Subscriber<? super R>) - Method in interface io.servicetalk.concurrent.api.SingleOperator
Implementation of this operator.
apply(HttpRequestMetaData) - Method in interface io.servicetalk.http.utils.TimeoutFromRequest
Deprecated.
Determine timeout duration, if present, from a request and/or apply default timeout durations.
apply(FlushStrategy.FlushSender) - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
 
apply(FlushStrategy.FlushSender) - Method in interface io.servicetalk.transport.netty.internal.FlushStrategy
Every time a new write that requires custom flushes is initiated, this method is invoked.
apply(FlushStrategy.FlushSender) - Method in class io.servicetalk.transport.netty.internal.SplittingFlushStrategy
Deprecated.
 
apply(String, String) - Method in interface io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.CredentialsVerifier
Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
apply(T1, T2, T3) - Method in interface io.servicetalk.concurrent.api.Function3
Applies the function to the given arguments.
apply(T1, T2, T3, T4) - Method in interface io.servicetalk.concurrent.api.Function4
Applies the function to the given arguments.
appSerializerAsciiFixLen() - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.US_ASCII encoding using fixed int length delimited framing.
appSerializerAsciiVarLen() - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.US_ASCII encoding using variable int length delimited framing.
appSerializerFixLen(Charset) - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with charset encoding using fixed int length delimited framing.
appSerializerUtf8FixLen() - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.UTF_8 encoding using fixed int length delimited framing.
appSerializerUtf8VarLen() - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with StandardCharsets.UTF_8 encoding using variable int length delimited framing.
appSerializerVarLen(Charset) - Static method in class io.servicetalk.http.api.HttpSerializers
Creates a HttpStreamingSerializerDeserializer that serializes Strings with charset encoding using fixed int length delimited framing.
array() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the backing byte array of this buffer.
array() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
arrayOffset() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the offset of the first byte within the backing byte array of this buffer.
arrayOffset() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
ArrayUtils - Class in io.servicetalk.concurrent.internal
Deprecated.
This internal class will be removed in the future releases without a replacement. If you depend on it, consider copying into your codebase.
asBlockingClient() - Method in interface io.servicetalk.grpc.api.GrpcClient
Converts this GrpcClient to a blocking client.
asBlockingClient() - Method in interface io.servicetalk.health.v1.Health.HealthClient
 
asBlockingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
asBlockingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the BlockingHttpClient API.
asBlockingClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
Convert this StreamingHttpClient to the BlockingHttpClient API.
asBlockingConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asBlockingConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
Convert this HttpConnection to the BlockingHttpConnection API.
asBlockingConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asBlockingConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the BlockingStreamingHttpClient API.
asBlockingStreamingClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
asBlockingStreamingConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asBlockingStreamingConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
asChildOf(Span) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
 
asChildOf(SpanContext) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanBuilder
 
asciiStringIndexOf(CharSequence, char, int) - Static method in class io.servicetalk.buffer.api.CharSequences
asClient() - Method in interface io.servicetalk.grpc.api.BlockingGrpcClient
Converts this BlockingGrpcClient to a client.
asClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
Convert this BlockingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
Convert this BlockingStreamingHttpClient to the HttpClient API.
asClient() - Method in interface io.servicetalk.http.api.StreamingHttpClient
Convert this StreamingHttpClient to the HttpClient API.
asConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
Convert this BlockingHttpConnection to the HttpConnection API.
asConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asConnection() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpLoadBalancedConnection
 
asConnection() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.ReservedStreamingHttpConnection
 
asConnection() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
Convert this StreamingHttpConnection to the HttpConnection API.
asException() - Method in class io.servicetalk.grpc.api.GrpcStatus
asException(Supplier<Status>) - Method in class io.servicetalk.grpc.api.GrpcStatus
asExecutor() - Method in interface io.servicetalk.transport.netty.internal.NettyIoExecutor
Deprecated.
IoExecutor now implements Executor so this method is redundant.
asInputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer
Return an InputStream that wraps the given Buffer.
asOutputStream(Buffer) - Static method in interface io.servicetalk.buffer.api.Buffer
Return an OutputStream that wraps the given Buffer.
asReadOnly() - Method in interface io.servicetalk.buffer.api.Buffer
Create a read-only view for this buffer.
asReadOnly() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
asReadOnly() - Method in class io.servicetalk.tcp.netty.internal.TcpClientConfig
Create a read only view of this object.
asReadOnly() - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
Create a read only view of this object.
asSafeObserver(TransportObserver) - Static method in class io.servicetalk.transport.api.TransportObservers
Coverts passed TransportObserver to a safe version that catches and logs all exceptions, but does not rethrow them.
assertNoAsyncErrors(String, Queue<? extends Throwable>) - Static method in class io.servicetalk.test.resources.TestUtils
Helper method to check if a given Queue contains any errors, usually produced through async sources.
assertNoAsyncErrors(Queue<? extends Throwable>) - Static method in class io.servicetalk.test.resources.TestUtils
Helper method to check if a given Queue contains any errors, usually produced through async sources.
assignConnectionError(Channel, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils
Assigns a Throwable to the passed Channel to report it as a closure reason.
asStreamingClient() - Method in interface io.servicetalk.http.api.BlockingHttpClient
Convert this BlockingHttpClient to the StreamingHttpClient API.
asStreamingClient() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpClient
asStreamingClient() - Method in interface io.servicetalk.http.api.HttpClient
Convert this HttpClient to the StreamingHttpClient API.
asStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
asStreamingConnection() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
asStreamingConnection() - Method in interface io.servicetalk.http.api.HttpConnection
Convert this HttpConnection to the StreamingHttpConnection API.
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingHttpConnection
 
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedBlockingStreamingHttpConnection
 
asStreamingConnection() - Method in interface io.servicetalk.http.api.ReservedHttpConnection
 
AsyncCloseable - Interface in io.servicetalk.concurrent.api
Used to close/shutdown a resource.
AsyncCloseables - Class in io.servicetalk.concurrent.api
A utility class to create AsyncCloseables.
AsyncCloseables.CloseableResource - Interface in io.servicetalk.concurrent.api
A resource that can be converted to an AsyncCloseable.
AsyncContext - Class in io.servicetalk.concurrent.api
Presents a static interface to retain state in an asynchronous environment.
AsyncContextInMemoryScopeManager - Class in io.servicetalk.opentracing.asynccontext
A InMemoryScopeManager that uses AsyncContext as the backing storage.
AuthenticationException - Exception in io.servicetalk.http.utils.auth
An authentication exception, which indicates that access was denied and usually converts to 401 (Unauthorized) or 407 (Proxy Authentication Required) response.
AuthenticationException(String) - Constructor for exception io.servicetalk.http.utils.auth.AuthenticationException
Creates a new instance.
AUTHORIZATION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"authorization"
AutoClosableUtils - Class in io.servicetalk.concurrent.internal
Utilities for AutoCloseable.
AutoCloseables - Class in io.servicetalk.concurrent.api
A utility class for methods related to AutoCloseable.
available() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
 
AVAILABLE - Static variable in class io.servicetalk.client.api.ServiceDiscovererEvent.Status
Signifies the ServiceDiscovererEvent.address() is available for use in connection establishment.
await(CountDownLatch) - Static method in class io.servicetalk.concurrent.test.internal.AwaitUtils
Await a CountDownLatch until the latch is counted down, throws unchecked InterruptedException.
await(CountDownLatch, long, TimeUnit) - Static method in class io.servicetalk.concurrent.test.internal.AwaitUtils
Await a CountDownLatch until the latch is counted down or the given time duration expires, throws unchecked InterruptedException.
awaitOnComplete() - Method in class io.servicetalk.concurrent.test.internal.TestCompletableSubscriber
Block until a terminal signal is received, throws if TestCompletableSubscriber.onError(Throwable) and returns normally if TestCompletableSubscriber.onComplete().
awaitOnComplete() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber
Block until a terminal signal is received, throws if TestPublisherSubscriber.onError(Throwable) and returns normally if TestPublisherSubscriber.onComplete().
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestCompletableSubscriber
Block until a terminal signal is received, throws if TestCompletableSubscriber.onComplete() and returns normally if TestCompletableSubscriber.onError(Throwable).
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber
Block until a terminal signal is received, throws if TestPublisherSubscriber.onComplete() and returns normally if TestPublisherSubscriber.onError(Throwable).
awaitOnError() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber
Block until a terminal signal is received, throws if TestSingleSubscriber.onSuccess(Object) and returns normally if TestSingleSubscriber.onError(Throwable).
awaitOnSuccess() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber
Block until a terminal signal is received, throws if TestSingleSubscriber.onError(Throwable) and returns normally if TestSingleSubscriber.onSuccess(Object).
awaitResult(Future<T>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils
Await the completion of the passed Future and return its result.
awaitShutdown() - Method in interface io.servicetalk.transport.api.ServerContext
Blocks and awaits shutdown of the server this ServerContext represents.
awaitSubscription() - Method in class io.servicetalk.concurrent.test.internal.TestCompletableSubscriber
awaitSubscription() - Method in class io.servicetalk.concurrent.test.internal.TestPublisherSubscriber
awaitSubscription() - Method in class io.servicetalk.concurrent.test.internal.TestSingleSubscriber
awaitTermination(Future<Void>) - Static method in class io.servicetalk.concurrent.internal.FutureUtils
Await the completion of the passed Future.
AwaitUtils - Class in io.servicetalk.concurrent.test.internal
Utilities to do blocking await calls for tests.

B

B3KeyValueFormatter<T> - Class in io.servicetalk.opentracing.inmemory
 
B3KeyValueFormatter(TriConsumer<T, CharSequence, CharSequence>, BiFunction<T, CharSequence, CharSequence>, boolean) - Constructor for class io.servicetalk.opentracing.inmemory.B3KeyValueFormatter
Create a new instance.
BACKGROUND - Enum constant in enum class io.servicetalk.http.netty.HttpClients.DiscoveryStrategy
Resolves an address in a background.
backgroundExecutor(Executor) - Method in class io.servicetalk.loadbalancer.DelegatingLoadBalancerBuilder
 
backgroundExecutor(Executor) - Method in class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
 
backgroundExecutor(Executor) - Method in interface io.servicetalk.loadbalancer.LoadBalancerBuilder
Set the background Executor to use for determining time and scheduling background tasks such as those associated with outlier detection.
backgroundExecutor(Executor) - Method in interface io.servicetalk.loadbalancer.RoundRobinLoadBalancerBuilder
This LoadBalancer may monitor hosts to which connection establishment has failed using health checks that run in the background.
backgroundExecutor(Executor) - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder
Deprecated.
 
backoffRatio(float, float) - Method in class io.servicetalk.capacity.limiter.api.AimdCapacityLimiterBuilder
Defines the backoff ratios for AIMD.
backoffRatio(float, float) - Method in class io.servicetalk.capacity.limiter.api.GradientCapacityLimiterBuilder
Defines the backoff ratios when certain conditions are met.
BAD_GATEWAY - Static variable in class io.servicetalk.http.api.HttpResponseStatus
502 Bad Gateway
BAD_REQUEST - Static variable in class io.servicetalk.http.api.HttpResponseStatus
400 Bad Request
badGateway() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badGateway() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badGateway() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_GATEWAY response.
badRequest() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
badRequest() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
badRequest() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.BAD_REQUEST response.
baggageItems() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemorySpanContext
 
BASE64 - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"base64"
baseEjectionTime() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The base ejection time.
baseEjectionTime(Duration) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the base ejection time.
baseUriFunction(BiFunction<ConnectionContext, HttpRequestMetaData, String>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Set the function used to compute the base URI for the incoming HTTP request.
BasicAuthenticated - Annotation Interface in io.servicetalk.http.security.auth.basic.jersey
Indicates that the marked Application, resource class or resource method is authenticated with HTTP Basic and that a SecurityContext needs to be established for the in-flight request.
BasicAuthHttpServiceFilter<UserInfo> - Class in io.servicetalk.http.utils.auth
A StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.Builder<UserInfo> - Class in io.servicetalk.http.utils.auth
A builder for an StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo> - Interface in io.servicetalk.http.utils.auth
Verifies user-id and password, parsed from the 'Basic' HTTP Authentication Scheme credentials.
BasicAuthPrincipal<UserInfo> - Class in io.servicetalk.http.security.auth.basic.jersey
A generic Principal that wraps a user provided UserInfo.
BasicAuthPrincipal(UserInfo) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
Create a new instance.
BasicAuthSecurityContext - Class in io.servicetalk.http.security.auth.basic.jersey
A generic SecurityContext that wraps a user provided Principal, and which is designed for the SecurityContext.BASIC_AUTH authentication scheme.
BasicAuthSecurityContext(Principal, boolean) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
Creates a new instance, which has no support for roles.
BasicAuthSecurityContext(Principal, boolean, Predicate<String>) - Constructor for class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContext
Creates a new instance.
BasicAuthSecurityContextFilters - Class in io.servicetalk.http.security.auth.basic.jersey
Factory methods for building ContainerRequestFilter that establish SecurityContexts for requests authenticated with the Basic HTTP Authentication Scheme (RFC7617).
BasicAuthSecurityContextFilters.AbstractBuilder<B extends BasicAuthSecurityContextFilters.AbstractBuilder,PF,SCF> - Class in io.servicetalk.http.security.auth.basic.jersey
A builder for ContainerRequestFilter instances.
BasicAuthSecurityContextFilters.NoUserInfoBuilder - Class in io.servicetalk.http.security.auth.basic.jersey
A builder that can be used when no user info is stored in AsyncContext.
BasicAuthSecurityContextFilters.UserInfoBuilder<UserInfo> - Class in io.servicetalk.http.security.auth.basic.jersey
A builder that can be used when user info is stored in AsyncContext.
batchFlush(int, Publisher<?>) - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
Creates a FlushStrategy that will flush writes in a batch of batchSize or on expiration of a batch duration i.e.
batchSpans(int, Duration) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Configure batching of spans before sending it to the zipkin collector.
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for Subscriptions of the returned Completable.
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for PublisherSource.Subscriptions of the returned Publisher.
beforeCancel(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onCancel Runnable argument before Cancellable.cancel() is called for Subscriptions of the returned Single.
beforeFinally(SingleTerminalSignalConsumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the corresponding method on beforeFinally TerminalSignalConsumer argument before any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() - invokes TerminalSignalConsumer.onComplete() CompletableSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
beforeFinally(TerminalSignalConsumer) - Method in class io.servicetalk.concurrent.api.Single
Invokes the corresponding method on beforeFinally TerminalSignalConsumer argument before any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) - invokes TerminalSignalConsumer.onComplete() SingleSource.Subscriber.onError(Throwable) - invokes TerminalSignalConsumer.onError(Throwable) Cancellable.cancel() - invokes TerminalSignalConsumer.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the whenFinally Runnable argument before any of the following terminal methods are called: CompletableSource.Subscriber.onComplete() CompletableSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/CompletableSource.Subscribers of the returned Completable.
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the beforeFinally Runnable argument before any of the following terminal methods are called: PublisherSource.Subscriber.onComplete() PublisherSource.Subscriber.onError(Throwable) Cancellable.cancel() for PublisherSource.Subscriptions/PublisherSource.Subscribers of the returned Publisher.
beforeFinally(Runnable) - Method in class io.servicetalk.concurrent.api.Single
Invokes the whenFinally Runnable argument before any of the following terminal methods are called: SingleSource.Subscriber.onSuccess(Object) SingleSource.Subscriber.onError(Throwable) Cancellable.cancel() for Subscriptions/SingleSource.Subscribers of the returned Single.
BeforeFinallyHttpOperator - Class in io.servicetalk.http.utils
Helper operator for signaling the end of an HTTP Request/Response cycle.
BeforeFinallyHttpOperator(TerminalSignalConsumer) - Constructor for class io.servicetalk.http.utils.BeforeFinallyHttpOperator
Create a new instance.
BeforeFinallyHttpOperator(TerminalSignalConsumer, boolean) - Constructor for class io.servicetalk.http.utils.BeforeFinallyHttpOperator
Create a new instance.
BeforeFinallyHttpOperator(Runnable) - Constructor for class io.servicetalk.http.utils.BeforeFinallyHttpOperator
Create a new instance.
beforeOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onComplete Runnable argument before CompletableSource.Subscriber.onComplete() is called for CompletableSource.Subscribers of the returned Completable.
beforeOnComplete(Runnable) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onComplete Runnable argument before PublisherSource.Subscriber.onComplete() is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onError Consumer argument before CompletableSource.Subscriber.onError(Throwable) is called for CompletableSource.Subscribers of the returned Completable.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onError Consumer argument before PublisherSource.Subscriber.onError(Throwable) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnError(Consumer<Throwable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onError Consumer argument before SingleSource.Subscriber.onError(Throwable) is called for SingleSource.Subscribers of the returned Single.
beforeOnNext(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onNext Consumer argument before PublisherSource.Subscriber.onNext(Object) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnSubscribe(Consumer<? super PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onSubscribe Consumer argument before PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) is called for PublisherSource.Subscribers of the returned Publisher.
beforeOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Completable
Invokes the onSubscribe Consumer argument before CompletableSource.Subscriber.onSubscribe(Cancellable) is called for CompletableSource.Subscribers of the returned Completable.
beforeOnSubscribe(Consumer<Cancellable>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSubscribe Consumer argument before SingleSource.Subscriber.onSubscribe(Cancellable) is called for SingleSource.Subscribers of the returned Single.
beforeOnSuccess(Consumer<? super T>) - Method in class io.servicetalk.concurrent.api.Single
Invokes the onSuccess Consumer argument before SingleSource.Subscriber.onSuccess(Object) is called for SingleSource.Subscribers of the returned Single.
beforeRequest(LongConsumer) - Method in class io.servicetalk.concurrent.api.Publisher
Invokes the onRequest LongConsumer argument before PublisherSource.Subscription.request(long) is called for PublisherSource.Subscriptions of the returned Publisher.
beforeRequestStart() - Method in interface io.servicetalk.loadbalancer.RequestTracker
Invoked before each start of the action for which latency is to be tracked.
beforeRetry(int, HttpRequestMetaData, Throwable) - Method in interface io.servicetalk.http.netty.RetryingHttpRequesterFilter.RetryCallbacks
Called after a retry decision has been made, but before the retry is performed.
beforeSubscriber(Supplier<? extends CompletableSource.Subscriber>) - Method in class io.servicetalk.concurrent.api.Completable
Creates a new CompletableSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the CompletableSource.Subscriber methods before the CompletableSource.Subscribers of the returned Completable.
beforeSubscriber(Supplier<? extends PublisherSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the PublisherSource.Subscriber methods before the PublisherSource.Subscribers of the returned Publisher.
beforeSubscriber(Supplier<? extends SingleSource.Subscriber<? super T>>) - Method in class io.servicetalk.concurrent.api.Single
Creates a new SingleSource.Subscriber (via the subscriberSupplier argument) on each call to subscribe and invokes all the SingleSource.Subscriber methods before the SingleSource.Subscribers of the returned Single.
beforeSubscription(Supplier<? extends PublisherSource.Subscription>) - Method in class io.servicetalk.concurrent.api.Publisher
Creates a new PublisherSource.Subscription (via the subscriptionSupplier argument) on each call to subscribe and invokes all the PublisherSource.Subscription methods before the PublisherSource.Subscriptions of the returned Publisher.
BiIntFunction<T,R> - Interface in io.servicetalk.concurrent.api
A special function that takes an int and a custom argument and returns the result.
BiIntPredicate<T> - Interface in io.servicetalk.concurrent.api
A special predicate that takes an int and a custom argument to evaluate.
BINARY - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"binary"
bind(GrpcServiceFactory.ServerBinder, ExecutionContext<?>) - Method in class io.servicetalk.grpc.api.GrpcServiceFactory
Use the passed GrpcServiceFactory.ServerBinder to bind an appropriate gRPC service for the server.
bind(HttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds an HttpService to the associated server.
bind(SocketAddress, ReadOnlyTcpServerConfig, boolean, ExecutionContext<?>, InfluencerConnectionAcceptor, BiFunction<Channel, ConnectionObserver, Single<CC>>, Consumer<CC>) - Static method in class io.servicetalk.tcp.netty.internal.TcpServerBinder
Deprecated.
use the bind method with early and late acceptors instead.
bind(SocketAddress, ReadOnlyTcpServerConfig, ExecutionContext<?>, InfluencerConnectionAcceptor, BiFunction<Channel, ConnectionObserver, Single<CC>>, Consumer<CC>, EarlyConnectionAcceptor, LateConnectionAcceptor) - Static method in class io.servicetalk.tcp.netty.internal.TcpServerBinder
Create a ServerContext that represents a socket which is bound and listening on the listenAddress.
bindBlocking(BlockingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a BlockingHttpService to the associated server.
bindBlockingStreaming(BlockingStreamingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a BlockingStreamingHttpService to the associated server.
bindService() - Method in interface io.servicetalk.grpc.api.GrpcBindableService
Return an appropriate service factory bound to this service.
bindService() - Method in interface io.servicetalk.health.v1.Health.BlockingHealthService
Makes a Health.ServiceFactory bound to this instance implementing Health.BlockingHealthService
bindService() - Method in interface io.servicetalk.health.v1.Health.HealthService
Makes a Health.ServiceFactory bound to this instance implementing Health.HealthService
bindStreaming(StreamingHttpService) - Method in interface io.servicetalk.grpc.api.GrpcServiceFactory.ServerBinder
Binds a StreamingHttpService to the associated server.
BlockingGrpcClient<Client extends GrpcClient> - Interface in io.servicetalk.grpc.api
A blocking client to a gRPC service.
BlockingGrpcService - Interface in io.servicetalk.grpc.api
A blocking gRPC service.
BlockingHttpClient - Interface in io.servicetalk.http.api
The equivalent of HttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpConnection - Interface in io.servicetalk.http.api
The equivalent of HttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpRequester - Interface in io.servicetalk.http.api
The equivalent of HttpRequester with synchronous/blocking APIs instead of asynchronous APIs.
BlockingHttpService - Interface in io.servicetalk.http.api
The equivalent of HttpService but with synchronous/blocking APIs instead of asynchronous APIs.
blockingInvocation(Completable) - Static method in class io.servicetalk.concurrent.api.internal.BlockingUtils
Subscribes a Completable immediately and awaits result.
blockingInvocation(Single<T>) - Static method in class io.servicetalk.concurrent.api.internal.BlockingUtils
Subscribes a Single immediately and awaits result.
BlockingIterable<T> - Interface in io.servicetalk.concurrent
An Iterable which supports generation of BlockingIterators.
BlockingIterable.Processor<T> - Interface in io.servicetalk.concurrent
A BlockingIterable that supports to dynamically emitting items using BlockingIterable.Processor.next(Object).
BlockingIterables - Class in io.servicetalk.concurrent.internal
Utility methods for BlockingIterable.
BlockingIterator<T> - Interface in io.servicetalk.concurrent
An Iterator that is also an AutoCloseable and whose blocking operations support timeout durations.
BlockingProcessorSignalsHolder<T> - Interface in io.servicetalk.concurrent.api
A holder of items for a BlockingIterable.Processor.
BlockingSpliterator<T> - Interface in io.servicetalk.concurrent
BlockingStreamingGrpcServerResponse<T> - Interface in io.servicetalk.grpc.api
The response for streaming use-cases that provides ability to defer sending response meta-data and write the payload to an GrpcPayloadWriter.
BlockingStreamingHttpClient - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpConnection - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequest - Interface in io.servicetalk.http.api
The equivalent of HttpRequest but provides the payload as a BlockingIterable.
BlockingStreamingHttpRequester - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpRequester but with synchronous/blocking APIs instead of asynchronous APIs.
BlockingStreamingHttpRequestFactory - Interface in io.servicetalk.http.api
A factory for creating BlockingStreamingHttpRequests.
BlockingStreamingHttpRequestResponseFactory - Interface in io.servicetalk.http.api
BlockingStreamingHttpResponse - Interface in io.servicetalk.http.api
The equivalent of HttpResponse but provides the payload as a BlockingIterable.
BlockingStreamingHttpResponseFactory - Interface in io.servicetalk.http.api
A factory for creating BlockingStreamingHttpResponses.
BlockingStreamingHttpServerResponse - Interface in io.servicetalk.http.api
The equivalent of HttpResponse but provides an ability to write the payload to an HttpPayloadWriter.
BlockingStreamingHttpService - Interface in io.servicetalk.http.api
The equivalent of StreamingHttpService but with synchronous/blocking APIs instead of asynchronous APIs.
blockingStreamingResponseFactory() - Method in class io.servicetalk.http.api.HttpServiceContext
BlockingUtils - Class in io.servicetalk.concurrent.api.internal
Common utility functions to unwrap ExecutionException from async operations.
boundaries() - Method in interface io.servicetalk.concurrent.api.BufferStrategy
Returns a Publisher representing asynchronous buffer boundaries.
BOUNDARY - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"boundary"
breaker() - Method in class io.servicetalk.traffic.resilience.http.StateContext
Returns the CircuitBreaker in-use for the currently evaluated request.
buffer(BufferStrategy<T, BC, B>) - Method in class io.servicetalk.concurrent.api.Publisher
Create a Publisher that buffers items from this Publisher and emit those buffers instead of the individual items.
Buffer - Interface in io.servicetalk.buffer.api
An arbitrary and sequential accessible sequence of zero or more bytes (octets).
bufferAllocator() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
 
bufferAllocator() - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
bufferAllocator() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
 
bufferAllocator() - Method in interface io.servicetalk.transport.api.ExecutionContext
Return the BufferAllocator that can be used to allocate Buffers if needed.
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Sets the BufferAllocator to be used by this server.
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder
Deprecated.
 
bufferAllocator(BufferAllocator) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
 
bufferAllocator(BufferAllocator) - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Sets the BufferAllocator to use.
BufferAllocator - Interface in io.servicetalk.buffer.api
An API to allocate Buffers.
BufferAllocators - Class in io.servicetalk.buffer.netty
Available BufferAllocators.
BufferDecoder - Interface in io.servicetalk.encoding.api
Used to decode buffers for aggregated and streaming use cases.
bufferDecoderGroup() - Method in class io.servicetalk.grpc.api.GrpcClientFactory
Get the supported BufferDecoderGroup for this client factory.
bufferDecoderGroup(BufferDecoderGroup) - Method in class io.servicetalk.grpc.api.GrpcClientFactory
Sets the supported BufferDecoderGroup for this client factory.
bufferDecoderGroup(BufferDecoderGroup) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
BufferDecoderGroup - Interface in io.servicetalk.encoding.api
A group of BufferDecoders used when multiple options may be supported.
BufferDecoderGroupBuilder - Class in io.servicetalk.encoding.api
Builder for BufferDecoderGroups.
BufferDecoderGroupBuilder() - Constructor for class io.servicetalk.encoding.api.BufferDecoderGroupBuilder
Create a new instance.
BufferDecoderGroupBuilder(int) - Constructor for class io.servicetalk.encoding.api.BufferDecoderGroupBuilder
Create a new instance.
bufferEncoder(SerializerDeserializer<Buffer>, StreamingSerializerDeserializer<Buffer>, CharSequence) - Static method in class io.servicetalk.encoding.netty.NettyBufferEncoders
Create a BufferEncoderDecoder given the underlying SerializerDeserializer and StreamingSerializerDeserializer implementations.
BufferEncoder - Interface in io.servicetalk.encoding.api
Used to encode buffers for aggregated and streaming use cases.
BufferEncoderDecoder - Interface in io.servicetalk.encoding.api
bufferEncoders(List<BufferEncoder>) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
BufferEncodingException - Exception in io.servicetalk.encoding.api
A specialization of SerializationException used to indicate an encoding exception.
BufferEncodingException(String) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException
Create a new instance.
BufferEncodingException(String, Throwable) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException
New instance.
BufferEncodingException(String, Throwable, boolean, boolean) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException
New instance.
BufferEncodingException(Throwable) - Constructor for exception io.servicetalk.encoding.api.BufferEncodingException
New instance.
BufferHandler - Class in io.servicetalk.transport.netty.internal
Deprecated.
This API is going to be removed in future releases with no planned replacement. If it cannot be removed from your application, consider copying it into your codebase.
BufferHolder - Interface in io.servicetalk.buffer.api
Deprecated.
This API is going to be removed in future releases with no planned replacement. If it cannot be removed from your application, consider copying it into your codebase.
BufferPublisherInputStream - Class in io.servicetalk.http.router.jersey.internal
An InputStream built around a Publisher<Buffer>, which can either be read OIO style or provide its wrapped Publisher.
BufferPublisherInputStream(Publisher<Buffer>, int) - Constructor for class io.servicetalk.http.router.jersey.internal.BufferPublisherInputStream
Creates a new BufferPublisherInputStream instance.
bufferSizeHint() - Method in interface io.servicetalk.concurrent.api.BufferStrategy
A rough estimate of the number of items in a buffer.
BufferStrategies - Class in io.servicetalk.concurrent.api
A static factory of BufferStrategy instances.
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B> - Interface in io.servicetalk.concurrent.api
A strategy for buffering items emitted from a Publisher.
BufferStrategy.Accumulator<T,B> - Interface in io.servicetalk.concurrent.api
An intermediate mutable object that holds items till it is finished.
BufferUtils - Class in io.servicetalk.buffer.netty
Internal utilities for Buffers.
build() - Method in class io.servicetalk.capacity.limiter.api.AimdCapacityLimiterBuilder
Builds an AIMD dynamic CapacityLimiter based on config options of this builder.
build() - Method in class io.servicetalk.capacity.limiter.api.FixedCapacityLimiterBuilder
Build a fixed capacity CapacityLimiter according to this configuration.
build() - Method in class io.servicetalk.capacity.limiter.api.GradientCapacityLimiterBuilder
Builds a Gradient dynamic CapacityLimiter based on config options of this builder.
build() - Method in class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
Deprecated.
 
build() - Method in interface io.servicetalk.client.api.partition.PartitionAttributesBuilder
Deprecated.
build() - Method in class io.servicetalk.concurrent.api.ReplayStrategyBuilder
Build the ReplayStrategy.
build() - Method in class io.servicetalk.encoding.api.BufferDecoderGroupBuilder
Build a new BufferDecoderGroup.
build() - Method in class io.servicetalk.encoding.netty.ZipCompressionBuilder
Build and return an instance of the SerializerDeserializer with the configuration of the builder.
build() - Method in class io.servicetalk.encoding.netty.ZipContentCodecBuilder
Deprecated.
Build and return an instance of the ContentCodec with the configuration of the builder.
build() - Method in class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
Builds a new GrpcExecutionStrategy.
build() - Method in class io.servicetalk.grpc.protobuf.ProtoBufSerializationProviderBuilder
Deprecated.
Builds a new GrpcSerializationProvider containing all the message types registered with this builder.
build() - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
build() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
build() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
build() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
build() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
 
build() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
build() - Method in class io.servicetalk.http.api.Http2SettingsBuilder
Build the Map that represents HTTP/2 Setting.
build() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder
Builds a new HttpClient.
build() - Method in class io.servicetalk.http.api.HttpExecutionStrategies.Builder
Builds a new HttpExecutionStrategy.
build() - Method in class io.servicetalk.http.api.ProxyConfigBuilder
Builds a new ProxyConfig.
build() - Method in class io.servicetalk.http.api.RedirectConfigBuilder
Builds a new RedirectConfig.
build() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
Builds this chain and returns a computed HttpExecutionStrategyInfluencer that reflects the strategy of the entire chain.
build() - Method in class io.servicetalk.http.netty.DefaultHttpLoadBalancerFactory.Builder
Deprecated.
Builds a DefaultHttpLoadBalancerFactory using the properties configured on this builder.
build() - Method in class io.servicetalk.http.netty.H1ProtocolConfigBuilder
build() - Method in class io.servicetalk.http.netty.H1SpecExceptions.Builder
build() - Method in class io.servicetalk.http.netty.H2KeepAlivePolicies.KeepAlivePolicyBuilder
build() - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder
build() - Method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter.Builder
Builds a retrying RetryingHttpRequesterFilter with this' builders configuration.
build() - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthSecurityContextFilters.AbstractBuilder
Build a new ContainerRequestFilter instance.
build() - Method in class io.servicetalk.loadbalancer.DelegatingLoadBalancerBuilder
 
build() - Method in class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
 
build() - Method in interface io.servicetalk.loadbalancer.LoadBalancerBuilder
Builds the LoadBalancerFactory configured by this builder.
build() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Build the OutlierDetectorConfig.
build() - Method in class io.servicetalk.loadbalancer.P2CLoadBalancingPolicy.Builder
Deprecated.
Construct an immutable P2CLoadBalancingPolicy.
build() - Method in class io.servicetalk.loadbalancer.P2CLoadBalancingPolicyBuilder
Construct an immutable P2CLoadBalancingPolicy.
build() - Method in interface io.servicetalk.loadbalancer.RoundRobinLoadBalancerBuilder
Builds the LoadBalancerFactory configured by this builder.
build() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder
Deprecated.
 
build() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancingPolicy.Builder
Deprecated.
Construct the immutable RoundRobinLoadBalancingPolicy.
build() - Method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancingPolicyBuilder
Construct the immutable RoundRobinLoadBalancingPolicy.
build() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
Builds a new OpenTelemetryOptions.
build() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Builds a new HttpReporter instance with this builder's options.
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Builds a new UdpReporter instance with this builder's options.
build() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder
Builds the ZipkinPublisher with supplied options.
build() - Method in class io.servicetalk.traffic.resilience.http.ServiceRejectionPolicy.Builder
Return a custom ServiceRejectionPolicy based on the options of this builder.
build() - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
Invoke to build an instance of TrafficResilienceHttpClientFilter filter to be used inside the HttpClientBuilder.
build() - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
Invoke to build an instance of TrafficResilienceHttpServiceFilter filter to be used inside the HttpServerBuilder.
build() - Method in class io.servicetalk.transport.api.ClientSslConfigBuilder
Build a new ClientSslConfig.
build() - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Build a new ServerSslConfig.
build() - Method in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
Builds a new ExecutionContext or return the default context if none of the components are set in this builder.
build(GrpcClientFactory<Client, ?>) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
build(GrpcClientFactory<Client, ?>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder
Builds a gRPC client.
build(GrpcClientFactory<Client, ?>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder
Builds a gRPC client.
build(HttpExecutionStrategy) - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
Builds this chain and returns the head HttpExecutionStrategyInfluencer for the chain.
build(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the HttpService for the specified JAX-RS Application class.
build(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the HttpService for the specified JAX-RS Application.
buildARecordDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
 
buildARecordDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
 
buildARecordDiscoverer() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder
Build a new ServiceDiscoverer which targets host addresses (e.g.
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
 
buildBlocking() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
buildBlocking() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder
Creates a new BlockingHttpClient.
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder
Builds a blocking gRPC client.
buildBlocking(GrpcClientFactory<?, BlockingClient>) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder.MultiClientBuilder
Builds a blocking gRPC client.
buildBlocking(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingHttpService for the specified JAX-RS Application class.
buildBlocking(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingHttpService for the specified JAX-RS Application.
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
 
buildBlockingStreaming() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
buildBlockingStreaming() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder
buildBlockingStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingStreamingHttpService for the specified JAX-RS Application class.
buildBlockingStreaming(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the BlockingStreamingHttpService for the specified JAX-RS Application.
builder(String) - Static method in class io.servicetalk.dns.discovery.netty.DnsServiceDiscoverers
builder(String) - Static method in class io.servicetalk.loadbalancer.LoadBalancers
A new LoadBalancerBuilder instance.
builder(String) - Static method in class io.servicetalk.loadbalancer.RoundRobinLoadBalancers
Builder() - Constructor for class io.servicetalk.grpc.api.GrpcExecutionStrategies.Builder
 
Builder() - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder
Create a new instance.
Builder() - Constructor for class io.servicetalk.http.netty.H1SpecExceptions.Builder
 
Builder() - Constructor for class io.servicetalk.http.netty.RetryingHttpRequesterFilter.Builder
 
Builder() - Constructor for class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Construct a new builder using the default initial values.
Builder() - Constructor for class io.servicetalk.loadbalancer.P2CLoadBalancingPolicy.Builder
Deprecated.
 
Builder() - Constructor for class io.servicetalk.loadbalancer.RoundRobinLoadBalancerFactory.Builder
Deprecated.
Builder() - Constructor for class io.servicetalk.loadbalancer.RoundRobinLoadBalancingPolicy.Builder
Deprecated.
 
Builder() - Constructor for class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
 
Builder() - Constructor for class io.servicetalk.traffic.resilience.http.ServiceRejectionPolicy.Builder
 
Builder(SingleAddressHttpClientBuilder<?, ?>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Builder(BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo>, String) - Constructor for class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new builder for an StreamingHttpServiceFilter, which filters HTTP requests using RFC7617: The 'Basic' HTTP Authentication Scheme.
Builder(InMemoryScopeManager) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer.Builder
Constructs a builder for an DefaultInMemoryTracer.
Builder(RouteExecutionStrategyFactory<GrpcExecutionStrategy>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder
Builder(RouteExecutionStrategyFactory<GrpcExecutionStrategy>, List<ContentCodec>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder
Builder(String, Reporter<Span>) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher.Builder
Create a new instance.
Builder(SocketAddress) - Constructor for class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Create a new UdpReporter.Builder for a given collectorAddress.
Builder(Supplier<CapacityLimiter>) - Constructor for class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
A TrafficResilienceHttpClientFilter with no partitioning schemes.
Builder(Supplier<CapacityLimiter>) - Constructor for class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
A TrafficResilienceHttpServiceFilter with no partitioning schemes.
Builder(Supplier<Function<HttpRequestMetaData, CapacityLimiter>>, boolean) - Constructor for class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
A TrafficResilienceHttpClientFilter can support request partitioning schemes.
Builder(Supplier<Function<HttpRequestMetaData, CapacityLimiter>>, boolean) - Constructor for class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
A TrafficResilienceHttpServiceFilter can support request partitioning schemes.
Builder(List<ContentCodec>) - Constructor for class io.servicetalk.health.v1.Health.ServiceFactory.Builder
BuilderUtils - Class in io.servicetalk.transport.netty.internal
Utilities which are used for builders.
buildMulti() - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
buildMulti() - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder
Returns a GrpcClientBuilder.MultiClientBuilder to be used to create multiple clients that share the underlying transport.
buildPartial() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
buildPartial() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
buildProxy() - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new instance for proxy service.
buildServer() - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter.Builder
Creates a new instance for non-proxy service.
buildSpan(String) - Method in interface io.servicetalk.opentracing.inmemory.api.InMemoryTracer
 
buildSpan(String) - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
buildSrvDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
 
buildSrvDiscoverer() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
 
buildSrvDiscoverer() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder
Build a new ServiceDiscoverer which queries SRV Resource Records corresponding to serviceName.
buildStreaming() - Method in class io.servicetalk.encoding.netty.ZipCompressionBuilder
Build and return an instance of the StreamingSerializerDeserializer with the configuration of the builder.
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
 
buildStreaming() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
buildStreaming() - Method in interface io.servicetalk.http.api.PartitionedHttpClientBuilder
Builds a new StreamingHttpClient.
buildStreaming() - Method in interface io.servicetalk.http.router.predicate.dsl.RouteStarter
Builds the StreamingHttpService that performs the configured routing.
buildStreaming() - Method in class io.servicetalk.http.router.predicate.HttpPredicateRouterBuilder
 
buildStreaming(Class<? extends Application>) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the StreamingHttpService for the specified JAX-RS Application class.
buildStreaming(Application) - Method in class io.servicetalk.http.router.jersey.HttpJerseyRouterBuilder
Build the StreamingHttpService for the specified JAX-RS Application.
byteArraySerializer(boolean) - Static method in class io.servicetalk.serializer.utils.ByteArraySerializer
Create a new instance.
ByteArraySerializer - Class in io.servicetalk.serializer.utils
Serialize/deserialize byte[].
ByteProcessor - Interface in io.servicetalk.buffer.api
Provides a mechanism to iterate over a collection of bytes.
BYTES - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"bytes"
bytesBefore(byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
bytesBefore(int, byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(int, byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
bytesBefore(int, int, byte) - Method in interface io.servicetalk.buffer.api.Buffer
Locates the first occurrence of the specified value in this buffer.
bytesBefore(int, int, byte) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
bytesEstimator() - Method in interface io.servicetalk.grpc.api.SerializerDescriptor
Get a function used to estimate the serialized size (in bytes) of each object.
bytesStreamingSerializer(Consumer<HttpHeaders>) - Static method in class io.servicetalk.http.api.HttpSerializers
Create a HttpStreamingSerializer that serializes byte[].
ByteToMessageDecoder - Class in io.servicetalk.transport.netty.internal
ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an other Message type.
ByteToMessageDecoder(ByteBufAllocator) - Constructor for class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Create a new instance.

C

cache() - Method in class io.servicetalk.concurrent.api.Completable
Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache() - Method in class io.servicetalk.concurrent.api.Single
Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int) - Method in class io.servicetalk.concurrent.api.Completable
Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache(int) - Method in class io.servicetalk.concurrent.api.Single
Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean) - Method in class io.servicetalk.concurrent.api.Completable
Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
cache(int, boolean) - Method in class io.servicetalk.concurrent.api.Single
Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean, BiFunction<T, Throwable, Completable>) - Method in class io.servicetalk.concurrent.api.Single
Create a Single that subscribes a single time upstream but allows for multiple downstream SingleSource.Subscribers.
cache(int, boolean, Function<Throwable, Completable>) - Method in class io.servicetalk.concurrent.api.Completable
Create a Completable that subscribes a single time upstream but allows for multiple downstream CompletableSource.Subscribers.
CACHE_CONTROL - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"cache-control"
CACHEABLE - Static variable in class io.servicetalk.http.api.HttpRequestMethod.Properties
As defined in Method Definitions, methods which are cacheable, but not safe or idempotent.
CacheConnectionHttpLoadBalanceFactory<ResolvedAddress> - Class in io.servicetalk.http.utils
A HttpLoadBalancerFactory that will cache successive connection creation attempts and return the same Single instead of creating a new connection each time.
CacheConnectionHttpLoadBalanceFactory(HttpLoadBalancerFactory<ResolvedAddress>, ToIntFunction<ResolvedAddress>) - Constructor for class io.servicetalk.http.utils.CacheConnectionHttpLoadBalanceFactory
Create a new instance.
calculateDifference(List<? extends T>, List<? extends T>, Comparator<T>, ServiceDiscovererUtils.TwoIntsConsumer, ServiceDiscovererEvent.Status) - Static method in class io.servicetalk.dns.discovery.netty.ServiceDiscovererUtils
Given a sorted list of currently active addresses, and a new set of unsorted active address calculate the ServiceDiscovererEvents.
calculateMaxQueueSize(int) - Method in interface io.servicetalk.concurrent.api.GroupedPublisher.QueueSizeProvider
Deprecated.
Calculate the maximum queue size for a particular GroupedPublisher key.
calculateSourceRequested(AtomicLongFieldUpdater<T>, AtomicLongFieldUpdater<T>, AtomicLongFieldUpdater<T>, int, T) - Static method in class io.servicetalk.concurrent.internal.ConcurrentUtils
Attempts to increment sourceRequestedUpdater in order to make it the same as requestNUpdater while not exceeding the limit.
cancel() - Method in interface io.servicetalk.concurrent.api.SingleTerminalSignalConsumer
Callback to indicate termination via Cancellable.cancel().
cancel() - Method in interface io.servicetalk.concurrent.api.TerminalSignalConsumer
Callback to indicate termination via Cancellable.cancel().
cancel() - Method in interface io.servicetalk.concurrent.Cancellable
Sends a hint to the producer of the associated asynchronous execution that the consumer related to this Cancellable is not interested in the outcome of the execution.
cancel() - Method in class io.servicetalk.concurrent.internal.ConcurrentSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.DelayedCancellable
 
cancel() - Method in class io.servicetalk.concurrent.internal.DelayedSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.ScalarValueSubscription
 
cancel() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable
 
cancel() - Method in class io.servicetalk.concurrent.internal.ThreadInterruptingCancellable
 
CANCEL - Static variable in class io.servicetalk.http.api.Http2ErrorCode
cancelAccumulation() - Method in interface io.servicetalk.concurrent.api.ReplayAccumulator
Called if the accumulation can be cancelled and any asynchronous resources can be cleaned up (e.g.
cancelCurrent() - Method in class io.servicetalk.concurrent.internal.SequentialCancellable
Cancels only the Cancellable that is currently held without side effect for any SequentialCancellable.nextCancellable(Cancellable).
CancelImmediatelySubscriber - Class in io.servicetalk.concurrent.internal
Cancellable - Interface in io.servicetalk.concurrent
An entity that can be cancelled.
CANCELLED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode
Cancelled (typically by caller).
CANCELLED - Enum constant in enum class io.servicetalk.loadbalancer.ErrorClass
Failure due to cancellation.
cancelUpstream() - Method in interface io.servicetalk.concurrent.api.ReplayStrategy
Determine if all the downstream subscribers cancel, should upstream be cancelled.
cancelUpstream(boolean) - Method in class io.servicetalk.concurrent.api.ReplayStrategyBuilder
Determine if all the downstream subscribers cancel, should upstream be cancelled.
capacity() - Method in interface io.servicetalk.buffer.api.Buffer
Returns the number of bytes (octets) this buffer can contain.
capacity() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
capacity(int) - Method in interface io.servicetalk.buffer.api.Buffer
Sets the capacity of this buffer.
capacity(int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
capacity(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
capacity(int) - Method in class io.servicetalk.capacity.limiter.api.FixedCapacityLimiterBuilder
Defines the fixed capacity for the CapacityLimiter.
CapacityLimiter - Interface in io.servicetalk.capacity.limiter.api
A provider of capacity for a client or server.
CapacityLimiter.LimiterState - Interface in io.servicetalk.capacity.limiter.api
Representation of the state of the CapacityLimiter when a CapacityLimiter.Ticket is issued.
CapacityLimiter.Ticket - Interface in io.servicetalk.capacity.limiter.api
Result of CapacityLimiter.tryAcquire(Classification, ContextMap) when capacity is enough to meet the demand.
CapacityLimiters - Class in io.servicetalk.capacity.limiter.api
A static factory for creating instances of CapacityLimiters.
capacityPartitions(Supplier<Function<HttpRequestMetaData, CapacityLimiter>>, boolean) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
Define CapacityLimiter partitions.
capacityPartitions(Supplier<Function<HttpRequestMetaData, CapacityLimiter>>, boolean) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
Define CapacityLimiter partitions.
capturedRequestHeaders() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions
List of request headers to be captured as extra span attributes.
capturedRequestHeaders(List<String>) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
Add the headers to be captured as extra span attributes.
capturedResponseHeaders() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions
List of response headers to be captured as extra span attributes.
capturedResponseHeaders(List<String>) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
Add the headers to be captured as extra span attributes.
caseInsensitiveHashCode(CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences
Calculate a hash code of a byte array assuming ASCII character encoding.
cast(Class<R>) - Method in class io.servicetalk.concurrent.api.Publisher
Cast this Publisher from type Publisher to type Publisher.
cast(Class<R>) - Method in class io.servicetalk.concurrent.api.Single
Cast this Single from type Single to type Single.
catchPayloadFailure(Void, Throwable, HttpHeaders) - Method in class io.servicetalk.http.api.StatelessTrailersTransformer
 
catchPayloadFailure(State, Throwable, HttpHeaders) - Method in interface io.servicetalk.http.api.TrailersTransformer
Invoked once all TrailersTransformer instances are accepted and the payload stream has terminated with an error.
catchUnexpected(Throwable, Throwable) - Static method in class io.servicetalk.concurrent.internal.ThrowableUtils
Used in scenarios where multiple operations which aren't expected to throw but exception propagation must be delayed to preserve control flow.
cause() - Method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns the cause of error if this is an error notification.
cause() - Method in class io.servicetalk.grpc.api.GrpcStatus
CertificateCompressionAlgorithm - Interface in io.servicetalk.transport.api
Represents an algorithm that can compress and decompress SSL certificates.
certificateCompressionAlgorithms() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
 
certificateCompressionAlgorithms() - Method in interface io.servicetalk.transport.api.SslConfig
Get the list of usable CertificateCompressionAlgorithms to advertise.
certificateCompressionAlgorithms(CertificateCompressionAlgorithm...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Sets the certificate compression algorithms to advertise if the feature is supported at runtime.
certificateCompressionAlgorithms(List<CertificateCompressionAlgorithm>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Sets the certificate compression algorithms to advertise if the feature is supported at runtime.
CertificateCompressionAlgorithms - Class in io.servicetalk.transport.api
CertificateCompressionException - Exception in io.servicetalk.transport.api
When thrown contains information about a failure during TLS certificate compression.
CertificateCompressionException(String) - Constructor for exception io.servicetalk.transport.api.CertificateCompressionException
Create a new CertificateCompressionException with just a message.
CertificateCompressionException(String, Throwable) - Constructor for exception io.servicetalk.transport.api.CertificateCompressionException
Create a new CertificateCompressionException with message and cause.
changePostToGet(boolean) - Method in class io.servicetalk.http.api.RedirectConfigBuilder
Enforces change of the request method from POST to GET for subsequent requests for 301 (Moved Permanently) and 302 (Found) status codes.
channel() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
Get access to the underlying Channel.
CHANNEL_CLOSEABLE_KEY - Static variable in class io.servicetalk.transport.netty.internal.ChannelSet
 
CHANNEL_CLOSED_INBOUND - Enum constant in enum class io.servicetalk.transport.netty.internal.CloseHandler.CloseEvent
Inbound SocketChannel shutdown observed.
CHANNEL_CLOSED_OUTBOUND - Enum constant in enum class io.servicetalk.transport.netty.internal.CloseHandler.CloseEvent
Outbound SocketChannel shutdown observed.
channelClosed(Throwable) - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
ChannelCloseUtils - Class in io.servicetalk.transport.netty.internal
Utilities to handle Channel closure and its reason.
channelError(Channel) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils
Returns an error associated with the passed Channel.
channelExecutionContext(Channel, ExecutionContext<ES>) - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextUtils
Utility that maps Channel.eventLoop() into IoExecutor and caches the result for future mappings to reduce allocations.
channelInactive(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
ChannelInitializer - Interface in io.servicetalk.transport.netty.internal
Configures a Channel.
channelOutboundClosed() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
channelRead(ChannelHandlerContext, Object) - Method in class io.servicetalk.transport.netty.internal.BufferHandler
Deprecated.
 
channelRead(ChannelHandlerContext, Object) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
channelReadComplete(ChannelHandlerContext) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
 
ChannelSet - Class in io.servicetalk.transport.netty.internal
Manages a set of Channels to provide a mechanism for closing all of them.
ChannelSet(Executor) - Constructor for class io.servicetalk.transport.netty.internal.ChannelSet
New instance.
channelWritable() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
CharSequences - Class in io.servicetalk.buffer.api
8-bit ASCII strings factory and basic utilities helper.
CHARSET - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"charset"
CharsetUtils - Class in io.servicetalk.utils.internal
Charset utilities.
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
check() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
check(GrpcClientMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient
If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcClientMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient
If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcExecutionStrategy, Health.CheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
check(GrpcServiceContext, HealthCheckRequest) - Method in class io.servicetalk.grpc.health.DefaultHealthService
 
check(GrpcServiceContext, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingCheckRpc
If the requested service is unknown, the call will fail with status NOT_FOUND.
check(GrpcServiceContext, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.CheckRpc
If the requested service is unknown, the call will fail with status NOT_FOUND.
check(Health.CheckMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient
check(Health.CheckMetadata, HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient
check(Health.CheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
check(HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.BlockingHealthClient
If the requested service is unknown, the call will fail with status NOT_FOUND.
check(HealthCheckRequest) - Method in interface io.servicetalk.health.v1.Health.HealthClient
If the requested service is unknown, the call will fail with status NOT_FOUND.
checkBlocking(GrpcExecutionStrategy, Health.BlockingCheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
checkBlocking(Health.BlockingCheckRpc) - Method in class io.servicetalk.health.v1.Health.ServiceFactory.Builder
 
checkDuplicateSubscription(PublisherSource.Subscription, PublisherSource.Subscription) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Checks for an already existing PublisherSource.Subscription and if one is given calls Cancellable.cancel() on next and returns false.
CheckMetadata(ContentCodec) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata
Deprecated.
 
CheckMetadata(GrpcExecutionStrategy) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata
Deprecated.
 
CheckMetadata(GrpcExecutionStrategy, ContentCodec) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata
Deprecated.
 
CheckMetadata(GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata
Deprecated.
 
CheckMetadata(Duration) - Constructor for class io.servicetalk.health.v1.Health.CheckMetadata
Deprecated.
 
CHUNKED - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"chunked"
ciphers() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
 
ciphers() - Method in interface io.servicetalk.transport.api.SslConfig
Get the cipher suites to enable, in the order of preference.
ciphers(String...) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the cipher suites to enable, in the order of preference.
ciphers(List<String>) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the cipher suites to enable, in the order of preference.
cipherSuiteFilter() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
 
cipherSuiteFilter() - Method in interface io.servicetalk.transport.api.SslConfig
Defines filtering behavior for ciphers suites.
cipherSuiteFilter(SslConfig.CipherSuiteFilter) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the filtering behavior for ciphers suites.
CircuitBreaker - Interface in io.servicetalk.circuit.breaker.api
ServiceTalk API for a Circuit Breaker.
circuitBreakerPartitions(Supplier<Function<HttpRequestMetaData, CircuitBreaker>>) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
Define CircuitBreaker to manage local or remote errors.
circuitBreakerPartitions(Supplier<Function<HttpRequestMetaData, CircuitBreaker>>) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
Define CircuitBreaker partitions to manage local errors.
Classification - Interface in io.servicetalk.capacity.limiter.api
Classification of requests.
classifier(Supplier<Function<HttpRequestMetaData, Classification>>) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
Classification in the context of capacity management allows for hints to the relevant CapacityLimiter to be influenced on the decision-making process by the class of the request.
classifier(Supplier<Function<HttpRequestMetaData, Classification>>) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter.Builder
Classification in the context of capacity management allows for hints to the relevant CapacityLimiter to be influenced on the decision making process by the class of the request.
clear() - Method in interface io.servicetalk.buffer.api.Buffer
Sets the readerIndex and writerIndex of this buffer to 0.
clear() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
 
clear() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
clear() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to clear all the entries from the current context.
clear() - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
clear() - Method in interface io.servicetalk.context.api.ContextMap
Clear the contents of this ContextMap.
clear() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
clear() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
clear() - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
clear() - Method in interface io.servicetalk.http.api.HttpHeaders
Removes all headers.
clear() - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
clearField(Descriptors.FieldDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
clearService() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
string service = 1;
clearStatus() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;
clearStatus(String) - Method in class io.servicetalk.grpc.health.DefaultHealthService
Clears the health status record of a service.
clearThreadLocal() - Static method in class io.servicetalk.transport.netty.internal.ExecutionContextUtils
 
CLIENT_ERROR_4XX - Enum constant in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass
clientAuthMode() - Method in class io.servicetalk.transport.api.DelegatingServerSslConfig
 
clientAuthMode() - Method in interface io.servicetalk.transport.api.ServerSslConfig
Get the client authentication mode.
clientAuthMode(SslClientAuthMode) - Method in class io.servicetalk.transport.api.ServerSslConfigBuilder
Set the SslClientAuthMode which determines how client authentication should be done.
ClientFactory() - Constructor for class io.servicetalk.health.v1.Health.ClientFactory
 
ClientGroup<Key,Client extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A data-structure capable of holding arbitrary number of clients and bridging lifecycle events across all clients managed by the group.
ClientInvoker<State> - Interface in io.servicetalk.http.api
Deprecated.
There is no use of this interface in our codebase, it will be removed in the future releases. If you depend on it, consider replicating a similar interface in your codebase.
clientNameFromAddress(U) - Method in class io.servicetalk.loadbalancer.experimental.DefaultHttpLoadBalancerProvider
Extract the service name from the address object.
ClientPeerRejectionPolicy - Class in io.servicetalk.traffic.resilience.http
Policy for peer capacity rejections that allows customization of behavior (retries or pass-through).
ClientSslConfig - Interface in io.servicetalk.transport.api
Specifies the configuration for client side TLS/SSL.
ClientSslConfigBuilder - Class in io.servicetalk.transport.api
Default builder for ClientSslConfig objects.
ClientSslConfigBuilder() - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder
Create a new instance using this JVM's TrustManagerFactory.getDefaultAlgorithm() and default TrustManagerFactory.
ClientSslConfigBuilder(Supplier<InputStream>) - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder
Create a new instance using trustCertChainSupplier to verify trusted servers.
ClientSslConfigBuilder(TrustManagerFactory) - Constructor for class io.servicetalk.transport.api.ClientSslConfigBuilder
Create a new instance using tmf to verify trusted servers.
clone() - Method in class io.servicetalk.health.v1.HealthCheckRequest.Builder
 
clone() - Method in class io.servicetalk.health.v1.HealthCheckResponse.Builder
 
close() - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Closes all contained AsyncCloseables and awaits termination of all of them.
close() - Method in class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
 
close() - Method in class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
 
close() - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
close() - Method in interface io.servicetalk.concurrent.BlockingIterable.Processor
Closes this BlockingIterable and all the current or future BlockingIterators.
close() - Method in interface io.servicetalk.concurrent.BlockingIterator
This method is used to communicate that you are no longer interested in consuming data.
close() - Method in interface io.servicetalk.concurrent.BlockingSpliterator
This method is used to communicate that you are no longer interested in consuming data.
close() - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIteratorAsInputStream
 
close() - Method in interface io.servicetalk.grpc.api.BlockingGrpcService
 
close() - Method in interface io.servicetalk.grpc.api.GrpcClient
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRequestStreamingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingResponseStreamingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingRoute
 
close() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.BlockingStreamingRoute
 
close() - Method in interface io.servicetalk.http.api.BlockingHttpRequester
 
close() - Method in interface io.servicetalk.http.api.BlockingHttpService
 
close() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequester
 
close() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpService
 
close() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
close() - Method in interface io.servicetalk.http.api.HttpClient
 
close() - Method in interface io.servicetalk.http.api.HttpConnection
 
close() - Method in interface io.servicetalk.http.api.StreamingHttpClient
 
close() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
 
close() - Method in class io.servicetalk.opentracing.inmemory.DefaultInMemoryTracer
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
close() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Blocking close method delegates to ZipkinPublisher.closeAsync().
close() - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Deprecated.
Disposes this StreamingDeserializer.
close() - Method in interface io.servicetalk.transport.api.ServerContext
 
close(ChannelHandlerContext, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils
Close the passed ChannelHandlerContext due to the observed error.
close(Channel, Throwable) - Static method in class io.servicetalk.transport.netty.internal.ChannelCloseUtils
Close the passed Channel due to the observed error.
close(Throwable) - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
close(Throwable) - Method in interface io.servicetalk.oio.api.PayloadWriter
This method shares the same characteristics as Closeable.close() but propagates cause to downstream consumer instead of propagating "successful" completion.
CLOSE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"close"
CloseableIterable<T> - Interface in io.servicetalk.concurrent
An Iterable which supports generation of CloseableIterators.
CloseableIterator<T> - Interface in io.servicetalk.concurrent
An Iterator that is also an AutoCloseable.
CloseableIteratorBufferAsInputStream - Class in io.servicetalk.concurrent.api.internal
Conversion from a CloseableIterator of Buffers to a InputStream.
CloseableIteratorBufferAsInputStream(CloseableIterator<Buffer>) - Constructor for class io.servicetalk.concurrent.api.internal.CloseableIteratorBufferAsInputStream
Create a new instance.
closeAndReThrow(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils
Call AutoCloseable.close() and re-throw any exception.
closeAndReThrowIoException(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils
Call AutoCloseable.close() and re-throw any exceptions as a IOException.
closeAndRethrowUnchecked(Closeable) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils
Call Closeable.close() and re-throw an unchecked exception if a checked exception is thrown.
closeAndReThrowUnchecked(AutoCloseable) - Static method in class io.servicetalk.concurrent.internal.AutoClosableUtils
closeAsync() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
 
closeAsync() - Method in class io.servicetalk.client.api.DelegatingServiceDiscoverer
 
closeAsync() - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
Deprecated.
 
closeAsync() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
Deprecated.
 
closeAsync() - Method in interface io.servicetalk.concurrent.api.AsyncCloseable
Used to close/shutdown a resource.
closeAsync() - Method in interface io.servicetalk.concurrent.api.CompositeCloseable
Closes all contained AsyncCloseables.
closeAsync() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.RequestStreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.ResponseStreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.Route
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcRoutes.StreamingRoute
 
closeAsync() - Method in interface io.servicetalk.grpc.api.GrpcService
 
closeAsync() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
closeAsync() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
closeAsync() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
closeAsync() - Method in interface io.servicetalk.http.api.HttpService
Closes this HttpService asynchronously.
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
 
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
closeAsync() - Method in interface io.servicetalk.http.api.StreamingHttpService
Closes this StreamingHttpService asynchronously.
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
 
closeAsync() - Method in class io.servicetalk.http.api.StreamingHttpServiceToOffloadedStreamingHttpService
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
closeAsync() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Attempts to close the configured Reporter.
closeAsync() - Method in interface io.servicetalk.transport.api.ConnectionAcceptor
Deprecated.
 
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
closeAsync() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
 
closeAsync() - Method in interface io.servicetalk.transport.api.EarlyConnectionAcceptor
 
closeAsync() - Method in interface io.servicetalk.transport.api.LateConnectionAcceptor
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.ChannelSet
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.NettyPipelinedConnection
 
closeAsync() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.DelegatingServiceDiscoverer
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
Deprecated.
 
closeAsyncGracefully() - Method in class io.servicetalk.client.api.internal.partition.PowerSetPartitionMap
Deprecated.
 
closeAsyncGracefully() - Method in interface io.servicetalk.concurrent.api.AsyncCloseable
Used to close/shutdown a resource, similar to AsyncCloseable.closeAsync(), but attempts to cleanup state before abruptly closing.
closeAsyncGracefully() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
 
closeAsyncGracefully() - Method in class io.servicetalk.http.api.StreamingHttpServiceToOffloadedStreamingHttpService
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter
 
closeAsyncGracefully() - Method in class io.servicetalk.opentracing.zipkin.publisher.ZipkinPublisher
Attempts to flush and close the configured Reporter.
closeAsyncGracefully() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.ChannelSet
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyPipelinedConnection
 
closeAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyServerContext
 
closeAsyncGracefully(AsyncCloseable, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.AsyncCloseables
Invokes AsyncCloseable.closeAsyncGracefully() on the closable, applies a timeout, and if the timeout fires forces a call to AsyncCloseable.closeAsync().
closeAsyncGracefullyNoOffload() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
closeAsyncNoOffload() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
 
ClosedPartitionException - Exception in io.servicetalk.client.api.partition
Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
ClosedPartitionException(PartitionAttributes, String) - Constructor for exception io.servicetalk.client.api.partition.ClosedPartitionException
Deprecated.
Create a new instance.
closeGracefully() - Method in interface io.servicetalk.concurrent.GracefulAutoCloseable
Used to close/shutdown a resource, similar to AutoCloseable.close(), but attempts to cleanup state before abruptly closing.
closeGracefully() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
closeGracefully() - Method in interface io.servicetalk.http.api.HttpClient
 
closeGracefully() - Method in interface io.servicetalk.http.api.HttpConnection
 
closeGracefully() - Method in interface io.servicetalk.http.api.StreamingHttpClient
 
closeGracefully() - Method in interface io.servicetalk.http.api.StreamingHttpConnection
 
closeGracefully() - Method in interface io.servicetalk.transport.api.ServerContext
 
closeGracefully(Executor, GracefulAutoCloseable, long, TimeUnit) - Static method in class io.servicetalk.concurrent.api.AutoCloseables
Invokes GracefulAutoCloseable.closeGracefully() on the closable, applies a timeout, and if the timeout fires forces a call to AutoCloseable.close().
CloseHandler - Class in io.servicetalk.transport.netty.internal
Contract between protocol codecs and a close handler.
CloseHandler() - Constructor for class io.servicetalk.transport.netty.internal.CloseHandler
 
CloseHandler.CloseEvent - Enum Class in io.servicetalk.transport.netty.internal
These events indicate an event was observed from the protocol or Channel that indicates the end of the Channel and no further requests should be attempted.
CloseHandler.CloseEventObservedException - Exception in io.servicetalk.transport.netty.internal
ClosedChannelException with additional meta-data to provide more context on what side initiated the close event.
CloseHandler.DiscardFurtherInboundEvent - Class in io.servicetalk.transport.netty.internal
Netty UserEvent to indicate the further inbound data should be discarded.
CloseHandler.InboundDataEndEvent - Class in io.servicetalk.transport.netty.internal
CloseHandler.NettyUserEvent to indicate the end of inbound data was observed at the transport.
closeIterator(Iterator<T>) - Method in class io.servicetalk.concurrent.internal.AbstractCloseableIterable
Closes an Iterator as returned by Iterable.iterator() of the Iterable that is wrapped by this AbstractCloseableIterable.
code() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns the status code.
code() - Method in class io.servicetalk.http.api.Http2ErrorCode
Get the decimal value of the error code.
code() - Method in class io.servicetalk.http.api.HttpResponseStatus
Get the three digit status-code indicating status of the response.
codeAsCharSequence() - Method in class io.servicetalk.http.api.HttpResponseStatus
codec() - Method in exception io.servicetalk.encoding.api.CodecDecodingException
Deprecated.
Returns the codec in use when this exception occurred.
codec() - Method in exception io.servicetalk.encoding.api.CodecEncodingException
Deprecated.
Returns the codec in use when this exception occurred.
codec(Codec) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.HttpReporter.Builder
Sets the Codec to encode the Spans with.
codec(Codec) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Sets the Codec to encode the Spans with.
Codec - Enum Class in io.servicetalk.opentracing.zipkin.publisher.reporter
Zipkin data formats for reporting of Spans.
CodecDecodingException - Exception in io.servicetalk.encoding.api
Deprecated.
CodecDecodingException(ContentCodec, String) - Constructor for exception io.servicetalk.encoding.api.CodecDecodingException
Deprecated.
New instance.
CodecDecodingException(ContentCodec, String, Throwable) - Constructor for exception io.servicetalk.encoding.api.CodecDecodingException
Deprecated.
New instance.
CodecEncodingException - Exception in io.servicetalk.encoding.api
Deprecated.
CodecEncodingException(ContentCodec, String) - Constructor for exception io.servicetalk.encoding.api.CodecEncodingException
Deprecated.
New instance.
CodecEncodingException(ContentCodec, String, Throwable) - Constructor for exception io.servicetalk.encoding.api.CodecEncodingException
Deprecated.
New instance.
collect(Supplier<? extends R>, BiFunction<? super R, ? super T, R>) - Method in class io.servicetalk.concurrent.api.Publisher
Collects all items emitted by this Publisher into a single item.
collectUnordered(int, Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnordered(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnordered(Iterable<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnordered(Iterable<? extends Single<? extends T>>, int) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnorderedDelayError(int, Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnorderedDelayError(Single<? extends T>...) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of the passed Singles into a single Collection.
collectUnorderedDelayError(Iterable<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
collectUnorderedDelayError(Iterable<? extends Single<? extends T>>, int) - Static method in class io.servicetalk.concurrent.api.Single
Asynchronously collects results of individual Singles returned by the passed Iterable into a single Collection.
combine(GrpcLifecycleObserver, GrpcLifecycleObserver) - Static method in class io.servicetalk.grpc.utils.GrpcLifecycleObservers
Combines multiple GrpcLifecycleObservers into a single GrpcLifecycleObserver.
combine(GrpcLifecycleObserver, GrpcLifecycleObserver, GrpcLifecycleObserver...) - Static method in class io.servicetalk.grpc.utils.GrpcLifecycleObservers
Combines multiple GrpcLifecycleObservers into a single GrpcLifecycleObserver.
combine(HttpLifecycleObserver, HttpLifecycleObserver) - Static method in class io.servicetalk.http.utils.HttpLifecycleObservers
Combines multiple HttpLifecycleObservers into a single HttpLifecycleObserver.
combine(HttpLifecycleObserver, HttpLifecycleObserver, HttpLifecycleObserver...) - Static method in class io.servicetalk.http.utils.HttpLifecycleObservers
Combines multiple HttpLifecycleObservers into a single HttpLifecycleObserver.
combine(TransportObserver...) - Static method in class io.servicetalk.transport.api.TransportObservers
Combines multiple TransportObservers into a single TransportObserver.
combine(Object, Object) - Static method in class io.servicetalk.utils.internal.ThrowableUtils
Combine two potential Throwables into one.
compareTo(PartitionAttributes.Key) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
Deprecated.
 
compareTo(HttpProtocolVersion) - Method in class io.servicetalk.http.api.HttpProtocolVersion
 
compareTo(HttpRequestMethod) - Method in class io.servicetalk.http.api.HttpRequestMethod
 
Completable - Class in io.servicetalk.concurrent.api
An asynchronous computation that does not emit any data.
Completable() - Constructor for class io.servicetalk.concurrent.api.Completable
New instance.
CompletableFirstStep - Interface in io.servicetalk.concurrent.api.test
Provides the ability to express expectations for the first step in a Subscriber's lifecycle.
CompletableLastStep - Interface in io.servicetalk.concurrent.api.test
Provides the ability to express expectations for the terminal signals (e.g.
CompletableOperator - Interface in io.servicetalk.concurrent.api
An operator contract for a Completable.
completableOrError() - Method in class io.servicetalk.concurrent.api.Publisher
Converts this Publisher to a Completable.
CompletableSource - Interface in io.servicetalk.concurrent
An asynchronous computation that does not emit any data.
CompletableSource.Processor - Interface in io.servicetalk.concurrent
A CompletableSource.Processor represents a processing stage that is both a CompletableSource and a CompletableSource.Subscriber and obeys the contracts of both.
CompletableSource.Subscriber - Interface in io.servicetalk.concurrent
Subscriber of the outcome of a Cancellable.
complete() - Static method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns a TerminalNotification for completion.
completed() - Method in interface io.servicetalk.capacity.limiter.api.CapacityLimiter.Ticket
Callback to indicate that a request was completed successfully.
completed() - Static method in class io.servicetalk.concurrent.api.Completable
Creates a realized completed Completable.
COMPLETED - Static variable in class io.servicetalk.transport.netty.internal.ContextFilterSuccessful
 
composite(List<CapacityLimiter>) - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
A composite CapacityLimiter that is composed of multiple CapacityLimiters.
CompositeBuffer - Interface in io.servicetalk.buffer.api
A virtual Buffer which shows multiple buffers as a single merged buffer.
CompositeCloseable - Interface in io.servicetalk.concurrent.api
A AsyncCloseable and Closeable that allows for adding new AsyncCloseables till it is closed.
COMPRESS - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"compress"
COMPRESSION_ERROR - Static variable in class io.servicetalk.http.api.Http2ErrorCode
computeFlushStrategy(FlushStrategy, boolean) - Method in interface io.servicetalk.transport.netty.internal.NettyConnectionContext.FlushStrategyProvider
Given the current FlushStrategy associated with this NettyConnectionContext, return a new FlushStrategy.
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to compute a new entry for the current context if this map does not already contain this key or is mapped to null.
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
computeIfAbsent(ContextMap.Key<T>, Function<ContextMap.Key<T>, T>) - Method in interface io.servicetalk.context.api.ContextMap
Computes a new entry for this ContextMap if this map does not already contain this key or is mapped to null.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Completable and propagate its terminal signal to the returned Completable.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Publisher
Listens for completion of next Completable after this Publisher terminates successfully.
concat(Completable) - Method in class io.servicetalk.concurrent.api.Single
Returns a Single that emits the result of this Single after next Completable terminates successfully.
concat(Completable...) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to each Completable in nexts in a sequential fashion after termination, and the final terminal signals is propagated to the returned Completable.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Publisher and propagate all emissions to the returned Publisher.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Publisher
Emits items emitted by next Publisher after this Publisher terminates successfully.
concat(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Publisher that first emits the result of this Single and then subscribes and emits all elements from next Publisher.
concat(Publisher<? extends T>, boolean) - Method in class io.servicetalk.concurrent.api.Single
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Completable
Once this Completable is terminated successfully, subscribe to next Single and propagate the result to the returned Single.
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Publisher
Listens and emits the result of next Single after this Publisher terminates successfully.
concat(Single<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
Returns a Publisher that first emits the result of this Single and then subscribes and emits result of next Single.
concatDeferSubscribe(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
This method is like Single.concat(Publisher) subscribe to the next Publisher will be deferred until demand is received (at least 2 items requested).
concatPropagateCancel(Completable) - Method in class io.servicetalk.concurrent.api.Publisher
This method is like Publisher.concat(Completable) except next will be subscribed to and cancelled if this Publisher is cancelled or terminates with PublisherSource.Subscriber.onError(Throwable).
concatPropagateCancel(Publisher<? extends T>) - Method in class io.servicetalk.concurrent.api.Single
This method is like Single.concat(Publisher) except next will be subscribed to and cancelled if this Publisher is cancelled or terminates with SingleSource.Subscriber.onError(Throwable).
ConcurrentSubscription - Class in io.servicetalk.concurrent.internal
This class prevents concurrent invocation of PublisherSource.Subscription methods and preserves the Reactive Streams, 2.7 rule when there is a possibility of concurrency.
ConcurrentSubscription(PublisherSource.Subscription) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentSubscription
New instance.
ConcurrentTerminalSubscriber<T> - Class in io.servicetalk.concurrent.internal
Deprecated.
This internal class will be removed in the future releases without a replacement. If you depend on it, consider copying into your codebase.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Deprecated.
Create a new instance.
ConcurrentTerminalSubscriber(PublisherSource.Subscriber<T>, boolean) - Constructor for class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Deprecated.
Create a new instance.
ConcurrentUtils - Class in io.servicetalk.concurrent.internal
Utilities which can be used for concurrency.
configure(FeatureContext) - Method in class io.servicetalk.data.jackson.jersey.config.ServiceTalkJacksonSerializerAutoDiscoverable
 
configure(FeatureContext) - Method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
 
configure(FeatureContext) - Method in class io.servicetalk.data.protobuf.jersey.config.ServiceTalkProtobufSerializerAutoDiscoverable
 
configure(FeatureContext) - Method in class io.servicetalk.data.protobuf.jersey.ServiceTalkProtobufSerializerFeature
 
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.config.ServiceTalkAutoDiscoverable
 
configure(FeatureContext) - Method in class io.servicetalk.http.router.jersey.ServiceTalkFeature
 
configureForPartition(PartitionAttributes, SingleAddressHttpClientBuilder<U, R>) - Method in interface io.servicetalk.http.api.PartitionHttpClientBuilderConfigurator
Deprecated.
Configures the passed SingleAddressHttpClientBuilder for a given set of PartitionAttributes.
conflict() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
conflict() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
conflict() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CONFLICT response.
CONFLICT - Static variable in class io.servicetalk.http.api.HttpResponseStatus
409 Conflict
connect() - Method in class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
Connects this OutputStream to the returned Publisher such that any data written to this OutputStream is eventually delivered to a PublisherSource.Subscriber of the returned Publisher.
connect() - Method in class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
Connects this PayloadWriter to the returned Publisher such that any data written to this PayloadWriter is eventually delivered to a PublisherSource.Subscriber of the returned Publisher.
connect(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
connect(String) - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
connect(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
connect(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory
Create a new HttpRequestMethod.CONNECT request.
connect(SocketAddress, Object, ReadOnlyTcpClientConfig, boolean, ExecutionContext<?>, BiFunction<Channel, ConnectionObserver, Single<? extends C>>, TransportObserver) - Static method in class io.servicetalk.tcp.netty.internal.TcpConnector
Connects to the passed resolvedRemoteAddress address, resolving the address, if required.
CONNECT - Static variable in class io.servicetalk.http.api.HttpRequestMethod
HTTP CONNECT method.
CONNECT_ERROR - Static variable in class io.servicetalk.http.api.Http2ErrorCode
CONNECT_TIMEOUT - Static variable in class io.servicetalk.transport.api.ServiceTalkSocketOptions
Connect timeout in milliseconds.
ConnectableBufferOutputStream - Class in io.servicetalk.concurrent.api.internal
An OutputStream that can be connected to a sink such that any data written on the OutputStream is eventually emitted to the connected Publisher PublisherSource.Subscriber.
ConnectableBufferOutputStream(BufferAllocator) - Constructor for class io.servicetalk.concurrent.api.internal.ConnectableBufferOutputStream
Creates a new instance.
ConnectablePayloadWriter<T> - Class in io.servicetalk.concurrent.api.internal
A PayloadWriter that can be connected to a sink such that any data written on the PayloadWriter is eventually emitted to the connected Publisher PublisherSource.Subscriber.
ConnectablePayloadWriter() - Constructor for class io.servicetalk.concurrent.api.internal.ConnectablePayloadWriter
 
ConnectAndHttpExecutionStrategy - Class in io.servicetalk.http.api
ConnectAndHttpExecutionStrategy(HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
 
ConnectAndHttpExecutionStrategy(ConnectExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
 
ConnectAndHttpExecutionStrategy(ConnectExecutionStrategy, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
 
ConnectExecutionStrategy - Interface in io.servicetalk.transport.api
An execution strategy for creating or accepting connections.
CONNECTION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"connection"
ConnectionAcceptor - Interface in io.servicetalk.transport.api
Deprecated.
ConnectionAcceptorFactory - Interface in io.servicetalk.transport.api
Deprecated.
connectionClosed() - Method in interface io.servicetalk.transport.api.ConnectionObserver
Callback when the connection is closed.
connectionClosed() - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
 
connectionClosed(Throwable) - Method in interface io.servicetalk.transport.api.ConnectionObserver
Callback when the connection is closed due to an error.
connectionClosed(Throwable) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
 
connectionContext() - Method in interface io.servicetalk.http.api.BlockingHttpConnection
connectionContext() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpConnection
connectionContext() - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
connectionContext() - Method in interface io.servicetalk.http.api.FilterableStreamingHttpConnection
connectionContext() - Method in interface io.servicetalk.http.api.HttpConnection
connectionContext() - Method in class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
 
connectionContext() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
 
ConnectionContext - Interface in io.servicetalk.transport.api
A context for a connection.
connectionEstablished(ConnectionInfo) - Method in interface io.servicetalk.transport.api.ConnectionObserver
Callback when a non-multiplexed connection is established and ready.
connectionEstablished(ConnectionInfo) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
 
ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A factory for creating new connections.
ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> - Interface in io.servicetalk.client.api
A contract to decorate ConnectionFactory instances for the purpose of filtering.
ConnectionInfo - Interface in io.servicetalk.transport.api
Provides information about a connection.
ConnectionInfo.Protocol - Interface in io.servicetalk.transport.api
Provides information about the network protocol.
ConnectionLimitReachedException - Exception in io.servicetalk.client.api
Thrown when the number of connections reached their limit for a given resource (i.e.
ConnectionLimitReachedException(String) - Constructor for exception io.servicetalk.client.api.ConnectionLimitReachedException
Creates a new instance.
ConnectionObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into events associated with a network connection.
ConnectionObserver.DataObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into read and write events related to data flow.
ConnectionObserver.MultiplexedObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into new streams created by a multiplexed connection.
ConnectionObserver.ProxyConnectObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into proxy connect events for establishing a tunnel.
ConnectionObserver.ReadObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into read events.
ConnectionObserver.SecurityHandshakeObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into security handshake events.
ConnectionObserver.StreamObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into stream events.
ConnectionObserver.WriteObserver - Interface in io.servicetalk.transport.api
An observer interface that provides visibility into write events.
ConnectionObserverInitializer - Class in io.servicetalk.transport.netty.internal
A ChannelInitializer that registers a ConnectionObserver for all channels.
ConnectionObserverInitializer(ConnectionObserver, boolean, boolean) - Constructor for class io.servicetalk.transport.netty.internal.ConnectionObserverInitializer
ConnectionObserverInitializer(ConnectionObserver, Function<Channel, ConnectionInfo>, boolean, boolean) - Constructor for class io.servicetalk.transport.netty.internal.ConnectionObserverInitializer
Creates a new instance.
connectionPoolConfig(ConnectionPoolConfig) - Method in class io.servicetalk.loadbalancer.DelegatingLoadBalancerBuilder
 
connectionPoolConfig(ConnectionPoolConfig) - Method in interface io.servicetalk.loadbalancer.LoadBalancerBuilder
Set the ConnectionPoolStrategy to use with this load balancer.
ConnectionPoolConfig - Class in io.servicetalk.loadbalancer
Configuration of the strategy for selecting connections from a pool to the same endpoint.
ConnectionRejectedException - Exception in io.servicetalk.client.api
Thrown when a newly created connection was rejected.
ConnectionRejectedException(String) - Constructor for exception io.servicetalk.client.api.ConnectionRejectedException
Creates a new instance.
ConnectionRejectedException(String, Throwable) - Constructor for exception io.servicetalk.client.api.ConnectionRejectedException
Creates a new instance.
connectionWritabilityChanged(boolean) - Method in interface io.servicetalk.transport.api.ConnectionObserver
Callback when a writable state of the connection changes.
connectionWritabilityChanged(boolean) - Method in class io.servicetalk.transport.netty.internal.NoopTransportObserver.NoopConnectionObserver
 
connectRequestHeadersInitializer() - Method in interface io.servicetalk.http.api.ProxyConfig
An initializer for HttpHeaders related to HTTP/1.1 CONNECT request.
connectRequestHeadersInitializer(Consumer<HttpHeaders>) - Method in class io.servicetalk.http.api.ProxyConfigBuilder
Sets an initializer for HttpHeaders related to HTTP/1.1 CONNECT request.
connectStrategy() - Method in class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
Returns the ConnectExecutionStrategy portion of this strategy.
ConnectTimeoutException - Exception in io.servicetalk.client.api
Throws when a connect operations failed because of a timeout.
ConnectTimeoutException(String, Throwable) - Constructor for exception io.servicetalk.client.api.ConnectTimeoutException
Create a new instance.
consecutive5xx() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The number of consecutive failures before the attempt to suspect the host.
consecutive5xx(int) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the threshold for consecutive failures before a host is ejected.
consolidate() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Consolidate the composed Buffers.
consolidate(int, int) - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Consolidate the composed Buffers.
consolidateCacheSize(int) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
 
consolidateCacheSize(int) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
 
consolidateCacheSize(int) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder
Set the maximum size of the cache that is used to consolidate concurrent lookups for different hostnames.
ConsumableEvent<T> - Interface in io.servicetalk.client.api
A container for an event that requires acknowledgement when the event is consumed via ConsumableEvent.eventConsumed().
consume(ProcessorSignalsConsumer<T>) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Consumes the next item stored in this holder.
consume(ProcessorSignalsConsumer<T>, long, TimeUnit) - Method in interface io.servicetalk.concurrent.api.BlockingProcessorSignalsHolder
Consumes the next item stored in this holder.
consumeItem(T) - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the passed item.
consumeTerminal() - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the termination of the holder.
consumeTerminal(Throwable) - Method in interface io.servicetalk.concurrent.api.ProcessorSignalsConsumer
Consumes the Throwable that terminated the holder.
contains(int) - Method in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass
Determine if code falls into this HttpResponseStatus.StatusClass.
contains(PartitionAttributes.Key<T>) - Method in interface io.servicetalk.client.api.partition.PartitionAttributes
Deprecated.
Determine if there is a value associated with key.
contains(ContextMap.Key<T>, T) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to determine if this context contains an entry matching the passed key and value.
contains(ContextMap.Key<T>, T) - Method in interface io.servicetalk.context.api.ContextMap
Determine if this ContextMap contains an entry matching the passed key and value.
contains(HttpResponseStatus) - Method in enum class io.servicetalk.http.api.HttpResponseStatus.StatusClass
Determine if status code falls into this HttpResponseStatus.StatusClass.
contains(CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
contains(CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name exists, false otherwise.
contains(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
contains(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name and value exists, false otherwise.
containsIgnoreCase(CharSequence, CharSequence) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
containsIgnoreCase(CharSequence, CharSequence) - Method in interface io.servicetalk.http.api.HttpHeaders
Returns true if a header with the name and value exists, false otherwise.
containsKey(ContextMap.Key<?>) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to determine if the current context contains an entry corresponding to the key.
containsKey(ContextMap.Key<?>) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
containsKey(ContextMap.Key<?>) - Method in interface io.servicetalk.context.api.ContextMap
Determine if this ContextMap contains an entry corresponding to the key.
containsKey(String) - Method in class io.servicetalk.log4j2.mdc.utils.ServiceTalkThreadContextMap
 
containsKey(String) - Method in class io.servicetalk.opentracing.log4j2.ServiceTalkTracingThreadContextMap
 
containsValue(Object) - Static method in class io.servicetalk.concurrent.api.AsyncContext
Convenience method to determine if the current context contains an entry with the specified value.
containsValue(Object) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
containsValue(Object) - Method in interface io.servicetalk.context.api.ContextMap
Determine if this ContextMap contains an entry with the specified value.
content() - Method in interface io.servicetalk.buffer.api.BufferHolder
Deprecated.
The buffer contained by this object.
CONTENT_BASE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-base"
CONTENT_DISPOSITION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-disposition"
CONTENT_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-encoding"
CONTENT_LANGUAGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-language"
CONTENT_LENGTH - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-length"
CONTENT_LOCATION - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-location"
CONTENT_MD5 - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-md5"
CONTENT_RANGE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-range"
CONTENT_SECURITY_POLICY - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-security-policy"
CONTENT_TRANSFER_ENCODING - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-transfer-encoding"
CONTENT_TYPE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"content-type"
ContentCodec - Interface in io.servicetalk.encoding.api
Deprecated.
ContentCodecToBufferDecoder - Class in io.servicetalk.encoding.api.internal
Deprecated.
Use BufferDecoder. This type will be removed along with ContentCodec.
ContentCodecToBufferDecoder(ContentCodec) - Constructor for class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder
Deprecated.
Create a new instance.
ContentCodecToBufferEncoder - Class in io.servicetalk.encoding.api.internal
Deprecated.
Use BufferEncoder. This type will be removed along with ContentCodec.
ContentCodecToBufferEncoder(ContentCodec) - Constructor for class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder
Deprecated.
Create a new instance.
ContentCodingHttpRequesterFilter - Class in io.servicetalk.http.api
ContentCodingHttpRequesterFilter(List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpRequesterFilter
Deprecated.
Enable support of the provided encodings for requests and responses.
ContentCodingHttpServiceFilter - Class in io.servicetalk.http.api
ContentCodingHttpServiceFilter(List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpServiceFilter
Deprecated.
Enable support of the provided encodings for this server's responses.
ContentCodingHttpServiceFilter(List<ContentCodec>, List<ContentCodec>) - Constructor for class io.servicetalk.http.api.ContentCodingHttpServiceFilter
Deprecated.
Enable support of the provided encodings for both client requests and server responses.
ContentCodings - Class in io.servicetalk.encoding.netty
contentEncoding() - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Get the BufferEncoder to use for this request.
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.HttpRequest
 
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Set the BufferEncoder to use for this request.
contentEncoding(BufferEncoder) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
ContentEncodingHttpRequesterFilter - Class in io.servicetalk.http.api
A StreamingHttpClientFilter that adds encoding / decoding functionality for requests and responses respectively, as these are specified by the spec Content-Encoding.
ContentEncodingHttpRequesterFilter(BufferDecoderGroup) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter
Create a new instance and specify the supported decompression (advertised in HttpHeaderNames.ACCEPT_ENCODING).
ContentEncodingHttpServiceFilter - Class in io.servicetalk.http.api
A StreamingHttpService that adds encoding / decoding functionality for responses and requests respectively, as these are specified by the spec Content-Encoding.
ContentEncodingHttpServiceFilter(List<BufferEncoder>) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpServiceFilter
Create a new instance and specify the supported compression (matched against HttpHeaderNames.ACCEPT_ENCODING).
ContentEncodingHttpServiceFilter(List<BufferEncoder>, BufferDecoderGroup) - Constructor for class io.servicetalk.http.api.ContentEncodingHttpServiceFilter
Create a new instance and specify the supported decompression (matched against HttpHeaderNames.CONTENT_ENCODING) and compression (matched against HttpHeaderNames.ACCEPT_ENCODING).
contentEquals(CharSequence, CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences
Returns true if the content of both CharSequence's are equals.
contentEqualsIgnoreCase(CharSequence, CharSequence) - Static method in class io.servicetalk.buffer.api.CharSequences
Perform a case-insensitive comparison of two CharSequences.
contentType() - Method in interface io.servicetalk.grpc.api.SerializerDescriptor
Get the suffix to application/grpc which described the Content-Type for the serialization.
context() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Get the current ContextMap.
context() - Method in interface io.servicetalk.context.api.ContextMapHolder
Get the current ContextMap.
context() - Method in interface io.servicetalk.grpc.api.BlockingStreamingGrpcServerResponse
A response context that will be translated into HttpMetaData.context().
context() - Method in interface io.servicetalk.http.api.HttpMetaData
A context associated with this HttpMetaData.
context() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpan
 
context(ContextMap) - Method in interface io.servicetalk.context.api.ContextMapHolder
Set the ContextMap.
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
 
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
 
context(ContextMap) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpMetaData
Sets a context for this HttpMetaData.
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpRequest
 
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpRequestMetaData
 
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpResponse
 
context(ContextMap) - Method in interface io.servicetalk.http.api.HttpResponseMetaData
 
context(ContextMap) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
 
context(ContextMap) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
 
ContextFilterSuccessful - Class in io.servicetalk.transport.netty.internal
Netty pipeline event that represents the successful completion of the ConnectionAcceptor.
ContextMap - Interface in io.servicetalk.context.api
The key-value entry map for different types of the value, defined by the ContextMap.Key.
ContextMap.Key<T> - Class in io.servicetalk.context.api
A key identifies a specific object in a ContextMap.
ContextMapHolder - Interface in io.servicetalk.context.api
Interface for getting and setting a ContextMap.
ContextMapUtils - Class in io.servicetalk.concurrent.internal
Shared utilities for ContextMap.
contextResolverFor(ObjectMapper) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
contextResolverFor(JacksonSerializationProvider) - Static method in class io.servicetalk.data.jackson.jersey.ServiceTalkJacksonSerializerFeature
CONTINUE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"100-continue"
CONTINUE - Static variable in class io.servicetalk.http.api.HttpResponseStatus
100 Continue
continueResponse() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
continueResponse() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
continueResponse() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CONTINUE response.
continueWriting() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
COOKIE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"cookie"
cookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
Get the current value for HttpHeaderNames.COOKIE.
cookieHeaderValue() - Method in class io.servicetalk.http.api.HeaderUtils.CookiesIterator
Get the current value for HttpHeaderNames.COOKIE.
CookieMatcher - Interface in io.servicetalk.http.router.predicate.dsl
Methods for route matching on cookies.
CookiesByNameIterator(CharSequence) - Constructor for class io.servicetalk.http.api.HeaderUtils.CookiesByNameIterator
Create a new instance.
CookiesIterator() - Constructor for class io.servicetalk.http.api.HeaderUtils.CookiesIterator
 
cooldown(Duration) - Method in class io.servicetalk.capacity.limiter.api.AimdCapacityLimiterBuilder
Defines a period during which the additive part of the algorithm doesn't kick-in.
copy() - Method in interface io.servicetalk.buffer.api.Buffer
Returns a copy of this buffer's readable bytes.
copy() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
copy() - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
copy() - Method in interface io.servicetalk.context.api.ContextMap
Create an isolated copy of the current map.
copy() - Method in class io.servicetalk.http.api.StrategyInfluencerChainBuilder
Deprecated.
Creates a deep copy of this StrategyInfluencerChainBuilder.
copy(int, int) - Method in interface io.servicetalk.buffer.api.Buffer
Returns a copy of this buffer's sub-region.
copy(int, int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
CopyByteBufHandlerChannelInitializer - Class in io.servicetalk.transport.netty.internal
Initializer to configure ChannelInboundHandler that will ensure no pooled ByteBufs are passed to the user and so no leaks are produced if the user does not call ReferenceCountUtil.release(Object).
CopyByteBufHandlerChannelInitializer(ByteBufAllocator) - Constructor for class io.servicetalk.transport.netty.internal.CopyByteBufHandlerChannelInitializer
Creates a new instance.
corePool(int, boolean) - Static method in class io.servicetalk.loadbalancer.ConnectionPoolConfig
A connection selection strategy that prioritizes a configurable "core" pool.
create(ConnectionFactory<ResolvedAddress, C>) - Method in interface io.servicetalk.client.api.ConnectionFactoryFilter
Decorates the passed original ConnectionFactory to add the filtering logic.
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.DelegatingConnectionFactoryFilter
 
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.LimitingConnectionFactoryFilter
 
create(ConnectionFactory<ResolvedAddress, C>) - Method in class io.servicetalk.client.api.TransportObserverConnectionFactoryFilter
 
create(Completable) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new CompletableFirstStep.
create(Publisher<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new PublisherFirstStep.
create(Single<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new SingleFirstStep.
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.api.ContentCodingHttpRequesterFilter
Deprecated.
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in interface io.servicetalk.http.api.StreamingHttpClientFilterFactory
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.EnforceSequentialModeRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.HostHeaderHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpRequestFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
 
create(FilterableStreamingHttpClient) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.api.ContentCodingHttpRequesterFilter
Deprecated.
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.api.ContentEncodingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in interface io.servicetalk.http.api.StreamingHttpConnectionFilterFactory
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.EnforceSequentialModeRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.HostHeaderHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.IdleTimeoutConnectionFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.JavaNetSoTimeoutHttpConnectionFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RedirectingHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.http.utils.TimeoutHttpRequesterFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpRequestFilter
 
create(FilterableStreamingHttpConnection) - Method in class io.servicetalk.opentracing.http.TracingHttpRequesterFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.grpc.api.GrpcExceptionMapperServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.api.ContentCodingHttpServiceFilter
Deprecated.
 
create(StreamingHttpService) - Method in class io.servicetalk.http.api.ContentEncodingHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.api.HttpExceptionMapperServiceFilter
 
create(StreamingHttpService) - Method in interface io.servicetalk.http.api.StreamingHttpServiceFilterFactory
create(StreamingHttpService) - Method in class io.servicetalk.http.netty.HttpLifecycleObserverServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.auth.BasicAuthHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.PayloadSizeLimitingHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.RequestTargetDecoderHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.RequestTargetEncoderHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.http.utils.TimeoutHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryHttpServerFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.opentracing.http.TracingHttpServiceFilter
 
create(StreamingHttpService) - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter
 
create(ConnectionAcceptor) - Method in interface io.servicetalk.transport.api.ConnectionAcceptorFactory
Deprecated.
Create a ConnectionAcceptor using the provided ConnectionAcceptor.
create(Service) - Method in interface io.servicetalk.grpc.api.GrpcServiceFilterFactory
Deprecated.
created() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
created() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
created() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.CREATED response.
CREATED - Static variable in class io.servicetalk.http.api.HttpResponseStatus
201 Created
createForSource(CompletableSource) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new CompletableFirstStep.
createForSource(PublisherSource<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new PublisherFirstStep.
createForSource(SingleSource<T>) - Static method in class io.servicetalk.concurrent.api.test.StepVerifiers
Creates a new SingleFirstStep.
createIoExecutor() - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor() - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the default number of ioThreads.
createIoExecutor(int) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor.
createIoExecutor(int) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(int, IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor.
createIoExecutor(int, IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(int, String) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor.
createIoExecutor(int, String) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the specified number of ioThreads.
createIoExecutor(IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor(IoThreadFactory<T>) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the default number of ioThreads.
createIoExecutor(String) - Static method in class io.servicetalk.transport.netty.internal.NettyIoExecutors
Create a new NettyIoExecutor with the default number of ioThreads.
createIoExecutor(String) - Static method in class io.servicetalk.transport.netty.NettyIoExecutors
Creates a new IoExecutor with the default number of ioThreads.
cumulationReset() - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Resets cumulation.
currentStrategy() - Method in class io.servicetalk.transport.netty.internal.FlushStrategyHolder
Returns the current value of the enclosed FlushStrategy.
currentThreadIsIoThread() - Static method in interface io.servicetalk.transport.api.IoThreadFactory.IoThread
Returns true if the current thread is an IoThreadFactory.IoThread otherwise {code false}.
currentTime(TimeUnit) - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
 
currentTime(TimeUnit) - Method in interface io.servicetalk.concurrent.Executor
 
currentTime(TimeUnit) - Method in interface io.servicetalk.concurrent.TimeSource
Returns the internal clock time in the specified unit.
customStrategyBuilder() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies
A GrpcExecutionStrategy that disables all offloads.
customStrategyBuilder() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
A Builder for creating custom HttpExecutionStrategy.

D

DATA_LOSS - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode
Data corruption.
datagramChannel(EventLoopGroup) - Static method in class io.servicetalk.transport.netty.internal.BuilderUtils
Returns the correct Class to use with the given EventLoopGroup.
DATE - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"date"
DEADLINE_EXCEEDED - Enum constant in enum class io.servicetalk.grpc.api.GrpcStatusCode
Deadline expired.
DeadlineUtils - Class in io.servicetalk.grpc.internal
Constants and utilities related to gRPC deadlines.
DEBUG - Enum constant in enum class io.servicetalk.logging.api.LogLevel
DEBUG log level.
decode(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Decode the from one ByteBuf to an other.
decode(Buffer, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec
Deprecated.
Take a Buffer and decode its contents resulting in a Buffer with the decoded content.
decode(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec
Deprecated.
Take a Publisher of Buffer and encode its contents resulting in a Publisher of Buffer with the decoded contents.
decodeLast(ChannelHandlerContext, ByteBuf) - Method in class io.servicetalk.transport.netty.internal.ByteToMessageDecoder
Is called one last time when the ChannelHandlerContext goes in-active.
decoder() - Method in interface io.servicetalk.encoding.api.BufferDecoder
Get the Deserializer to use for aggregated content.
decoder() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder
Deprecated.
 
decoders() - Method in interface io.servicetalk.encoding.api.BufferDecoderGroup
Get the supported BufferDecoder for this group.
decoders() - Method in class io.servicetalk.encoding.api.EmptyBufferDecoderGroup
 
DEFAULT_ALLOCATOR - Static variable in class io.servicetalk.buffer.netty.BufferAllocators
Default BufferAllocator whose Buffers are typically backed by Netty buffers.
DEFAULT_BREAKER_REJECTION - Static variable in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter
 
DEFAULT_BREAKER_REJECTION_PREDICATE - Static variable in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter
Default rejection observer for dropped requests from an external sourced due to service unavailability.
DEFAULT_CAPACITY_REJECTION - Static variable in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpServiceFilter
 
DEFAULT_CAPACITY_REJECTION_PREDICATE - Static variable in class io.servicetalk.traffic.resilience.http.ClientPeerRejectionPolicy
Default rejection observer for dropped requests from an external sourced.
DEFAULT_HEADER_FILTER - Static variable in class io.servicetalk.http.api.HeaderUtils
 
DEFAULT_NAME_PREFIX - Static variable in class io.servicetalk.concurrent.api.DefaultThreadFactory
The default prefix used for new thread names.
DEFAULT_PEER_REJECTION_POLICY - Static variable in class io.servicetalk.traffic.resilience.http.ClientPeerRejectionPolicy
Default rejection policy for peer responses.
DEFAULT_REJECTION_POLICY - Static variable in class io.servicetalk.traffic.resilience.http.ServiceRejectionPolicy
Default response rejection policy.
DEFAULT_RO_ALLOCATOR - Static variable in class io.servicetalk.buffer.api.ReadOnlyBufferAllocators
Default BufferAllocator that creates Buffer instances which cannot be modified and are read only.
DefaultContextMap - Class in io.servicetalk.concurrent.internal
Default implementation of ContextMap.
DefaultContextMap() - Constructor for class io.servicetalk.concurrent.internal.DefaultContextMap
Creates a new instance.
defaultContextSupplier - Variable in class io.servicetalk.transport.netty.internal.ExecutionContextBuilder
 
DefaultDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty
Deprecated.
this class will be made package-private in the future, rely on the DnsServiceDiscovererBuilder instead.
DefaultDnsServiceDiscovererBuilder() - Constructor for class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
DefaultExecutionContext<ES extends ExecutionStrategy> - Class in io.servicetalk.transport.api
A default implementation of ExecutionContext.
DefaultExecutionContext(BufferAllocator, IoExecutor, Executor, ES) - Constructor for class io.servicetalk.transport.api.DefaultExecutionContext
Create a new instance.
DefaultFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpConnection, ReservableRequestConcurrencyController) - Constructor for class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
DefaultFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpConnection, ReservableRequestConcurrencyController, ScoreSupplier) - Constructor for class io.servicetalk.http.api.HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection
Create a new instance.
defaultFlushStrategy() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
defaultFlushStrategy() - Static method in class io.servicetalk.transport.netty.internal.FlushStrategies
Creates a default FlushStrategy.
defaultFlushStrategy() - Method in interface io.servicetalk.transport.netty.internal.NettyConnectionContext
Returns the FlushStrategy used by default for this NettyConnectionContext.
defaultFlushStrategy() - Method in class io.servicetalk.transport.netty.internal.NettyPipelinedConnection
 
DefaultGroupKey<Address> - Class in io.servicetalk.client.api
A default implementation of GroupKey.
DefaultGroupKey(Address, ExecutionContext<?>) - Constructor for class io.servicetalk.client.api.DefaultGroupKey
Create a new instance.
DefaultGrpcClientMetadata - Class in io.servicetalk.grpc.api
Default implementation for DefaultGrpcClientMetadata.
DefaultGrpcClientMetadata() - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Creates a new instance with default characteristics and empty request/response contexts.
DefaultGrpcClientMetadata(BufferEncoder) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Creates a new instance.
DefaultGrpcClientMetadata(BufferEncoder, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Creates a new instance.
DefaultGrpcClientMetadata(DefaultGrpcClientMetadata) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Create a new instance, by copying an existing instance.
DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Create a new instance.
DefaultGrpcClientMetadata(GrpcExecutionStrategy, BufferEncoder, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Create a new instance.
DefaultGrpcClientMetadata(String) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Deprecated.
DefaultGrpcClientMetadata(String, ContentCodec) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, GrpcClientMetadata) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, ContentCodec) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, GrpcExecutionStrategy, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
DefaultGrpcClientMetadata(String, Supplier<ContextMap>, Supplier<ContextMap>, GrpcExecutionStrategy, ContentCodec, Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Deprecated.
DefaultGrpcClientMetadata(Duration) - Constructor for class io.servicetalk.grpc.api.DefaultGrpcClientMetadata
Create a new instance.
DefaultHealthService - Class in io.servicetalk.grpc.health
Implementation of Health.HealthService which targets gRPC health checking that provides accessors to set/clear status for arbitrary services.
DefaultHealthService() - Constructor for class io.servicetalk.grpc.health.DefaultHealthService
Create a new instance.
DefaultHealthService(Predicate<String>) - Constructor for class io.servicetalk.grpc.health.DefaultHealthService
Create a new instance.
DefaultHttpCookiePair - Class in io.servicetalk.http.api
Default implementation of HttpCookiePair.
DefaultHttpCookiePair(CharSequence, CharSequence) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair
Create a new instance.
DefaultHttpCookiePair(CharSequence, CharSequence, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpCookiePair
Create a new instance.
DefaultHttpExecutionContext - Class in io.servicetalk.http.api
Default implementation of HttpExecutionContext.
DefaultHttpExecutionContext(BufferAllocator, IoExecutor, Executor, HttpExecutionStrategy) - Constructor for class io.servicetalk.http.api.DefaultHttpExecutionContext
Create a new instance.
DefaultHttpHeadersFactory - Class in io.servicetalk.http.api
Default implementation of HttpHeadersFactory.
DefaultHttpHeadersFactory(boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory
Create an instance of the factory with the default array size hint.
DefaultHttpHeadersFactory(boolean, boolean, boolean, int, int) - Constructor for class io.servicetalk.http.api.DefaultHttpHeadersFactory
Create an instance of the factory.
DefaultHttpLoadBalancerFactory<ResolvedAddress> - Class in io.servicetalk.http.api
Default implementation of HttpLoadBalancerFactory.
DefaultHttpLoadBalancerFactory<ResolvedAddress> - Class in io.servicetalk.http.netty
Deprecated.
DefaultHttpLoadBalancerFactory(LoadBalancerFactory<ResolvedAddress, FilterableStreamingHttpLoadBalancedConnection>) - Constructor for class io.servicetalk.http.api.DefaultHttpLoadBalancerFactory
Creates a new instance with execution strategy adapted from the underlying factory.
DefaultHttpLoadBalancerFactory.Builder<ResolvedAddress> - Class in io.servicetalk.http.netty
Deprecated.
A builder for creating instances of DefaultHttpLoadBalancerFactory.
DefaultHttpLoadBalancerProvider - Class in io.servicetalk.loadbalancer.experimental
A client builder provider that supports enabling the new `DefaultLoadBalancer` in applications via property flags.
DefaultHttpLoadBalancerProvider() - Constructor for class io.servicetalk.loadbalancer.experimental.DefaultHttpLoadBalancerProvider
 
defaultHttpPort(int) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
defaultHttpPort(int) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder
Configures the default port for the HTTP scheme if not explicitly provided as part of the HttpRequestMetaData.requestTarget().
DefaultHttpSetCookie - Class in io.servicetalk.http.api
Default implementation of HttpSetCookie.
DefaultHttpSetCookie(CharSequence, CharSequence) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Create a new not wrapped, not secure and not HTTP-only HttpSetCookie instance, with no path, domain, expire date and maximum age.
DefaultHttpSetCookie(CharSequence, CharSequence, boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Create a new HttpSetCookie instance, with no path, domain, expire date and maximum age.
DefaultHttpSetCookie(CharSequence, CharSequence, CharSequence, CharSequence, CharSequence, Long, HttpSetCookie.SameSite, boolean, boolean, boolean) - Constructor for class io.servicetalk.http.api.DefaultHttpSetCookie
Creates a new HttpSetCookie instance.
defaultHttpsPort(int) - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
 
defaultHttpsPort(int) - Method in interface io.servicetalk.http.api.MultiAddressHttpClientBuilder
Configures the default port for the HTTPS scheme if not explicitly provided as part of the HttpRequestMetaData.requestTarget().
defaultInitializer() - Static method in interface io.servicetalk.transport.netty.internal.ChannelInitializer
DefaultInMemorySpanContext - Class in io.servicetalk.opentracing.inmemory
SpanContext object used by the DefaultInMemoryTracer.
DefaultInMemorySpanContext(String, String, String, Boolean) - Constructor for class io.servicetalk.opentracing.inmemory.DefaultInMemorySpanContext
Constructs an instance.
DefaultInMemoryTracer - Class in io.servicetalk.opentracing.inmemory
Tracer implementation that propagates spans in-memory and emits events to listeners.
DefaultInMemoryTracer.Builder - Class in io.servicetalk.opentracing.inmemory
Builders for DefaultInMemoryTracer.
DefaultLoadBalancerClient - Class in io.servicetalk.examples.http.defaultloadbalancer
 
DefaultLoadBalancerClient() - Constructor for class io.servicetalk.examples.http.defaultloadbalancer.DefaultLoadBalancerClient
 
DefaultNettyConnection<Read,Write> - Class in io.servicetalk.transport.netty.internal
Implementation of NettyConnection backed by a netty Channel.
DefaultNettyConnection.CancelWriteUserEvent - Class in io.servicetalk.transport.netty.internal
Netty UserEvent to signal cancellation of the write stream.
DefaultNettyConnection.ContinueUserEvent - Class in io.servicetalk.transport.netty.internal
Netty UserEvent to signal continuation.
DefaultPartitionAttributesBuilder - Class in io.servicetalk.client.api.internal.partition
Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
DefaultPartitionAttributesBuilder(int) - Constructor for class io.servicetalk.client.api.internal.partition.DefaultPartitionAttributesBuilder
Deprecated.
Create a new instance.
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api.internal
Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
DefaultPartitionedClientGroup(Function<PartitionAttributes, Client>, Function<PartitionAttributes, Client>, DefaultPartitionedClientGroup.PartitionedClientFactory<U, R, Client>, PartitionMapFactory, Publisher<PartitionedServiceDiscovererEvent<R>>, int) - Constructor for class io.servicetalk.client.api.internal.DefaultPartitionedClientGroup
Deprecated.
Creates a new instance.
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> - Interface in io.servicetalk.client.api.internal
Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
DefaultRouteExecutionStrategyFactory<ES extends ExecutionStrategy> - Class in io.servicetalk.router.utils.internal
Implementation of RouteExecutionStrategyFactory that always throws IllegalArgumentException.
DefaultSerializer - Class in io.servicetalk.serialization.api
Deprecated.
Use implementations of following types:
DefaultSerializer(SerializationProvider) - Constructor for class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
New instance.
DefaultServiceDiscovererEvent<T> - Class in io.servicetalk.client.api
Default implementation of ServiceDiscovererEvent.
DefaultServiceDiscovererEvent(T, ServiceDiscovererEvent.Status) - Constructor for class io.servicetalk.client.api.DefaultServiceDiscovererEvent
Create a new instance.
DefaultServiceTalkThreadContextMap - Class in io.servicetalk.log4j2.mdc
Empty subclass to differentiate uses of MDC.
DefaultServiceTalkThreadContextMap() - Constructor for class io.servicetalk.log4j2.mdc.DefaultServiceTalkThreadContextMap
 
defaultStrategy() - Static method in class io.servicetalk.grpc.api.GrpcExecutionStrategies
A special default GrpcExecutionStrategy that offloads all actions unless merged with another strategy that requires less offloading.
defaultStrategy() - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
A special default HttpExecutionStrategy that provides safe default offloading of actions; the offloading used is unspecified and dependent upon the usage situation.
defaultStrategyFactory() - Static method in class io.servicetalk.router.utils.internal.DefaultRouteExecutionStrategyFactory
DefaultStreamingHttpRequestResponseFactory - Class in io.servicetalk.http.api
DefaultStreamingHttpRequestResponseFactory(BufferAllocator, HttpHeadersFactory, HttpProtocolVersion) - Constructor for class io.servicetalk.http.api.DefaultStreamingHttpRequestResponseFactory
Create a new instance.
defaultStreamingInfluencer() - Static method in interface io.servicetalk.http.api.HttpExecutionStrategyInfluencer
Deprecated.
This method is not useful anymore and will be removed in future releases.
DefaultTestCerts - Class in io.servicetalk.test.resources
Provides a set of certificates useful for tests that require SSL.
DefaultThreadFactory - Class in io.servicetalk.concurrent.api
A ThreadFactory implementation.
DefaultThreadFactory() - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates daemon threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(boolean) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates threads with Thread.NORM_PRIORITY priority.
DefaultThreadFactory(boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance.
DefaultThreadFactory(int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance that creates daemon threads.
DefaultThreadFactory(String) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
Create a new instance.
DefaultThreadFactory(String, boolean, int) - Constructor for class io.servicetalk.concurrent.api.DefaultThreadFactory
New instance.
defaultTimeout(Duration) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
defaultTimeout(Duration) - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder
 
defaultTimeout(Duration) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder
Set default timeout during which gRPC calls are expected to complete.
defaultTimeout(Duration) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder
Set a default timeout during which gRPC calls are expected to complete.
defaultTimeout(Duration, boolean) - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
defaultTimeout(Duration, boolean) - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder
 
defaultTimeout(Duration, boolean) - Method in interface io.servicetalk.grpc.api.GrpcClientBuilder
Set default timeout during which gRPC calls are expected to complete.
defaultTimeout(Duration, boolean) - Method in interface io.servicetalk.grpc.api.GrpcServerBuilder
Set a default timeout during which gRPC calls are expected to complete.
DefaultUserDataLoggerConfig - Class in io.servicetalk.logging.slf4j.internal
Default implementation of LoggerConfig.
DefaultUserDataLoggerConfig(String, LogLevel, BooleanSupplier) - Constructor for class io.servicetalk.logging.slf4j.internal.DefaultUserDataLoggerConfig
Create a new instance.
defer(Supplier<? extends Completable>) - Static method in class io.servicetalk.concurrent.api.Completable
Defer creation of a Completable till it is subscribed to.
defer(Supplier<? extends Publisher<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Publisher
Defers creation of a Publisher till it is subscribed.
defer(Supplier<? extends Single<? extends T>>) - Static method in class io.servicetalk.concurrent.api.Single
Defer creation of a Single till it is subscribed to.
deferredOnComplete() - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Deprecated.
deferredOnError(Throwable) - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Deprecated.
DeferSslHandler - Class in io.servicetalk.transport.netty.internal
A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler.
deflate() - Static method in class io.servicetalk.encoding.netty.ContentCodings
Deprecated.
Returns a DEFLATE based ZipContentCodecBuilder that allows building a customizable ContentCodec.
deflate() - Static method in class io.servicetalk.encoding.netty.NettyCompression
Returns a DEFLATE based ZipCompressionBuilder.
DEFLATE - Static variable in class io.servicetalk.http.api.HttpHeaderValues
"deflate"
deflateDefault() - Static method in class io.servicetalk.encoding.netty.ContentCodings
Deprecated.
Returns the default DEFLATE based ContentCodec.
deflateDefault() - Static method in class io.servicetalk.encoding.netty.NettyBufferEncoders
Get a default BufferEncoderDecoder for deflate encoding.
deflateDefault() - Static method in class io.servicetalk.encoding.netty.NettyCompression
Returns the default DEFLATE based SerializerDeserializer.
deflateDefaultStreaming() - Static method in class io.servicetalk.encoding.netty.NettyCompression
Returns the default DEFLATE based StreamingSerializerDeserializer.
delay() - Method in interface io.servicetalk.client.api.DelayedRetryException
A constant delay to apply.
delay() - Method in interface io.servicetalk.http.netty.RetryingHttpRequesterFilter.DelayedRetry
Deprecated.
A constant delay to apply.
delay() - Method in exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
 
delayedCancellable(Cancellable) - Method in class io.servicetalk.concurrent.internal.DelayedCancellable
Set the delayed Cancellable.
DelayedCancellable - Class in io.servicetalk.concurrent.internal
A Cancellable which serves as a placeholder until the "real" Cancellable is available.
DelayedCancellable() - Constructor for class io.servicetalk.concurrent.internal.DelayedCancellable
 
DelayedRetryException - Interface in io.servicetalk.client.api
An interface that enhances any exception to provide a constant delay to be applied when it needs to be retried.
DelayedRetryRequestDroppedException - Exception in io.servicetalk.traffic.resilience.http
A RequestDroppedException to indicate that a request was dropped by a server due to capacity constraints and requires a client to delay its retry.
DelayedRetryRequestDroppedException(Duration) - Constructor for exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
Creates a new instance.
DelayedRetryRequestDroppedException(Duration, String) - Constructor for exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
Creates a new instance.
DelayedRetryRequestDroppedException(Duration, String, Throwable) - Constructor for exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
Creates a new instance.
DelayedRetryRequestDroppedException(Duration, String, Throwable, boolean, boolean) - Constructor for exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
Creates a new instance.
DelayedRetryRequestDroppedException(Duration, Throwable) - Constructor for exception io.servicetalk.traffic.resilience.http.DelayedRetryRequestDroppedException
Creates a new instance.
delayedSubscription(PublisherSource.Subscription) - Method in class io.servicetalk.concurrent.internal.DelayedSubscription
DelayedSubscription - Class in io.servicetalk.concurrent.internal
A PublisherSource.Subscription which serves as a placeholder until the "real" PublisherSource.Subscription is available.
DelayedSubscription() - Constructor for class io.servicetalk.concurrent.internal.DelayedSubscription
 
delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactory
Returns the ConnectionFactory delegate.
delegate() - Method in class io.servicetalk.client.api.DelegatingConnectionFactoryFilter
Returns the ConnectionFactoryFilter delegate.
delegate() - Method in class io.servicetalk.client.api.DelegatingServiceDiscoverer
Returns the ServiceDiscoverer delegate.
delegate() - Method in class io.servicetalk.concurrent.api.DelegatingExecutor
Returns the delegate Executor used.
delegate() - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
Returns the DnsServiceDiscovererBuilder delegate.
delegate() - Method in class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
Returns the GrpcClientBuilder delegate.
delegate() - Method in class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder
Returns the GrpcServerBuilder delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpConnectionContext
Get the HttpConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpExecutionContext
Get the HttpExecutionContext that this class delegates to.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
Returns the HttpServerBuilder delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingHttpServiceContext
Returns the delegate HttpServiceContext.
delegate() - Method in class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
Returns the MultiAddressHttpClientBuilder delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
Returns the PartitionedHttpClientBuilder delegate.
delegate() - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
Returns the SingleAddressHttpClientBuilder delegate.
delegate() - Method in class io.servicetalk.http.api.ReservedStreamingHttpConnectionFilter
Get the FilterableReservedStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpClientFilter
Get the FilterableStreamingHttpClient this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpConnectionFilter
Get the FilterableStreamingHttpConnection this method delegates to.
delegate() - Method in class io.servicetalk.http.api.StreamingHttpServiceFilter
Returns StreamingHttpService to which all calls are delegated.
delegate() - Method in class io.servicetalk.loadbalancer.DelegatingLoadBalancerBuilder
Returns the DelegatingLoadBalancerBuilder delegate.
delegate() - Method in class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionAcceptor
The ConnectionAcceptor to which all calls are delegated to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingConnectionContext
Get the ConnectionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingExecutionContext
Get the ExecutionContext that this class delegates to.
delegate() - Method in class io.servicetalk.transport.api.DelegatingSslConfig
Get the DelegatingSslConfig to delegate to.
delegate() - Method in class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
Returns the delegate FlushStrategy used.
DelegatingClientSslConfig - Class in io.servicetalk.transport.api
Wrap a ClientSslConfig and delegate all methods to it.
DelegatingClientSslConfig(ClientSslConfig) - Constructor for class io.servicetalk.transport.api.DelegatingClientSslConfig
Create a new instance.
DelegatingConnectionAcceptor - Class in io.servicetalk.transport.api
An implementation of ConnectionAcceptor that delegates all methods to another ConnectionAcceptor.
DelegatingConnectionAcceptor(ConnectionAcceptor) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionAcceptor
New instance.
DelegatingConnectionContext - Class in io.servicetalk.transport.api
A ConnectionContext implementation that delegates all calls to a provided ConnectionContext.
DelegatingConnectionContext(ConnectionContext) - Constructor for class io.servicetalk.transport.api.DelegatingConnectionContext
New instance.
DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api
A ConnectionFactory that delegates all methods to another ConnectionFactory.
DelegatingConnectionFactory(ConnectionFactory<ResolvedAddress, C>) - Constructor for class io.servicetalk.client.api.DelegatingConnectionFactory
Create a new instance.
DelegatingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> - Class in io.servicetalk.client.api
A ConnectionFactoryFilter that delegates all methods to another ConnectionFactoryFilter.
DelegatingConnectionFactoryFilter(ConnectionFactoryFilter<ResolvedAddress, C>) - Constructor for class io.servicetalk.client.api.DelegatingConnectionFactoryFilter
Create a new instance.
DelegatingDnsServiceDiscovererBuilder - Class in io.servicetalk.dns.discovery.netty
A DnsServiceDiscovererBuilder that delegates all methods to another DnsServiceDiscovererBuilder.
DelegatingDnsServiceDiscovererBuilder(DnsServiceDiscovererBuilder) - Constructor for class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
Creates a new builder which delegates to the provided DnsServiceDiscovererBuilder.
DelegatingExecutionContext<ES extends ExecutionStrategy> - Class in io.servicetalk.transport.api
An ExecutionContext implementation that delegates all calls to a provided ExecutionContext.
DelegatingExecutionContext(ExecutionContext<? extends ES>) - Constructor for class io.servicetalk.transport.api.DelegatingExecutionContext
New instance.
DelegatingExecutor - Class in io.servicetalk.concurrent.api
An Executor that simply delegates all calls to another Executor.
DelegatingExecutor(Executor) - Constructor for class io.servicetalk.concurrent.api.DelegatingExecutor
New instance.
DelegatingFilterableStreamingHttpLoadBalancedConnection - Class in io.servicetalk.http.api
Implementation of FilterableStreamingHttpLoadBalancedConnection that delegates all methods.
DelegatingFilterableStreamingHttpLoadBalancedConnection(FilterableStreamingHttpLoadBalancedConnection) - Constructor for class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
Create a new instance.
DelegatingFlushStrategy - Class in io.servicetalk.transport.netty.internal
A FlushStrategy implementation that delegates all calls to another FlushStrategy.
DelegatingFlushStrategy(FlushStrategy) - Constructor for class io.servicetalk.transport.netty.internal.DelegatingFlushStrategy
Create a new instance.
DelegatingGrpcClientBuilder<U,R> - Class in io.servicetalk.grpc.api
A GrpcClientBuilder that delegates all methods to another GrpcClientBuilder.
DelegatingGrpcClientBuilder(GrpcClientBuilder<U, R>) - Constructor for class io.servicetalk.grpc.api.DelegatingGrpcClientBuilder
 
DelegatingGrpcServerBuilder - Class in io.servicetalk.grpc.api
A GrpcServerBuilder that delegates all methods to another GrpcServerBuilder.
DelegatingGrpcServerBuilder(GrpcServerBuilder) - Constructor for class io.servicetalk.grpc.api.DelegatingGrpcServerBuilder
 
DelegatingHttpConnectionContext - Class in io.servicetalk.http.api
HttpConnectionContext implementation that delegates all calls to a provided HttpConnectionContext.
DelegatingHttpConnectionContext(HttpConnectionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpConnectionContext
New instance.
DelegatingHttpExecutionContext - Class in io.servicetalk.http.api
An implementation of HttpExecutionContext that delegates all method calls to another HttpExecutionContext.
DelegatingHttpExecutionContext(HttpExecutionContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpExecutionContext
Creates a new instance.
DelegatingHttpServerBuilder - Class in io.servicetalk.http.api
A HttpServerBuilder that delegates all methods to another HttpServerBuilder.
DelegatingHttpServerBuilder(HttpServerBuilder) - Constructor for class io.servicetalk.http.api.DelegatingHttpServerBuilder
Create a new instance.
DelegatingHttpServiceContext - Class in io.servicetalk.http.api
An implementation of HttpServiceContext that delegates all calls to a provided HttpServiceContext.
DelegatingHttpServiceContext(HttpServiceContext) - Constructor for class io.servicetalk.http.api.DelegatingHttpServiceContext
New instance.
DelegatingLoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection> - Class in io.servicetalk.loadbalancer
A LoadBalancerBuilder that delegates all methods to another LoadBalancerBuilder.
DelegatingLoadBalancerBuilder(LoadBalancerBuilder<ResolvedAddress, C>) - Constructor for class io.servicetalk.loadbalancer.DelegatingLoadBalancerBuilder
Creates a new builder which delegates to the provided LoadBalancerBuilder.
DelegatingMultiAddressHttpClientBuilder<U,R> - Class in io.servicetalk.http.api
A MultiAddressHttpClientBuilder that delegates all methods to another MultiAddressHttpClientBuilder.
DelegatingMultiAddressHttpClientBuilder(MultiAddressHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingMultiAddressHttpClientBuilder
Create a new instance.
DelegatingPartitionedHttpClientBuilder<U,R> - Class in io.servicetalk.http.api
A PartitionedHttpClientBuilder that delegates all methods to another PartitionedHttpClientBuilder.
DelegatingPartitionedHttpClientBuilder(PartitionedHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder
Create a new instance.
DelegatingRoundRobinLoadBalancerBuilder<ResolvedAddress,C extends LoadBalancedConnection> - Class in io.servicetalk.loadbalancer
A RoundRobinLoadBalancerBuilder that delegates all methods to another RoundRobinLoadBalancerBuilder.
DelegatingRoundRobinLoadBalancerBuilder(RoundRobinLoadBalancerBuilder<ResolvedAddress, C>) - Constructor for class io.servicetalk.loadbalancer.DelegatingRoundRobinLoadBalancerBuilder
Creates a new builder which delegates to the provided RoundRobinLoadBalancerBuilder.
DelegatingServerSslConfig - Class in io.servicetalk.transport.api
Wrap a ServerSslConfig and delegate all methods to it.
DelegatingServerSslConfig(ServerSslConfig) - Constructor for class io.servicetalk.transport.api.DelegatingServerSslConfig
Create a new instance.
DelegatingServiceDiscoverer<UnresolvedAddress,ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> - Class in io.servicetalk.client.api
A ServiceDiscoverer that delegates all methods to another ServiceDiscoverer.
DelegatingServiceDiscoverer(ServiceDiscoverer<UnresolvedAddress, ResolvedAddress, E>) - Constructor for class io.servicetalk.client.api.DelegatingServiceDiscoverer
Creates a new instance.
DelegatingSingleAddressHttpClientBuilder<U,R> - Class in io.servicetalk.http.api
A SingleAddressHttpClientBuilder that delegates all methods to another SingleAddressHttpClientBuilder.
DelegatingSingleAddressHttpClientBuilder(SingleAddressHttpClientBuilder<U, R>) - Constructor for class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
Create a new instance.
DelegatingSslConfig<T extends SslConfig> - Class in io.servicetalk.transport.api
Wrap a SslConfig and delegate all methods to it.
DelegatingSslConfig(T) - Constructor for class io.servicetalk.transport.api.DelegatingSslConfig
Create a new instance.
delete(String) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
delete(String) - Method in class io.servicetalk.http.api.DelegatingFilterableStreamingHttpLoadBalancedConnection
 
delete(String) - Method in interface io.servicetalk.http.api.HttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
delete(String) - Method in interface io.servicetalk.http.api.StreamingHttpRequestFactory
Create a new HttpRequestMethod.DELETE request.
DELETE - Static variable in class io.servicetalk.http.api.HttpRequestMethod
HTTP DELETE method.
deliverAccumulation(Consumer<T>) - Method in interface io.servicetalk.concurrent.api.ReplayAccumulator
Called to deliver the signals from ReplayAccumulator.accumulate(Object) to new consumer.
deliverCompleteFromSource(CompletableSource.Subscriber) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal complete to a CompletableSource.Subscriber that has not yet had CompletableSource.Subscriber.onSubscribe(Cancellable) called.
deliverCompleteFromSource(PublisherSource.Subscriber<T>) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal complete to a PublisherSource.Subscriber that has not yet had PublisherSource.Subscriber.onSubscribe(PublisherSource.Subscription) called.
deliverDeferredTerminal() - Method in class io.servicetalk.concurrent.internal.ConcurrentTerminalSubscriber
Deprecated.
deliverErrorFromSource(CompletableSource.Subscriber, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal error to a CompletableSource.Subscriber that has not yet had CompletableSource.Subscriber.onSubscribe(Cancellable) called.
deliverErrorFromSource(PublisherSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
deliverErrorFromSource(SingleSource.Subscriber<T>, Throwable) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Deliver a terminal error to a SingleSource.Subscriber that has not yet had SingleSource.Subscriber.onSubscribe(Cancellable) called.
deliverSuccessFromSource(SingleSource.Subscriber<T>, T) - Static method in class io.servicetalk.concurrent.internal.SubscriberUtils
Invokes SingleSource.Subscriber.onSuccess(Object) ignoring an occurred exception if any.
description() - Method in class io.servicetalk.grpc.api.GrpcStatus
Returns additional descriptions, can be null.
deserialize(Buffer) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
Deprecated.
Use StreamingDeserializer that understands your protocol's framing.
deserialize(Buffer, BufferAllocator) - Method in interface io.servicetalk.serializer.api.Deserializer
Deserialize the contents from the Buffer parameter.
deserialize(Buffer, BufferAllocator) - Method in class io.servicetalk.serializer.utils.StringSerializer
 
deserialize(Buffer, BufferAllocator) - Method in class io.servicetalk.serializer.utils.ByteArraySerializer
 
deserialize(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.serializer.api.StreamingDeserializer
Deserialize a Publisher of Buffer into a Publisher of StreamingDeserializer.
deserialize(Publisher<Buffer>, BufferAllocator) - Method in class io.servicetalk.serializer.utils.FixedLengthStreamingSerializer
 
deserialize(Publisher<Buffer>, BufferAllocator) - Method in class io.servicetalk.serializer.utils.VarIntLengthStreamingSerializer
 
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(Publisher<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserialize(Publisher<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(Publisher<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserialize(BlockingIterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(BlockingIterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(BlockingIterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserialize(HttpHeaders, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deprecated.
Deserialize a single Object into a HttpDeserializer.
deserialize(HttpHeaders, BufferAllocator, Buffer) - Method in interface io.servicetalk.http.api.HttpDeserializer2
Deserialize a single Object into a HttpDeserializer2.
deserialize(HttpHeaders, Publisher<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deprecated.
Deserialize a Publisher of Objects into a Publisher of type HttpDeserializer.
deserialize(HttpHeaders, Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.http.api.HttpStreamingDeserializer
Deserialize a Publisher of Objects into a Publisher of type HttpStreamingDeserializer.
deserialize(HttpHeaders, BlockingIterable<Buffer>) - Method in interface io.servicetalk.http.api.HttpDeserializer
Deprecated.
Deserialize a BlockingIterable of Objects into a BlockingIterable of type HttpDeserializer.
deserialize(HttpHeaders, BlockingIterable<Buffer>, BufferAllocator) - Method in interface io.servicetalk.http.api.HttpStreamingDeserializer
deserialize(Iterable<Buffer>) - Method in interface io.servicetalk.serialization.api.StreamingDeserializer
deserialize(Iterable<Buffer>, BufferAllocator) - Method in interface io.servicetalk.serializer.api.StreamingDeserializer
Deserialize a Iterable of Buffer into a Iterable of StreamingDeserializer.
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(Iterable<Buffer>, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserialize(Iterable<Buffer>, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserialize(Iterable<Buffer>, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
deserializeAggregated(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserializeAggregated(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deprecated.
Use StreamingDeserializer that understands your protocol's framing.
deserializeAggregated(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserializeAggregated(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deprecated.
Use StreamingDeserializer that understands your protocol's framing.
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserializeAggregatedSingle(Buffer, TypeHolder<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deprecated.
deserializeAggregatedSingle(Buffer, Class<T>) - Method in class io.servicetalk.serialization.api.DefaultSerializer
Deprecated.
 
deserializeAggregatedSingle(Buffer, Class<T>) - Method in interface io.servicetalk.serialization.api.Serializer
Deprecated.
Deserializer<T> - Interface in io.servicetalk.serializer.api
Deserialize objects from Buffer to Deserializer.
deserializerFor(ContentCodec, Class<T>) - Method in interface io.servicetalk.grpc.api.GrpcSerializationProvider
Deprecated.
deserializerFor(TypeHolder<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider
Deprecated.
deserializerFor(Class<T>) - Method in interface io.servicetalk.http.api.HttpSerializationProvider
Deprecated.
detectBoundary(Object) - Method in interface io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider
Deprecated.
Detect the SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten.
difference(HttpExecutionStrategy, HttpExecutionStrategy) - Static method in class io.servicetalk.http.api.HttpExecutionStrategies
Find the difference between two strategies and provide a resulting strategy if there are differences in between the strategies.
disable() - Static method in class io.servicetalk.concurrent.api.AsyncContext
Disable AsyncContext.
disableAllRetries() - Static method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter
Retrying filter that disables any form of retry behaviour.
disableAutoRetries() - Static method in class io.servicetalk.http.netty.RetryingHttpRequesterFilter
Retrying filter that disables automatic retries for exceptions, but still waits until LoadBalancer becomes ready for the first time.
disabled() - Static method in class io.servicetalk.http.netty.H2KeepAlivePolicies
Returns a H2ProtocolConfig.KeepAlivePolicy that disables all keep alive behaviors.
discardSomeReadBytes() - Method in interface io.servicetalk.buffer.api.CompositeBuffer
Discard all Buffers which have been read.
discover(UnresolvedAddress) - Method in class io.servicetalk.client.api.DelegatingServiceDiscoverer
 
discover(UnresolvedAddress) - Method in interface io.servicetalk.client.api.ServiceDiscoverer
Subscribe to the service discovery system for changes in the available ServiceDiscoverer associated with address.
discoveryCancelled() - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererObserver.DnsDiscoveryObserver
Notifies that the current DNS discovery got cancelled.
discoveryFailed(Throwable) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererObserver.DnsDiscoveryObserver
Notifies that the current DNS discovery failed.
distinct() - Method in class io.servicetalk.concurrent.api.Publisher
Only emits distinct signals observed by this Publisher.
dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
 
dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
 
dnsResolverAddressTypes(DnsResolverAddressTypes) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder
Sets the list of the protocol families of the address resolved.
DnsResolverAddressTypes - Enum Class in io.servicetalk.dns.discovery.netty
Defined resolved address types.
DnsServerAddressStream - Interface in io.servicetalk.dns.discovery.netty
An infinite stream of DNS server addresses.
dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in class io.servicetalk.dns.discovery.netty.DefaultDnsServiceDiscovererBuilder
Deprecated.
 
dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in class io.servicetalk.dns.discovery.netty.DelegatingDnsServiceDiscovererBuilder
 
dnsServerAddressStreamProvider(DnsServerAddressStreamProvider) - Method in interface io.servicetalk.dns.discovery.netty.DnsServiceDiscovererBuilder
Set the DnsServerAddressStreamProvider which determines which DNS server should be used per query.
DnsServerAddressStreamProvider - Interface in io.servicetalk.dns.discovery.netty
Provides an opportunity to override which DnsServerAddressStream is used to resolve a specific hostname.
DnsServiceDiscovererBuilder - Interface in io.servicetalk.dns.discovery.netty
Builder for DNS ServiceDiscoverer which will attempt to resolve A, AAAA, CNAME, and SRV type queries.
DnsServiceDiscovererBuilderProvider - Interface in io.servicetalk.dns.discovery.netty
DnsServiceDiscovererObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into DNS ServiceDiscoverer built by DnsServiceDiscovererBuilder.
DnsServiceDiscovererObserver.DnsDiscoveryObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into individual DNS discoveries.
DnsServiceDiscovererObserver.DnsResolutionObserver - Interface in io.servicetalk.dns.discovery.netty
An observer that provides visibility into DNS resolution results.
DnsServiceDiscovererObserver.ResolutionResult - Interface in io.servicetalk.dns.discovery.netty
Results of the current DNS resolution.
DnsServiceDiscoverers - Class in io.servicetalk.dns.discovery.netty
A factory to create DNS ServiceDiscoverers.
doClose(boolean) - Method in interface io.servicetalk.concurrent.api.AsyncCloseables.CloseableResource
Supplies the Completable representing the close.
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.DefaultNettyConnection
 
doCloseAsyncGracefully() - Method in class io.servicetalk.transport.netty.internal.NettyChannelListenableAsyncCloseable
Initiate graceful closure.
domain() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
domain() - Method in interface io.servicetalk.http.api.HttpSetCookie
Returns the domain of this HttpSetCookie.
domainMatches(CharSequence, CharSequence) - Static method in class io.servicetalk.http.api.HeaderUtils
DomainSocketAddress - Class in io.servicetalk.transport.api
An address which represents a socket belonging to the AF_UNIX socket family.
DomainSocketAddress(File) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress
Create a new instance.
DomainSocketAddress(String) - Constructor for class io.servicetalk.transport.api.DomainSocketAddress
Create a new instance.
dontForceOpenCircuitOnPeerCircuitRejections() - Method in class io.servicetalk.traffic.resilience.http.TrafficResilienceHttpClientFilter.Builder
When a peer rejects a request due to an open-circuit (see.
drainRequestPayloadBody(boolean) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
drainRequestPayloadBody(boolean) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Configure automatic consumption of request payload body when it is not consumed by the service.
dropped() - Method in interface io.servicetalk.capacity.limiter.api.CapacityLimiter.Ticket
Callback to indicate that a request was dropped externally (eg.
duplicate() - Method in interface io.servicetalk.buffer.api.Buffer
Returns a buffer which shares the whole region of this buffer.
duplicate() - Method in interface io.servicetalk.buffer.api.BufferHolder
Deprecated.
Duplicates this BufferHolder.
duplicate() - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
duplicate() - Method in interface io.servicetalk.dns.discovery.netty.DnsServerAddressStream
Duplicate this object.
DuplicateAttributeException - Exception in io.servicetalk.client.api.partition
Deprecated.
We are unaware of anyone using "partition" feature and plan to remove it in future releases. If you depend on it, consider using ClientGroup as an alternative or reach out to the maintainers describing the use-case.
DuplicateAttributeException(PartitionAttributes.Key, String) - Constructor for exception io.servicetalk.client.api.partition.DuplicateAttributeException
Deprecated.
Create a new instance.
DuplicateSubscribeException - Exception in io.servicetalk.concurrent.internal
Used in scenarios where a subscribe to an asynchronous source is subscribed to, but there is already a subscriber and the source doesn't support multiple subscribers.
DuplicateSubscribeException(Object, Object) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException
Create a new instance.
DuplicateSubscribeException(Object, Object, String) - Constructor for exception io.servicetalk.concurrent.internal.DuplicateSubscribeException
Create a new instance.
DurationUtils - Class in io.servicetalk.utils.internal
Helper utilities for Duration.
dynamicAIMD() - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
AIMD is a request drop based dynamic CapacityLimiter for clients, that adapts its limit based on a configurable range of concurrency and re-evaluates this limit upon a request-drop event (eg. timeout or rejection due to capacity).
dynamicGradient() - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
Gradient is a dynamic concurrency limit algorithm used for clients or servers.
dynamicGradientOptimizeForLatency() - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
Gradient is a dynamic concurrency limit algorithm used for clients or servers.
dynamicGradientOptimizeForThroughput() - Static method in class io.servicetalk.capacity.limiter.api.CapacityLimiters
Gradient is a dynamic concurrency limit algorithm used for clients or servers.

E

EARLY_HINTS - Static variable in class io.servicetalk.http.api.HttpResponseStatus
103 Early Hints
EarlyConnectionAcceptor - Interface in io.servicetalk.transport.api
Allows to accept or reject connections early in the connection setup stage.
earlyHints() - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.HttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
earlyHints() - Method in interface io.servicetalk.http.api.StreamingHttpResponseFactory
Create a new HttpResponseStatus.EARLY_HINTS response.
effectiveHostAndPort() - Method in interface io.servicetalk.http.api.HttpRequestMetaData
Get the host and port components of the effective request URI.
EIGHT_NINES - Static variable in class io.servicetalk.grpc.internal.DeadlineUtils
gRPC spec requires timeout value to be 8 or fewer ASCII integer digits.
ejectionTimeJitter() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The amount of jitter to add to the ejection time.
ejectionTimeJitter(Duration) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the ejection time jitter.
ElementsAreNonnullByDefault - Annotation Interface in io.servicetalk.annotations
Indicates that fields, method parameters, method return types, and type parameters within a package are Nonnull unless explicitly annotated with Nullable.
empty() - Static method in class io.servicetalk.concurrent.api.Publisher
Creates a new Publisher that completes when subscribed without emitting any item to its PublisherSource.Subscriber.
EMPTY_BUFFER - Static variable in class io.servicetalk.buffer.api.EmptyBuffer
An instance of EmptyBuffer that can be shared.
EMPTY_SUBSCRIPTION - Static variable in class io.servicetalk.concurrent.internal.EmptySubscriptions
A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will throw on invalid demand.
EMPTY_SUBSCRIPTION_NO_THROW - Static variable in class io.servicetalk.concurrent.internal.EmptySubscriptions
A PublisherSource.Subscription with no associated PublisherSource.Subscriber that will not throw on invalid demand.
emptyAsciiString() - Static method in class io.servicetalk.buffer.api.CharSequences
Get a reference to an unmodifiable empty CharSequence with the same properties as CharSequences.newAsciiString(Buffer).
emptyAsyncCloseable() - Static method in class io.servicetalk.concurrent.api.AsyncCloseables
Creates an empty ListenableAsyncCloseable that does nothing when AsyncCloseable.closeAsync() apart from completing the ListenableAsyncCloseable.onClose().
emptyBlockingIterable() - Static method in class io.servicetalk.concurrent.internal.BlockingIterables
Get a BlockingIterable that generates BlockingIterators where Iterator.hasNext() returns true.
EmptyBuffer - Class in io.servicetalk.buffer.api
An immutable zero capacity Buffer.
EmptyBufferDecoderGroup - Class in io.servicetalk.encoding.api
A BufferDecoderGroup which is empty.
EmptyHttpHeaders - Class in io.servicetalk.http.api
HttpHeaders which are always empty and does not allow modification.
EmptySubscriptions - Class in io.servicetalk.concurrent.internal
Utility methods for PublisherSource.Subscriptions which don't deliver any data.
enableFrameLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.netty.H2ProtocolConfigBuilder
Enables a logger for HTTP/2 frames.
enableMetrics() - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions
Whether to enable operation metrics or not.
enableMetrics(boolean) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions.Builder
Whether to enable operation metrics or not.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.api.DelegatingHttpServerBuilder
 
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.http.api.DelegatingSingleAddressHttpClientBuilder
 
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in interface io.servicetalk.http.api.HttpServerBuilder
Enables wire-logging for this server.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in interface io.servicetalk.http.api.SingleAddressHttpClientBuilder
Enables wire-logging for connections created by this builder.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.opentracing.zipkin.publisher.reporter.UdpReporter.Builder
Enables wire-logging for UDP packets sent.
enableWireLogging(String, LogLevel, BooleanSupplier) - Method in class io.servicetalk.tcp.netty.internal.TcpServerConfig
Enable wire-logging for all connections.
encode(Buffer, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec
Deprecated.
Take a Buffer and encode its contents resulting in a Buffer with the encoded contents.
encode(Publisher<Buffer>, BufferAllocator) - Method in interface io.servicetalk.encoding.api.ContentCodec
Deprecated.
Take a Publisher of Buffer and encode its contents resulting in a Publisher of Buffer with the encoded contents.
encoded() - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
 
encoded() - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
encoded() - Method in interface io.servicetalk.http.api.HttpCookiePair
Get the encoded value of this HttpCookiePair.
encoder() - Method in interface io.servicetalk.encoding.api.BufferEncoder
Get the Serializer to use for aggregated content.
encoder() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder
Deprecated.
 
encoding() - Method in exception io.servicetalk.grpc.api.MessageEncodingException
Deprecated.
The name of the encoding used when the Exception was thrown.
encoding() - Method in interface io.servicetalk.http.api.HttpMetaData
Deprecated.
Use HttpRequestMetaData.contentEncoding() for requests and ContentEncodingHttpServiceFilter for responses. An example can be found here.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpRequest
Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpResponse
Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.BlockingStreamingHttpServerResponse
 
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpMetaData
Deprecated.
Use HttpRequestMetaData.contentEncoding(BufferEncoder) for requests and ContentEncodingHttpServiceFilter for responses. An example can be found here.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpRequest
Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.HttpResponse
 
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.StreamingHttpRequest
Deprecated.
encoding(ContentCodec) - Method in interface io.servicetalk.http.api.StreamingHttpResponse
Deprecated.
encodingFor(Collection<ContentCodec>, CharSequence) - Static method in class io.servicetalk.encoding.api.internal.HeaderUtils
encodingForRaw(List<T>, Function<T, CharSequence>, CharSequence) - Static method in class io.servicetalk.encoding.api.internal.HeaderUtils
Get the first encoding that matches name from supportedEncoders.
encodingName() - Method in interface io.servicetalk.encoding.api.BufferDecoder
Get the name of the encoding.
encodingName() - Method in interface io.servicetalk.encoding.api.BufferEncoder
Get the name of the encoding.
encodingName() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferDecoder
Deprecated.
 
encodingName() - Method in class io.servicetalk.encoding.api.internal.ContentCodecToBufferEncoder
Deprecated.
 
End - Enum constant in enum class io.servicetalk.transport.netty.internal.SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary
Deprecated.
 
EnforceSequentialModeRequesterFilter - Class in io.servicetalk.http.utils
Enforces sequential behavior of the client, deferring return of the response until after the request payload body is sent.
enforcingConsecutive5xx() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The probability in percentage that a host will be marked as unhealthy when a host reaches the OutlierDetectorConfig.consecutive5xx() threshold.
enforcingConsecutive5xx(int) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the probability in percentage that a host will be marked as unhealthy when a host reaches the OutlierDetectorConfig.consecutive5xx() threshold.
enforcingFailurePercentage() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The probability in percentage that a host will be marked as unhealthy when a host exceeds the failure percentage outlier detectors threshold.
enforcingFailurePercentage(int) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the probability in percentage that a host will be marked as unhealthy when a host exceeds the failure percentage outlier detectors threshold.
enforcingSuccessRate() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The probability in percentage that a host will be marked as unhealthy when a host exceeds the success rate outlier detectors threshold.
enforcingSuccessRate(int) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the probability in percentage that a host will be marked as unhealthy when a host exceeds the success rate outlier detectors threshold.
ENHANCE_YOUR_CALM - Static variable in class io.servicetalk.http.api.Http2ErrorCode
ensureNonNegative(int, String) - Static method in class io.servicetalk.utils.internal.NumberUtils
Ensures the int is non-negative.
ensureNonNegative(long, String) - Static method in class io.servicetalk.utils.internal.NumberUtils
Ensures the long is non-negative.
ensureNonNegative(Duration, String) - Static method in class io.servicetalk.utils.internal.DurationUtils
Ensures the duration is non-negative.
ensurePositive(int, String) - Static method in class io.servicetalk.utils.internal.NumberUtils
Ensures the int is positive, excluding zero.
ensurePositive(long, String) - Static method in class io.servicetalk.utils.internal.NumberUtils
Ensures the long is positive, excluding zero.
ensurePositive(Duration, String) - Static method in class io.servicetalk.utils.internal.DurationUtils
Ensures the duration is positive, excluding zero.
ensureType(ContextMap.Key<?>, Object) - Static method in class io.servicetalk.concurrent.internal.ContextMapUtils
Make sure that the value type matches with the ContextMap.Key.type().
ensureWritable(int) - Method in interface io.servicetalk.buffer.api.Buffer
Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
ensureWritable(int, boolean) - Method in interface io.servicetalk.buffer.api.Buffer
Expands the buffer Buffer.capacity() to make sure the number of writable bytes is equal to or greater than the specified value.
ensureWritable(int, boolean) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
epochMicros() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog
Get the microseconds since epoch for this InMemorySpanLog.
equals(ContextMap, ContextMap) - Static method in class io.servicetalk.concurrent.internal.ContextMapUtils
equals(Object) - Method in interface io.servicetalk.buffer.api.Buffer
Determines if the content of the specified buffer is identical to the content of this array.
equals(Object) - Method in class io.servicetalk.buffer.api.EmptyBuffer
 
equals(Object) - Method in class io.servicetalk.client.api.DefaultGroupKey
 
equals(Object) - Method in class io.servicetalk.client.api.DefaultServiceDiscovererEvent
 
equals(Object) - Method in class io.servicetalk.client.api.partition.PartitionAttributes.Key
Deprecated.
 
equals(Object) - Method in class io.servicetalk.client.api.ServiceDiscovererEvent.Status
 
equals(Object) - Method in class io.servicetalk.concurrent.internal.DefaultContextMap
 
equals(Object) - Method in class io.servicetalk.concurrent.internal.TerminalNotification
 
equals(Object) - Method in interface io.servicetalk.context.api.ContextMap
Determines if the specified object is equal to this ContextMap.
equals(Object) - Method in class io.servicetalk.grpc.api.GrpcStatus
 
equals(Object) - Method in class io.servicetalk.health.v1.HealthCheckRequest
 
equals(Object) - Method in class io.servicetalk.health.v1.HealthCheckResponse
 
equals(Object) - Method in class io.servicetalk.http.api.ConnectAndHttpExecutionStrategy
 
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpCookiePair
 
equals(Object) - Method in class io.servicetalk.http.api.DefaultHttpSetCookie
 
equals(Object) - Method in class io.servicetalk.http.api.EmptyHttpHeaders
 
equals(Object) - Method in class io.servicetalk.http.api.Http2ErrorCode
 
equals(Object) - Method in class io.servicetalk.http.api.HttpProtocolVersion
 
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod
 
equals(Object) - Method in class io.servicetalk.http.api.HttpRequestMethod.Properties
 
equals(Object) - Method in class io.servicetalk.http.api.HttpResponseStatus
 
equals(Object) - Method in class io.servicetalk.http.security.auth.basic.jersey.BasicAuthPrincipal
 
equals(Object) - Method in class io.servicetalk.loadbalancer.RichServiceDiscovererEvent
 
equals(Object) - Method in class io.servicetalk.logging.slf4j.internal.DefaultUserDataLoggerConfig
 
equals(Object) - Method in class io.servicetalk.opentelemetry.http.OpenTelemetryOptions
 
equals(Object) - Method in class io.servicetalk.transport.api.DefaultExecutionContext
 
equals(Object) - Method in class io.servicetalk.transport.api.DomainSocketAddress
 
equals(Object) - Method in class io.servicetalk.transport.api.FileDescriptorSocketAddress
 
equalsIgnoreCaseLower(char, char) - Static method in class io.servicetalk.buffer.api.CharSequences
Compare an unknown ascii character a with a known lowercase character lowerCaseChar in a case insensitive manner.
error(Throwable) - Static method in class io.servicetalk.concurrent.internal.TerminalNotification
Returns a TerminalNotification for cause.
ERROR - Enum constant in enum class io.servicetalk.logging.api.LogLevel
ERROR log level.
ErrorClass - Enum Class in io.servicetalk.loadbalancer
Enumeration of the main failure classes.
errorCode() - Method in exception io.servicetalk.http.api.Http2Exception
Get the error code which caused this exception.
estimateRequestN(long) - Method in interface io.servicetalk.transport.netty.internal.WriteDemandEstimator
Given the current capacity of the write buffer, supply how many items to request next from the associated PublisherSource.Subscription.
ETAG - Static variable in class io.servicetalk.http.api.HttpHeaderNames
"etag"
event() - Method in interface io.servicetalk.client.api.ConsumableEvent
Get the event.
event() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
Deprecated.
 
event() - Method in exception io.servicetalk.transport.netty.internal.CloseHandler.CloseEventObservedException
CloseHandler.CloseEvent was observed from the protocol or Channel.
eventConsumed() - Method in interface io.servicetalk.client.api.ConsumableEvent
Signify the ConsumableEvent.event() has been consumed and any side effects have taken place.
eventConsumed() - Method in class io.servicetalk.client.api.internal.IgnoreConsumedEvent
Deprecated.
 
EventLoopAwareNettyIoExecutor - Interface in io.servicetalk.transport.netty.internal
A special NettyIoExecutor that exposes the underlying netty EventLoopGroup.
EventLoopAwareNettyIoExecutors - Class in io.servicetalk.transport.netty.internal
A static factory to create or convert to EventLoopAwareNettyIoExecutor.
eventLoopGroup() - Method in interface io.servicetalk.transport.netty.internal.EventLoopAwareNettyIoExecutor
Returns the underlying EventLoopGroup.
eventName() - Method in interface io.servicetalk.opentracing.inmemory.api.InMemorySpanLog
Get the name of the event for this InMemorySpanLog.
eventStream() - Method in interface io.servicetalk.client.api.LoadBalancer
A Publisher of events provided by this LoadBalancer.
ewmaCancellationPenalty() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The penalty factor for local cancellation of requests.
ewmaCancellationPenalty(long) - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig.Builder
Set the penalty factor for local cancellation of requests.
ewmaErrorPenalty() - Method in class io.servicetalk.loadbalancer.OutlierDetectorConfig
The penalty factor for requests that were classified as an error.
ewmaErrorPenalty(long) - Method in class io.servicetalk.loadbalancer.