Package io.servicetalk.http.api

Class DelegatingPartitionedHttpClientBuilder<U,R>

java.lang.Object

io.servicetalk.http.api.DelegatingPartitionedHttpClientBuilder<U,R>

Type Parameters:

U - the type of address before resolution (unresolved address)

R - the type of address after resolution (resolved address)

All Implemented Interfaces:

PartitionedHttpClientBuilder<U,R>

public class DelegatingPartitionedHttpClientBuilder<U,R>
extends Object
implements PartitionedHttpClientBuilder<U,R>

A PartitionedHttpClientBuilder that delegates all methods to another PartitionedHttpClientBuilder.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.http.api.PartitionedHttpClientBuilder

PartitionedHttpClientBuilder.SingleAddressInitializer<U,R>

Constructor Summary

Constructors

Constructor	Description
DelegatingPartitionedHttpClientBuilder(PartitionedHttpClientBuilder<U,R> delegate)	Create a new instance.

Method Summary

Modifier and Type	Method	Description
PartitionedHttpClientBuilder<U,R>	bufferAllocator(BufferAllocator allocator)
HttpClient	build()
BlockingHttpClient	buildBlocking()
BlockingStreamingHttpClient	buildBlockingStreaming()
StreamingHttpClient	buildStreaming()
protected final PartitionedHttpClientBuilder<U,R>	delegate()	Returns the PartitionedHttpClientBuilder delegate.
PartitionedHttpClientBuilder<U,R>	executionStrategy(HttpExecutionStrategy strategy)
PartitionedHttpClientBuilder<U,R>	executor(Executor executor)
PartitionedHttpClientBuilder<U,R>	headersFactory(HttpHeadersFactory headersFactory)	Sets the HttpHeadersFactory to be used for creating HttpHeaders for new requests.
PartitionedHttpClientBuilder<U,R>	initializer(PartitionedHttpClientBuilder.SingleAddressInitializer<U,R> initializer)	Set a function which can customize options for each StreamingHttpClient that is built.
PartitionedHttpClientBuilder<U,R>	ioExecutor(IoExecutor ioExecutor)
PartitionedHttpClientBuilder<U,R>	partitionMapFactory(PartitionMapFactory partitionMapFactory)	Sets PartitionMapFactory to use by all StreamingHttpClients created by this builder.
PartitionedHttpClientBuilder<U,R>	retryServiceDiscoveryErrors(BiIntFunction<Throwable,? extends Completable> retryStrategy)	Sets a retry strategy to retry errors emitted by ServiceDiscoverer.
PartitionedHttpClientBuilder<U,R>	serviceDiscoverer(ServiceDiscoverer<U,R,PartitionedServiceDiscovererEvent<R>> serviceDiscoverer)	Sets a ServiceDiscoverer to resolve addresses of remote servers to connect to.
PartitionedHttpClientBuilder<U,R>	serviceDiscoveryMaxQueueSize(int serviceDiscoveryMaxQueueSize)	Sets the maximum amount of ServiceDiscovererEvent objects that will be queued for each partition.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DelegatingPartitionedHttpClientBuilder

public DelegatingPartitionedHttpClientBuilder(PartitionedHttpClientBuilder<U,R> delegate)

Create a new instance.

Parameters:

delegate - PartitionedHttpClientBuilder to which all methods are delegated.

Method Details

delegate

protected final PartitionedHttpClientBuilder<U,R> delegate()

Returns the PartitionedHttpClientBuilder delegate.

Returns:

Delegate PartitionedHttpClientBuilder.

toString

public String toString()

Overrides:

toString in class Object

ioExecutor

public PartitionedHttpClientBuilder<U,R> ioExecutor(IoExecutor ioExecutor)

Specified by:

ioExecutor in interface PartitionedHttpClientBuilder<U,R>

executor

public PartitionedHttpClientBuilder<U,R> executor(Executor executor)

Specified by:

executor in interface PartitionedHttpClientBuilder<U,R>

executionStrategy

public PartitionedHttpClientBuilder<U,R> executionStrategy(HttpExecutionStrategy strategy)

Specified by:

executionStrategy in interface PartitionedHttpClientBuilder<U,R>

bufferAllocator

public PartitionedHttpClientBuilder<U,R> bufferAllocator(BufferAllocator allocator)

Specified by:

bufferAllocator in interface PartitionedHttpClientBuilder<U,R>

headersFactory

public PartitionedHttpClientBuilder<U,R> headersFactory(HttpHeadersFactory headersFactory)

Description copied from interface: PartitionedHttpClientBuilder

Sets the HttpHeadersFactory to be used for creating HttpHeaders for new requests.

Specified by:

headersFactory in interface PartitionedHttpClientBuilder<U,R>

Parameters:

headersFactory - HttpHeadersFactory to be used for creating HttpHeaders for new requests

Returns:

this

serviceDiscoverer

public PartitionedHttpClientBuilder<U,R> serviceDiscoverer(ServiceDiscoverer<U,R,PartitionedServiceDiscovererEvent<R>> serviceDiscoverer)

Description copied from interface: PartitionedHttpClientBuilder

Sets a ServiceDiscoverer to resolve addresses of remote servers to connect to.

Specified by:

serviceDiscoverer in interface PartitionedHttpClientBuilder<U,R>

Parameters:

serviceDiscoverer - The ServiceDiscoverer to resolve addresses of remote servers to connect to. Lifecycle of the provided ServiceDiscoverer is managed externally and it should be closed after all built StreamingHttpClients will be closed and this ServiceDiscoverer is no longer needed.

Returns:

this.

retryServiceDiscoveryErrors

public PartitionedHttpClientBuilder<U,R> retryServiceDiscoveryErrors(BiIntFunction<Throwable,? extends Completable> retryStrategy)

Description copied from interface: PartitionedHttpClientBuilder

Sets a retry strategy to retry errors emitted by ServiceDiscoverer.

Specified by:

retryServiceDiscoveryErrors in interface PartitionedHttpClientBuilder<U,R>

Parameters:

retryStrategy - a retry strategy to retry errors emitted by ServiceDiscoverer.

Returns:

this.

See Also:

• RetryStrategies

serviceDiscoveryMaxQueueSize

public PartitionedHttpClientBuilder<U,R> serviceDiscoveryMaxQueueSize(int serviceDiscoveryMaxQueueSize)

Description copied from interface: PartitionedHttpClientBuilder

Sets the maximum amount of ServiceDiscovererEvent objects that will be queued for each partition.

It is assumed that the PublisherSource.Subscribers will process events in a timely manner (typically synchronously) so this typically doesn't need to be very large.

Specified by:

serviceDiscoveryMaxQueueSize in interface PartitionedHttpClientBuilder<U,R>

Parameters:

serviceDiscoveryMaxQueueSize - the maximum amount of ServiceDiscovererEvent objects that will be queued for each partition.

Returns:

this.

partitionMapFactory

public PartitionedHttpClientBuilder<U,R> partitionMapFactory(PartitionMapFactory partitionMapFactory)

Description copied from interface: PartitionedHttpClientBuilder

Sets PartitionMapFactory to use by all StreamingHttpClients created by this builder.

Specified by:

partitionMapFactory in interface PartitionedHttpClientBuilder<U,R>

Parameters:

partitionMapFactory - PartitionMapFactory to use.

Returns:

this.

initializer

public PartitionedHttpClientBuilder<U,R> initializer(PartitionedHttpClientBuilder.SingleAddressInitializer<U,R> initializer)

Description copied from interface: PartitionedHttpClientBuilder

Set a function which can customize options for each StreamingHttpClient that is built.

Specified by:

initializer in interface PartitionedHttpClientBuilder<U,R>

Parameters:

initializer - Initializes the SingleAddressHttpClientBuilder used to build new StreamingHttpClients.

Returns:

this

build

public HttpClient build()

buildStreaming

public StreamingHttpClient buildStreaming()

buildBlocking

public BlockingHttpClient buildBlocking()

buildBlockingStreaming

public BlockingStreamingHttpClient buildBlockingStreaming()