All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
Class |
Description |
AbstractCloseableIterable<T> |
|
AbstractCloseableIteratorAsInputStream<T> |
Conversion from a CloseableIterator to a InputStream given a Function to serialize to bytes.
|
AbstractFilterInterceptorTest |
|
AbstractFilterInterceptorTest.TestGlobalFilter |
|
AbstractFilterInterceptorTest.TestGlobalInterceptor |
|
AbstractFilterInterceptorTest.TestInputConsumingGlobalFilter |
|
AbstractFilterInterceptorTest.UpperCaseInputStream |
|
AbstractHttpRequesterFilterTest |
This parameterized test facilitates running HTTP requester filter tests under all calling variations: client,
connection, reserved connection, with and without SSL context.
|
AbstractHttpRequesterFilterTest.RequesterType |
|
AbstractHttpRequesterFilterTest.RequestHandler |
|
AbstractHttpRequesterFilterTest.RequestWithContextHandler |
|
AbstractHttpRequesterFilterTest.SecurityType |
|
AbstractHttpServiceFilterTest |
This parameterized test facilitates running HTTP service filter tests under all calling variations:
with and without SSL context.
|
AbstractHttpServiceFilterTest.SecurityType |
|
AbstractJerseyStreamingHttpServiceTest |
|
AbstractNonParameterizedJerseyStreamingHttpServiceTest |
|
AbstractNonParameterizedJerseyStreamingHttpServiceTest.RouterApi |
|
AbstractResourceTest |
|
AbstractResourceTest.TestApplication |
|
AbstractResourceTest.TestFilter |
|
AbstractResourceTest.TestFiltered |
|
AbstractRetryingFilterBuilder<Builder extends AbstractRetryingFilterBuilder<Builder,Filter,Meta>,Filter,Meta> |
An abstract builder for retrying filters.
|
AbstractRetryingFilterBuilder.ReadOnlyRetryableSettings<Meta> |
A read-only settings for retryable filters.
|
AddressUtils |
A utility class to work with addresses.
|
ArrayUtils |
Utilities for arrays.
|
AsyncCloseable |
Used to close/shutdown a resource.
|
AsyncCloseables |
|
AsyncCloseables.CloseableResource |
|
AsyncContext |
Presents a static interface to retain state in an asynchronous environment.
|
AsyncContextInMemoryScopeManager |
|
AsyncContextMap |
|
AsyncContextMap.Key<T> |
|
AsyncContextMapHolder |
|
AsynchronousResources |
Asynchronous (in JAX-RS lingo) resources.
|
AsynchronousResourceTest |
|
AuthenticationException |
|
AutoClosableUtils |
Utilities for AutoCloseable .
|
AutoCloseables |
A utility class for methods related to AutoCloseable .
|
AutoOnSubscribeCompletableSubscriberFunction |
|
AutoOnSubscribePublisherSubscriberFunction<T> |
|
AutoOnSubscribeSingleSubscriberFunction<T> |
|
AutoRetryStrategyProvider |
|
AutoRetryStrategyProvider.AutoRetryStrategy |
A strategy to use for automatic retries.
|
BaseJerseyRouterTestSuite |
|
BasicAuthenticated |
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> |
|
BasicAuthHttpServiceFilter.Builder<UserInfo> |
|
BasicAuthHttpServiceFilter.CredentialsVerifier<UserInfo> |
Verifies user-id and password , parsed from the 'Basic' HTTP Authentication Scheme credentials.
|
BasicAuthPrincipal<UserInfo> |
A generic Principal that wraps a user provided UserInfo .
|
BasicAuthSecurityContext |
A generic SecurityContext that wraps a user provided Principal ,
and which is designed for the SecurityContext.BASIC_AUTH authentication scheme.
|
BasicAuthSecurityContextFilters |
Factory methods for building ContainerRequestFilter that establish SecurityContext s for requests
authenticated with the Basic HTTP Authentication Scheme ( RFC7617).
|
BasicAuthSecurityContextFilters.AbstractBuilder<B extends BasicAuthSecurityContextFilters.AbstractBuilder,PF,SCF> |
A builder for ContainerRequestFilter instances.
|
BasicAuthSecurityContextFilters.NoUserInfoBuilder |
A builder that can be used when no user info is stored in AsyncContext .
|
BasicAuthSecurityContextFilters.UserInfoBuilder<UserInfo> |
A builder that can be used when user info is stored in AsyncContext .
|
BeforeFinallyHttpOperator |
Helper operator for signaling the end of an HTTP Request/Response cycle.
|
BiIntFunction<T,R> |
A special function that takes an int and a custom argument and returns the result.
|
BiIntPredicate<T> |
A special predicate that takes an int and a custom argument to evaluate.
|
BlockingGrpcClient<Client extends GrpcClient> |
A blocking client to a gRPC service.
|
BlockingGrpcService |
|
BlockingHttpClient |
The equivalent of HttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingHttpConnection |
The equivalent of HttpConnection but with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingHttpRequester |
The equivalent of HttpRequester with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingHttpService |
The equivalent of HttpService but with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingIterable<T> |
|
BlockingIterable.Processor<T> |
|
BlockingIterables |
|
BlockingIterator<T> |
An Iterator that is also an AutoCloseable and whose blocking operations support timeout durations.
|
BlockingProcessorSignalsHolder<T> |
|
BlockingSpliterator<T> |
An Spliterator which supports AutoCloseable.close() .
|
BlockingStreamingHttpClient |
The equivalent of StreamingHttpClient but with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingStreamingHttpConnection |
|
BlockingStreamingHttpRequest |
|
BlockingStreamingHttpRequester |
|
BlockingStreamingHttpRequestFactory |
|
BlockingStreamingHttpRequestResponseFactory |
|
BlockingStreamingHttpResponse |
|
BlockingStreamingHttpResponseFactory |
|
BlockingStreamingHttpServerResponse |
|
BlockingStreamingHttpService |
The equivalent of StreamingHttpService but with synchronous/blocking APIs instead of asynchronous APIs.
|
BlockingTestUtils |
Utilities to await results of an asynchronous computation either by blocking the calling thread.
|
Buffer |
An arbitrary and sequential accessible sequence of zero or more bytes (octets).
|
BufferAllocator |
|
BufferAllocators |
|
BufferHandler |
A ChannelHandler that converts does the following conversions:
Buffer to ByteBuf for writes.
BufferHolder to ByteBuf for writes.
ByteBuf to Buffer for reads.
ByteBufHolder to Buffer for reads.
This also releases any ByteBuf once converted to Buffer .
|
BufferHolder |
An object which contains a Buffer .
|
BufferPublisherInputStream |
|
BufferStrategies |
|
BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B> |
|
BufferStrategy.Accumulator<T,B> |
An intermediate mutable object that holds items till it is finished .
|
BufferUtils |
Internal utilities for Buffer s.
|
BuilderUtils |
Utilities which are used for builders.
|
ByteProcessor |
Provides a mechanism to iterate over a collection of bytes.
|
ByteToMessageDecoder |
ChannelInboundHandlerAdapter which decodes bytes in a stream-like fashion from one ByteBuf to an
other Message type.
|
CancelImmediatelySubscriber |
|
Cancellable |
An entity that can be cancelled.
|
CancellableResources |
|
CancellationTest |
|
ChannelCloseUtils |
Utilities to handle Channel closure and its reason.
|
ChannelInitializer |
Configures a Channel .
|
ChannelSet |
Manages a set of Channel s to provide a mechanism for closing all of them.
|
CharSequences |
8-bit ASCII strings factory and basic utilities helper.
|
CharSequences |
Deprecated.
|
ClientGroup<Key,Client extends ListenableAsyncCloseable> |
A data-structure capable of holding arbitrary number of clients and bridging lifecycle events across all clients
managed by the group.
|
ClientInvoker<State> |
|
ClientSecurityConfig |
Client security configuration.
|
ClientSecurityConfigurator |
|
CloseableIterable<T> |
|
CloseableIterator<T> |
An Iterator that is also an AutoCloseable .
|
CloseableIteratorBufferAsInputStream |
|
ClosedPartitionException |
Thrown when a request is issued against a valid partition that was closed after selection.
|
CloseHandler |
Contract between protocol codecs and a close handler.
|
CloseHandler.CloseEvent |
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 |
ClosedChannelException with additional meta-data to provide more context on what side initiated the close
event.
|
CloseHandler.DiscardFurtherInboundEvent |
Netty UserEvent to indicate the further inbound data should be discarded.
|
Codec |
Zipkin data formats for reporting of Span s.
|
Completable |
An asynchronous computation that does not emit any data.
|
CompletableFirstStep |
Provides the ability to express expectations for the first step in a Subscriber 's lifecycle.
|
CompletableLastStep |
Provides the ability to express expectations for the terminal signals (e.g.
|
CompletableOperator |
|
CompletableSource |
An asynchronous computation that does not emit any data.
|
CompletableSource.Processor |
|
CompletableSource.Subscriber |
|
CompositeBuffer |
A virtual Buffer which shows multiple buffers as a single merged buffer.
|
CompositeCloseable |
|
ConcurrentCompletableSubscriberFunction |
|
ConcurrentPublisherSubscriberFunction<T> |
|
ConcurrentSingleSubscriberFunction<T> |
|
ConcurrentSubscription |
|
ConcurrentTerminalSubscriber<T> |
|
ConcurrentUtils |
Utilities which can be used for concurrency.
|
ConditionalFilterFactory |
|
ConditionalFilterFactory.FilterFactory |
|
ConnectableBufferOutputStream |
|
ConnectablePayloadWriter<T> |
|
ConnectionAcceptor |
A contract that defines the connection acceptance criterion.
|
ConnectionAcceptorFactory |
|
ConnectionClosedException |
Thrown when the connection is no longer available.
|
ConnectionContext |
A context for a connection.
|
ConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> |
A factory for creating new connections.
|
ConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> |
|
ConnectionInfo |
Provides information about a connection.
|
ConnectionInfo.Protocol |
Provides information about the network protocol.
|
ConnectionObserver |
An observer interface that provides visibility into events associated with a network connection.
|
ConnectionObserver.DataObserver |
An observer interface that provides visibility into read and write events related to data flow.
|
ConnectionObserver.MultiplexedObserver |
An observer interface that provides visibility into new streams created by a multiplexed connection.
|
ConnectionObserver.ReadObserver |
An observer interface that provides visibility into read events.
|
ConnectionObserver.SecurityHandshakeObserver |
An observer interface that provides visibility into security handshake events.
|
ConnectionObserver.StreamObserver |
An observer interface that provides visibility into stream events.
|
ConnectionObserver.WriteObserver |
An observer interface that provides visibility into write events.
|
ConnectionObserverInitializer |
|
ConnectionRejectedException |
Thrown when a newly created connection was rejected.
|
ConnectTimeoutException |
Throws when a connect operations failed because of a timeout.
|
ConsumableEvent<T> |
|
ContentCodec |
API to support encode and decode of Buffer s.
|
ContentCodecBuilder |
|
ContentCodingHttpRequesterFilter |
|
ContentCodingHttpServiceFilter |
|
ContentCodings |
Common available encoding implementations.
|
ContextFilterSuccessful |
|
CookieMatcher |
Methods for route matching on cookies.
|
CopyByteBufHandlerChannelInitializer |
Initializer to configure ChannelInboundHandler that will ensure no pooled ByteBuf s are passed to
the user and so no leaks are produced if the user does not call ReferenceCountUtil.release(Object) .
|
DefaultAutoRetryStrategyProvider |
|
DefaultAutoRetryStrategyProvider.Builder |
|
DefaultDnsServiceDiscovererBuilder |
Builder for DNS ServiceDiscoverer which will attempt to
resolve A , AAAA , CNAME , and SRV type queries.
|
DefaultExecutionContext |
|
DefaultGroupKey<Address> |
|
DefaultGrpcClientMetadata |
|
DefaultHttpCookiePair |
|
DefaultHttpExecutionContext |
|
DefaultHttpHeadersFactory |
|
DefaultHttpLoadBalancerFactory<ResolvedAddress> |
|
DefaultHttpLoadBalancerFactory.Builder<ResolvedAddress> |
|
DefaultHttpSetCookie |
|
DefaultInMemoryTracer |
Tracer implementation that propagates spans in-memory and emits events to listeners.
|
DefaultInMemoryTracer.Builder |
|
DefaultInMemoryTraceState |
|
DefaultNettyConnection<Read,Write> |
|
DefaultPartitionAttributesBuilder |
|
DefaultPartitionedClientGroup<U,R,Client extends ListenableAsyncCloseable> |
|
DefaultPartitionedClientGroup.PartitionedClientFactory<U,R,Client> |
Factory for building partitioned clients.
|
DefaultRouteExecutionStrategyFactory<ES extends ExecutionStrategy> |
|
DefaultSerializer |
|
DefaultServiceDiscovererEvent<T> |
|
DefaultServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> |
|
DefaultServiceDiscoveryRetryStrategy.Builder<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> |
|
DefaultServiceTalkThreadContextMap |
Empty subclass to differentiate uses of MDC.
|
DefaultStreamingHttpRequestResponseFactory |
|
DefaultTestCerts |
Provides a set of certificates useful for tests that require SSL.
|
DefaultThreadFactory |
A ThreadFactory implementation.
|
DefaultUserDataLoggerConfig |
|
DeferredEmptySubscription |
|
DeferSslHandler |
A ChannelHandler that holds a place in a pipeline, allowing us to defer adding the SslHandler .
|
DelayedCancellable |
|
DelayedSubscription |
|
DelegatingConnectionAcceptor |
|
DelegatingConnectionContext |
|
DelegatingConnectionFactory<ResolvedAddress,C extends ListenableAsyncCloseable> |
|
DelegatingExecutionContext |
|
DelegatingExecutor |
|
DelegatingFlushStrategy |
|
DelegatingHttpConnectionContext |
|
DelegatingHttpExecutionContext |
|
DelegatingHttpExecutionStrategy |
|
DelegatingHttpServiceContext |
|
DelegatingSignalOffloader |
|
DelegatingSignalOffloaderFactory |
|
DeliberateException |
|
DemandCheckingSubscriber<T> |
|
DemandCheckingSubscriberFunction<T> |
|
DnsResolverAddressTypes |
Defined resolved address types.
|
DnsServerAddressStream |
An infinite stream of DNS server addresses.
|
DnsServerAddressStreamProvider |
|
DnsServiceDiscovererObserver |
|
DnsServiceDiscovererObserver.DnsDiscoveryObserver |
An observer that provides visibility into individual DNS resolutions.
|
DnsServiceDiscovererObserver.DnsResolutionObserver |
An observer that provides visibility into DNS resolution results.
|
DnsServiceDiscovererObserver.ResolutionResult |
Results of the current DNS resolution.
|
DomainSocketAddress |
|
DuplicateAttributeException |
|
DuplicateSubscribeException |
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.
|
ElementsAreNonnullByDefault |
Indicates that fields, method parameters, method return types, and type parameters
within a package are Nonnull unless explicitly annotated with Nullable .
|
EmbeddedDuplexChannel |
EmbeddedChannel that implements DuplexChannel .
|
EmptyBuffer |
An immutable zero capacity Buffer .
|
EmptyHttpHeaders |
HttpHeaders which are always empty and does not allow modification.
|
EmptySubscriptions |
|
EventLoopAwareNettyIoExecutor |
A special NettyIoExecutor that exposes the underlying netty EventLoopGroup .
|
EventLoopAwareNettyIoExecutors |
|
ExceptionMapperTest |
|
ExceptionMapperTest.TestApplication |
|
ExceptionMapperTest.TestExceptionMapper |
|
ExecutionContext |
Context related to execution and allocation.
|
ExecutionContextBuilder |
|
ExecutionContextRule |
Test helper that creates and disposes an ExecutionContext for your test case or suite.
|
ExecutionContextToHttpExecutionContext |
|
ExecutionStrategy |
An execution strategy for all transports.
|
ExecutionStrategyConfigurationFailuresTest |
|
ExecutionStrategyResources |
|
ExecutionStrategyResources.AbstractExecutionStrategyResource |
|
ExecutionStrategyResources.ResourceDefaultStrategy |
|
ExecutionStrategyResources.ResourceInvalidExecStrategy |
|
ExecutionStrategyResources.ResourceRouteExecIdStrategy |
|
ExecutionStrategyResources.ResourceRouteNoOffloadsStrategy |
|
ExecutionStrategyResources.ResourceUnsupportedAsync |
|
ExecutionStrategyTest |
|
ExecutionStrategyTest.TestApplication |
|
ExecutionStrategyTest.TestExecutorStrategy |
|
ExecutionStrategyTest.TestMode |
|
Executor |
A general abstraction to execute immediate and delayed tasks.
|
Executor |
A general abstraction to execute immediate and delayed tasks.
|
ExecutorRule<E extends Executor> |
An ExternalResource wrapper for an Executor .
|
Executors |
Utility methods to create various Executor s.
|
FileDescriptorSocketAddress |
Special SocketAddress that allows to wrap an already existing filedescriptor.
|
FilterableGrpcClient |
A client to a gRPC service that supports filtering.
|
FilterableReservedStreamingHttpConnection |
|
FilterableStreamingHttpClient |
|
FilterableStreamingHttpConnection |
|
FilterableStreamingHttpLoadBalancedConnection |
|
FixedLevelLogger |
|
FlowControlUtils |
A set of utility methods for safe math operations to prevent overflow.
|
FlushStrategies |
|
FlushStrategy |
A strategy that defines how to flush writes on a connection.
|
FlushStrategy.FlushSender |
|
FlushStrategy.WriteEventsListener |
|
FlushStrategyHolder |
|
FutureUtils |
A set of utilities for interacting with Future .
|
GlobalExecutionContext |
ServiceTalk's shared ExecutionContext with reasonable defaults for APIs when a user doesn't provide one.
|
GlobalFiltersTest |
|
GlobalFiltersTest.TestApplication |
|
GracefulAutoCloseable |
An extension of AutoCloseable to add graceful closure semantics.
|
GroupedPublisher<Key,T> |
|
GroupedPublisher.QueueSizeProvider |
|
GroupKey<Address> |
Identifies a client within a group of clients, and provides enough information to create a client if non exist.
|
GrpcClient<BlockingClient extends BlockingGrpcClient> |
A client to a gRPC service.
|
GrpcClientBuilder<U,R> |
A builder for building a gRPC client.
|
GrpcClientBuilder.MultiClientBuilder |
An interface to create multiple gRPC clients sharing the
same underlying transport instance.
|
GrpcClientCallFactory |
A factory to create gRPC client call objects for different
programming models.
|
GrpcClientCallFactory.BlockingClientCall<Req,Resp> |
An abstraction to make blocking client calls.
|
GrpcClientCallFactory.BlockingRequestStreamingClientCall<Req,Resp> |
An abstraction to make blocking client calls where request is streaming.
|
GrpcClientCallFactory.BlockingResponseStreamingClientCall<Req,Resp> |
An abstraction to make blocking client calls where response is streaming.
|
GrpcClientCallFactory.BlockingStreamingClientCall<Req,Resp> |
An abstraction to make blocking bi-directional streaming client calls.
|
GrpcClientCallFactory.ClientCall<Req,Resp> |
An abstraction to make asynchronous client calls.
|
GrpcClientCallFactory.RequestStreamingClientCall<Req,Resp> |
An abstraction to make asynchronous client calls where request is streaming.
|
GrpcClientCallFactory.ResponseStreamingClientCall<Req,Resp> |
An abstraction to make asynchronous client calls where response is streaming.
|
GrpcClientCallFactory.StreamingClientCall<Req,Resp> |
An abstraction to make asynchronous bi-directional streaming client calls.
|
GrpcClientFactory<Client extends GrpcClient<BlockingClient>,BlockingClient extends BlockingGrpcClient<Client>,Filter extends FilterableClient,FilterableClient extends FilterableGrpcClient,FilterFactory extends GrpcClientFilterFactory<Filter,FilterableClient>> |
|
GrpcClientFilterFactory<Filter extends FilterableClient,FilterableClient extends FilterableGrpcClient> |
A factory to create gRPC client filters.
|
GrpcClientMetadata |
Metadata for a gRPC client call.
|
GrpcClients |
A factory to create gRPC clients.
|
GrpcClientSecurityConfigurator<U,R> |
|
GrpcExecutionContext |
|
GrpcExecutionStrategies |
|
GrpcExecutionStrategies.Builder |
|
GrpcExecutionStrategy |
An execution strategy for gRPC client and servers.
|
GrpcMetadata |
Metadata for a gRPC call.
|
GrpcPayloadWriter<T> |
|
GrpcRoutes<Service extends GrpcService> |
A holder of gRPC routes that constitutes a service.
|
GrpcRoutes.AllGrpcRoutes |
A collection of route corresponding to the enclosing GrpcRoutes .
|
GrpcRoutes.BlockingRequestStreamingRoute<Req,Resp> |
A blocking gRPC route with request streaming.
|
GrpcRoutes.BlockingResponseStreamingRoute<Req,Resp> |
A blocking gRPC route with response streaming.
|
GrpcRoutes.BlockingRoute<Req,Resp> |
|
GrpcRoutes.BlockingStreamingRoute<Req,Resp> |
A blocking gRPC route with bi-directional streaming.
|
GrpcRoutes.RequestStreamingRoute<Req,Resp> |
An asynchronous gRPC route with request streaming.
|
GrpcRoutes.ResponseStreamingRoute<Req,Resp> |
An asynchronous gRPC route with response streaming.
|
GrpcRoutes.Route<Req,Resp> |
An asynchronous gRPC route.
|
GrpcRoutes.StreamingRoute<Req,Resp> |
An asynchronous gRPC route with bi-directional streaming.
|
GrpcSerializationProvider |
A provider for gRPC serialization/deserialization.
|
GrpcServerBuilder |
A builder for building a gRPC server.
|
GrpcServers |
A factory to create gRPC servers.
|
GrpcServerSecurityConfigurator |
|
GrpcService |
|
GrpcServiceContext |
|
GrpcServiceContext.GrpcProtocol |
|
GrpcServiceFactory<Filter extends Service,Service extends GrpcService,FilterFactory extends GrpcServiceFilterFactory<Filter,Service>> |
|
GrpcServiceFactory.ServerBinder |
A utility to bind an HTTP service for gRPC with an
appropriate programming model.
|
GrpcServiceFilterFactory<Filter extends Service,Service> |
A factory to create gRPC service filters.
|
GrpcStatus |
Class representing gRPC statuses.
|
GrpcStatusCode |
Standard gRPC status codes.
|
GrpcStatusException |
|
H1ProtocolConfig |
|
H1ProtocolConfigBuilder |
|
H1SpecExceptions |
Additional exceptions for HTTP/1.1 specification.
|
H1SpecExceptions.Builder |
|
H2HeadersFactory |
|
H2KeepAlivePolicies |
|
H2KeepAlivePolicies.KeepAlivePolicyBuilder |
|
H2ProtocolConfig |
Configuration for HTTP/2 protocol.
|
H2ProtocolConfig.KeepAlivePolicy |
|
H2ProtocolConfigBuilder |
|
HeaderUtils |
|
HeaderUtils |
|
HeaderUtils.CookiesByNameIterator |
|
HeaderUtils.CookiesIterator |
|
HexUtils |
Utilities for hex strings.
|
HostAndPort |
A tuple of <host name, port> .
|
HttpApiConversions |
|
HttpApiConversions.ServiceAdapterHolder |
|
HttpClient |
Provides a means to issue requests against HTTP service.
|
HttpClients |
Factory methods for building HttpClient (and other API variations) instances.
|
HttpConnection |
Represents a single fixed connection to a HTTP server.
|
HttpConnectionContext |
|
HttpCookiePair |
|
HttpDeserializer<T> |
A factory to address deserialization concerns for HTTP request/response payload bodies.
|
HttpEventKey<T> |
A key which identifies a configuration setting for a connection.
|
HttpExecutionContext |
|
HttpExecutionStrategies |
|
HttpExecutionStrategies.Builder |
|
HttpExecutionStrategy |
An execution strategy for HTTP client and servers.
|
HttpExecutionStrategyInfluencer |
|
HttpHeaderNames |
|
HttpHeaders |
|
HttpHeadersFactory |
|
HttpHeaderValues |
|
HttpJerseyRouterBuilder |
Builds an StreamingHttpService which routes requests to JAX-RS annotated classes,
using Jersey as the routing engine, eg.
|
HttpLoadBalancerFactory<ResolvedAddress> |
|
HttpMetaData |
Meta data shared between requests and responses.
|
HttpOutputStream |
The OutputStream which provides access to the HTTP
trailers.
|
HttpPayloadWriter<T> |
An interface which mimics behavior like OutputStream , but allows for writing of objects of type
HttpPayloadWriter and provides access to the HTTP trailers.
|
HttpPredicateRouterBuilder |
|
HttpProtocolConfig |
Defines configuration options for HTTP protocol versions.
|
HttpProtocolConfigs |
|
HttpProtocolVersion |
|
HttpReporter |
A Span Reporter that will publish to an HTTP endpoint with a configurable encoding Codec .
|
HttpReporter.Builder |
|
HttpRequest |
An HTTP request.
|
HttpRequester |
Provides a means to make a HTTP request.
|
HttpRequestFactory |
|
HttpRequestMetaData |
Meta data associated with an HTTP request.
|
HttpRequestMetaDataFactory |
|
HttpRequestMethod |
|
HttpRequestMethod.Properties |
|
HttpRequestResponseFactory |
|
HttpRequestUriUtils |
Helper methods for computing effective request URIs according
to RFC 7230, section 5.5
and base URIs (which are effective request URIs with / as path, and no query nor fragment.
|
HttpResponse |
An HTTP response.
|
HttpResponseFactory |
|
HttpResponseMetaData |
Meta data associated with an HTTP response.
|
HttpResponseMetaDataFactory |
|
HttpResponseStatus |
|
HttpResponseStatus.StatusClass |
|
HttpSerializationProvider |
|
HttpSerializationProviders |
|
HttpSerializer<T> |
A factory to address serialization concerns for HTTP request/response payload bodies.
|
HttpServerBuilder |
A builder for building HTTP Servers.
|
HttpServers |
Factory methods for building HTTP Servers backed by ServerContext .
|
HttpServerSecurityConfigurator |
|
HttpService |
|
HttpServiceContext |
|
HttpSetCookie |
|
HttpSetCookie.SameSite |
|
IdleTimeoutInitializer |
Initializes the channel with idle timeout handling.
|
IgnoreConsumedEvent<T> |
|
IllBehavedRequestFilterTest |
|
IllBehavedRequestFilterTest.IllBehavedRequestFilter |
|
IllBehavedRequestFilterTest.TestApplication |
|
IllegalCharacterException |
Exception that clarifies an illegal character and expected values.
|
InMemoryReference |
Represents a reference to another span.
|
InMemoryScopeManager |
A ScopeManager that works with Scope instances.
|
InMemorySpan |
A span that allows reading values at runtime.
|
InMemorySpanBuilder |
A Tracer.SpanBuilder that works with InMemorySpan instances.
|
InMemorySpanContext |
A span that allows reading values at runtime.
|
InMemorySpanEventListener |
Listener for tracing events.
|
InMemorySpanLog |
A entry that corresponds to Span.log(long, String) events.
|
InMemoryTracer |
|
InMemoryTraceState |
Utility for representing a Ziplin-like trace state.
|
InMemoryTraceStateFormat<C> |
|
InputConsumingGlobalFiltersTest |
|
InputConsumingGlobalFiltersTest.TestApplication |
|
InterceptorsTest |
|
InterceptorsTest.TestApplication |
|
InvalidRedirectException |
Throws when redirect could not be performed.
|
IoExecutor |
Executor that handles IO.
|
IoThreadFactory |
Default ThreadFactory to create IO Thread s.
|
JacksonSerializationProvider |
|
JdkFlowAdapters |
A set of adapter methods for converting to and from
JDK Flow
APIs and ServiceTalk APIs.
|
LastHttpMetaData |
An indicator that can be attached to the last chunk of payload to carry
trailer headers.
|
LatestValueSubscriber<T> |
|
LegacyTestCompletable |
Deprecated.
|
LegacyTestSingle<T> |
Deprecated.
|
LimitingConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> |
|
LimitingConnectionFactoryFilter.ConnectionLimiter<ResolvedAddress,C extends ListenableAsyncCloseable> |
|
ListenableAsyncCloseable |
|
LoadBalancedAddress<C extends LoadBalancedConnection> |
|
LoadBalancedConnection |
|
LoadBalancer<C extends LoadBalancedConnection> |
Given multiple SocketAddress es select the most desired SocketAddress to use.
|
LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection> |
|
LoadBalancerReadyEvent |
|
LoggerConfig |
Logger name + level configuration.
|
LoggerStringWriter |
|
LoggingCompletableSubscriber |
|
LoggingPublisherSubscriber<T> |
|
LoggingReporter |
A Simple Reporter that logs the span at INFO level.
|
LoggingSingleSubscriber<T> |
|
LogLevel |
Defines different severity level of logging.
|
Main |
This class implements the
plugin.proto
interface to produce ServiceTalk code corresponding to .proto service definitions.
|
Matchers |
Custom Matcher s specific to http-api.
|
MathUtils |
Internal math utilities.
|
MaxRequestLimitExceededException |
Exception raised when more concurrent requests have been issued on a connection than is allowed.
|
MaxRequestLimitExceededRejectedSubscribeException |
Exception raised when more concurrent requests have been issued on a connection than is allowed.
|
MessageEncodingException |
Exception thrown when a message was encoded with an unsupported encoder.
|
MixedModeResources |
|
MixedModeResourceTest |
|
MixinAwareParametersRunnerFactory |
JUnit supports @Test annotated default methods from v5, this small extension enables it for JUnit 4.
|
MockFlushStrategy |
|
MultiAddressHttpClientBuilder<U,R> |
|
MultiAddressHttpClientFilterFactory<U> |
|
NettyChannelListenableAsyncCloseable |
|
NettyConnection<Read,Write> |
A wrapper over a physical connection providing a way to read/write as a Publisher .
|
NettyConnectionContext |
|
NettyConnectionContext.FlushStrategyProvider |
|
NettyFutureCompletable |
|
NettyIoExecutor |
|
NettyIoExecutors |
|
NettyIoExecutors |
Factory methods to create IoExecutor s using netty as the transport.
|
NettyPipelineSslUtils |
Utilities for ChannelPipeline and SSL/TLS.
|
NettyServerContext |
|
NoAvailableHostException |
Thrown when no host is available but at least one is required.
|
NonResubscribeableCompletableSubscriberFunction |
|
NonResubscribeablePublisherSubscriberFunction<T> |
|
NonResubscribeableSingleSubscriberFunction<T> |
|
NoOffloadsRouteExecutionStrategy |
A special RouteExecutionStrategy that indicates that a resource class or method needs to use a strategy that
does not offload user code using a different thread pool.
|
NoopTransportObserver |
|
NoopTransportObserver.NoopConnectionObserver |
|
NoopTransportObserver.NoopDataObserver |
|
NoopTransportObserver.NoopMultiplexedObserver |
|
NoopTransportObserver.NoopReadObserver |
|
NoopTransportObserver.NoopSecurityHandshakeObserver |
|
NoopTransportObserver.NoopStreamObserver |
|
NoopTransportObserver.NoopWriteObserver |
|
NoopWriteEventsListener |
|
OffloaderAwareExecutor |
|
PartitionAttributes |
Provide a way to describe a partition using a collection of of attributes.
|
PartitionAttributes.Key<T> |
|
PartitionAttributesBuilder |
|
PartitionedHttpClientBuilder<U,R> |
|
PartitionedHttpClientSecurityConfigurator<U,R> |
|
PartitionedServiceDiscovererEvent<ResolvedAddress> |
|
PartitionHttpClientBuilderConfigurator<U,R> |
If different clients used by a partitioned client created by a PartitionedHttpClientBuilder have different
builder configuration, this configurator helps to configure them differently.
|
PartitionMap<T extends AsyncCloseable> |
|
PartitionMapFactory |
|
PayloadWriter<T> |
An interface which mimics behavior like OutputStream , but allows for writing of objects of type
PayloadWriter .
|
PayloadWriterUtils |
|
PlatformDependent |
Provide utilities that are dependent on the current runtime environment.
|
PowerSetPartitionMap<T extends AsyncCloseable> |
|
PowerSetPartitionMapFactory |
|
Processors |
Static factory methods for creating processor instances for different type of sources.
|
ProcessorSignalsConsumer<T> |
|
ProtobufSerializationProvider |
|
ProtoBufSerializationProviderBuilder |
|
ProxyResponseException |
A proxy response exception, that indicates an unexpected response status from a proxy.
|
Publisher<T> |
An asynchronous computation that produces 0, 1 or more elements and may or may not terminate successfully or with
an error.
|
PublisherFirstStep<T> |
Provides the ability to express expectations for the first step in a Subscriber 's lifecycle.
|
PublisherLastStep |
Provides the ability to express expectations for the terminal signals (e.g.
|
PublisherOperator<T,R> |
|
PublisherProcessorSignalsHolder<T> |
|
PublisherSource<T> |
An asynchronous computation that emits zero or more items to its PublisherSource.Subscriber and may or may not terminate
successfully or with an error.
|
PublisherSource.Processor<T,R> |
|
PublisherSource.Subscriber<T> |
A subscriber of result(s) produced by a PublisherSource .
|
PublisherSource.Subscription |
|
PublisherStep<T> |
|
PublisherToSingleOperator<T,R> |
|
QueueFullAndRejectedSubscribeException |
Exception indicating a bounded queue is full, which also resulted in a rejected subscribe.
|
QueueFullException |
Exception indicating a bounded queue is full.
|
RandomDataUtils |
|
ReactiveStreamsAdapters |
A set of adapter methods for converting to and from
Reactive Streams APIs and ServiceTalk APIs.
|
ReadOnlyBufferAllocators |
Utility class containing BufferAllocator s that create Buffer instances which cannot be modified and
are read only.
|
ReadOnlyClientSecurityConfig |
Read-only security config for clients.
|
ReadOnlyServerSecurityConfig |
Read-only security config for servers.
|
ReadOnlyTcpClientConfig |
|
ReadOnlyTcpServerConfig |
|
RedirectingHttpRequesterFilter |
|
ReflectionUtils |
Provide utilities to assist reflective access.
|
RejectedSubscribeError |
Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is
established.
|
RejectedSubscribeException |
Used in scenarios where a subscribe to an asynchronous source is attempted, but no "real" subscription is
established.
|
RepeatStrategies |
|
RepeatStrategies.TerminateRepeatException |
An Exception instance used to indicate termination of repeats.
|
RequestConcurrencyController |
An interface which allows controlling reserving connections which maybe used concurrently.
|
RequestConcurrencyController.Result |
|
RequestConcurrencyControllers |
|
RequestProperties |
Helper methods used internally for accessing ServiceTalk-specific request properties.
|
RequestTargetDecoderHttpServiceFilter |
|
RequestTargetEncoderHttpRequesterFilter |
|
RequestTargetEncoderHttpServiceFilter |
|
ReservableRequestConcurrencyController |
|
ReservableRequestConcurrencyControllers |
|
ReservedBlockingHttpConnection |
|
ReservedBlockingStreamingHttpConnection |
|
ReservedHttpConnection |
|
ReservedStreamingHttpConnection |
|
ReservedStreamingHttpConnectionFilter |
|
RetryableConnectException |
Throws when a connect operations failed.
|
RetryableException |
A marker-interface for exceptions which are safely retryable and occur only before ServiceTalk starts writing a
request to the network.
|
RetryingHttpRequesterFilter |
A filter to enable retries for HTTP requests.
|
RetryingHttpRequesterFilter.Builder |
|
RetryStrategies |
|
RoundRobinLoadBalancer<ResolvedAddress,C extends LoadBalancedConnection> |
A LoadBalancer that uses a round robin strategy for selecting addresses.
|
RoundRobinLoadBalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection> |
|
RouteContinuation |
Methods for continuing a route.
|
RouteExecutionStrategy |
Indicates that a resource class or method needs a specific execution strategy.
|
RouteExecutionStrategyFactory<ES> |
|
RouteExecutionStrategyUtils |
|
RouteStarter |
Methods for starting a route.
|
RunnableCompletable |
|
SamplingStrategies |
Utility methods for sampling strategies.
|
ScalarValueSubscription<T> |
|
ScanWithMapper<T,R> |
|
ScoreSupplier |
Enables components to expose a score.
|
SecurityConfigurator |
An abstraction to configure SSL/TLS.
|
SecurityConfigurator.SslProvider |
The provider to use for SSLEngine .
|
SecurityFilterTest |
|
SecurityFilterTest.TestApplication |
|
SecurityFilterTest.TestSecurityFilter |
|
SequentialCancellable |
|
SequentialCompletableSubscriberFunction |
|
SequentialDnsServerAddressStreamProvider |
|
SequentialPublisherSubscriberFunction<T> |
|
SequentialSingleSubscriberFunction<T> |
|
SerializationException |
Exception indicating an error during serialization or deserialization.
|
SerializationProvider |
A provider of serialization implementation for Serializer .
|
Serializer |
A contract for serialization and deserialization.
|
ServerContext |
Context for servers.
|
ServerSecurityConfig |
Server security configuration.
|
ServerSecurityConfigurator |
|
ServerSecurityConfigurator.ClientAuth |
Indicates the state of the SSLEngine with respect to client authentication.
|
ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> |
Represents the interaction pattern with a service discovery system.
|
ServiceDiscovererEvent<ResolvedAddress> |
Notification from the Service Discovery system that availability for an address has changed.
|
ServiceDiscovererUtils |
|
ServiceDiscovererUtils.TwoIntsConsumer |
Represents an operation that accepts two int -valued arguments and returns no result.
|
ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> |
|
ServiceTalkAutoDiscoverable |
|
ServiceTalkFeature |
Feature enabling ServiceTalk request handling.
|
ServiceTalkJacksonSerializerAutoDiscoverable |
|
ServiceTalkJacksonSerializerFeature |
Feature enabling ServiceTalk Jackson serializer request/response content handling.
|
ServiceTalkSocketOptions |
SocketOption s that can be used beside StandardSocketOptions .
|
ServiceTalkTestTimeout |
Standard timeout shared by test classes.
|
ServiceTalkThreadContextMap |
A ThreadContext that provides storage for MDC based upon AsyncContext .
|
ServiceTalkTracingThreadContextMap |
|
SignalOffloader |
A contract to offload signals to and
from any asynchronous source.
|
SignalOffloaderFactory |
|
SignalOffloaders |
|
Single<T> |
An asynchronous computation that either completes with success giving the result or completes with an error.
|
SingleAddressHttpClientBuilder<U,R> |
A builder of StreamingHttpClient instances which call a single server based on the provided unresolved
address.
|
SingleAddressHttpClientSecurityConfigurator<U,R> |
|
SingleFirstStep<T> |
Provides the ability to express expectations for the first step in a Subscriber 's lifecycle.
|
SingleLastStep<T> |
Provides the ability to express expectations for the terminal signals (e.g.
|
SingleLineFormatter |
Single-line serialization format.
|
SingleLineValue |
Wrapper for supporting injecting and extracting single-string values.
|
SingleOperator<T,R> |
An operator contract for a Single .
|
SingleSource<T> |
An asynchronous computation that either completes with success giving the result or completes with an error.
|
SingleSource.Processor<T,R> |
|
SingleSource.Subscriber<T> |
|
SingleTerminalSignalConsumer<T> |
|
SingletonDnsServerAddressStreamProvider |
|
Slf4jFixedLevelLoggers |
|
SocketOptionUtils |
Utilities to convert SocketOption s.
|
SourceAdapters |
A set of adapter methods to convert an asynchronous source in this module to a corresponding source in
io.servicetalk.concurrent module.
|
SourceWrappers |
When request's contents are not buffered, Jersey's determines if the entity body input stream that backs a request
can be closed by introspecting the return type of the MessageBodyReader .
|
SourceWrappers.PublisherSource<T> |
|
SourceWrappers.SingleSource<T> |
A Single that is also a Source .
|
SplittingFlushStrategy |
A FlushStrategy that splits writes into logical write boundaries and manages flush state across those logical
write boundaries.
|
SplittingFlushStrategy.FlushBoundaryProvider |
|
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary |
|
SslClientChannelInitializer |
|
SslContextFactory |
A factory for creating SslContext s.
|
SslServerChannelInitializer |
|
StacklessClosedChannelException |
ClosedChannelException that will not not fill in the stacktrace but use a cheaper way of producing
limited stacktrace details for the user.
|
StatelessTrailersTransformer<Payload> |
|
StepVerifier |
Provides the ability to verify expectations on asynchronous sources.
|
StrategyInfluencerChainBuilder |
|
StreamingDeserializer<T> |
|
StreamingHttpClient |
|
StreamingHttpClientFilter |
|
StreamingHttpClientFilterFactory |
|
StreamingHttpConnection |
|
StreamingHttpConnectionFilter |
|
StreamingHttpConnectionFilterFactory |
|
StreamingHttpRequest |
|
StreamingHttpRequester |
|
StreamingHttpRequestFactory |
|
StreamingHttpRequestResponseFactory |
|
StreamingHttpRequests |
|
StreamingHttpResponse |
|
StreamingHttpResponseFactory |
|
StreamingHttpResponses |
|
StreamingHttpService |
A service contract for the HTTP protocol.
|
StreamingHttpServiceFilter |
|
StreamingHttpServiceFilterFactory |
|
StreamingSerializer |
A contract capable of serializing a stream of Object s into a stream of Buffer s.
|
StringMultiValueMatcher |
Extends CookieMatcher for things where the value is a string, like headers and query parameters.
|
SubscribableCompletable |
|
SubscribablePublisher<T> |
|
SubscribableSingle<T> |
|
SubscriberUtils |
|
SynchronousResources |
Synchronous (in JAX-RS lingo [1]) resources.
|
SynchronousResourceTest |
|
TcpClient |
A utility to create a TCP clients for tests.
|
TcpClientChannelInitializer |
|
TcpClientConfig |
Configuration for TCP based clients.
|
TcpConnector |
Utility class for TCP clients to connect.
|
TcpServer |
A utility to create a TCP server for tests.
|
TcpServerBinder |
Utility class to start a TCP based server.
|
TcpServerChannelInitializer |
|
TcpServerConfig |
Configuration for TCP based servers.
|
TerminalNotification |
Holder of Throwable .
|
TerminalSignalConsumer |
|
TestCancellable |
|
TestCompletable |
|
TestCompletable.Builder |
|
TestCompletableSubscriber |
|
TestExecutor |
An Executor implementation that provides methods for controlling execution of queued and schedules tasks,
for testing.
|
TestHttpServiceContext |
|
TestIterableToBlockingIterable<T> |
|
TestPojo |
|
TestPublisher<T> |
|
TestPublisher.Builder<T> |
|
TestPublisherSubscriber<T> |
|
TestSingle<T> |
|
TestSingle.Builder<T> |
Allows for creating TestSingle s with non-default settings.
|
TestSingleSubscriber<T> |
|
TestStreamingHttpClient |
|
TestStreamingHttpConnection |
|
TestSubscription |
|
TestUtils |
|
TestUtils.ContentReadException |
|
ThreadInterruptingCancellable |
|
ThrowableUtils |
Utility for creating static Throwable s.
|
TimeoutHttpRequesterFilter |
A filter to enable timeouts for HTTP requests.
|
TracingConstants |
Various constants for tracing.
|
TracingHttpRequesterFilter |
An HTTP filter that supports open tracing.
|
TracingHttpServiceFilter |
|
TrailersTransformer<State,Payload> |
A contract for transforming trailers for a streaming HTTP request/response.
|
TransportObserver |
An observer interface that provides visibility into transport events.
|
TransportObserverConnectionFactoryFilter<ResolvedAddress,C extends ListenableAsyncCloseable> |
|
TransportObservers |
|
TypeHolder<T> |
An abstract class to infer ParameterizedType s for a child class.
|
UdpReporter |
A Span Reporter that will publish to a UDP listener with a configurable encoding Codec .
|
UdpReporter.Builder |
|
UnknownPartitionException |
Thrown when a request is issued but there is no associated partition to send the request to.
|
UserDataLoggerConfig |
LoggerConfig used in areas that can filter logging output to include user data or not.
|
VerificationTestUtils |
|
Verifiers |
|
WireLoggingInitializer |
|
WriteDemandEstimator |
|
WriteDemandEstimators |
|
ZipkinHeaderNames |
|
ZipkinPublisher |
A publisher of Span s to the zipkin transport.
|
ZipkinPublisher.Builder |
|