Package io.servicetalk.http.netty

Class DefaultHttpLoadBalancerFactory<ResolvedAddress>

java.lang.Object

io.servicetalk.http.netty.DefaultHttpLoadBalancerFactory<ResolvedAddress>

Type Parameters:

ResolvedAddress - The type of address after resolution.

All Implemented Interfaces:

LoadBalancerFactory<ResolvedAddress,FilterableStreamingHttpLoadBalancedConnection>, HttpExecutionStrategyInfluencer, HttpLoadBalancerFactory<ResolvedAddress>

public final class DefaultHttpLoadBalancerFactory<ResolvedAddress>
extends java.lang.Object
implements HttpLoadBalancerFactory<ResolvedAddress>, HttpExecutionStrategyInfluencer

Default implementation of HttpLoadBalancerFactory.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultHttpLoadBalancerFactory.Builder<ResolvedAddress>	A builder for creating instances of DefaultHttpLoadBalancerFactory.

Method Summary

Modifier and Type	Method	Description
HttpExecutionStrategy	influenceStrategy(HttpExecutionStrategy strategy)	Optionally modify the passed HttpExecutionStrategy to a new HttpExecutionStrategy that suits this HttpExecutionStrategyInfluencer.
<T extends FilterableStreamingHttpLoadBalancedConnection> LoadBalancer<T>	newLoadBalancer(Publisher<? extends ServiceDiscovererEvent<ResolvedAddress>> eventPublisher, ConnectionFactory<ResolvedAddress,T> cf)	Create a new LoadBalancer.
FilterableStreamingHttpLoadBalancedConnection	toLoadBalancedConnection(FilterableStreamingHttpConnection connection)	Converts the passed FilterableStreamingHttpConnection to a FilterableStreamingHttpLoadBalancedConnection.

Methods inherited from class java.lang.Object

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

Method Detail

newLoadBalancer

public <T extends FilterableStreamingHttpLoadBalancedConnection> LoadBalancer<T> newLoadBalancer(Publisher<? extends ServiceDiscovererEvent<ResolvedAddress>> eventPublisher,
                                                                                                 ConnectionFactory<ResolvedAddress,T> cf)

Description copied from interface: LoadBalancerFactory

Create a new LoadBalancer.

Specified by:

newLoadBalancer in interface HttpLoadBalancerFactory<ResolvedAddress>

Specified by:

newLoadBalancer in interface LoadBalancerFactory<ResolvedAddress,FilterableStreamingHttpLoadBalancedConnection>

Type Parameters:

T - Type of connections created by the passed ConnectionFactory.

Parameters:

eventPublisher - A stream of ServiceDiscovererEvents which the LoadBalancer can use to connect to physical hosts. Typically generated from a ServiceDiscoverer.

cf - ConnectionFactory that the returned LoadBalancer will use to generate new connections. Returned LoadBalancer will own the responsibility for this ConnectionFactory and hence will call AsyncCloseable.closeAsync() when AsyncCloseable.closeAsync() is called.

Returns:

a new LoadBalancer.

toLoadBalancedConnection

public FilterableStreamingHttpLoadBalancedConnection toLoadBalancedConnection(FilterableStreamingHttpConnection connection)

Description copied from interface: HttpLoadBalancerFactory

Converts the passed FilterableStreamingHttpConnection to a FilterableStreamingHttpLoadBalancedConnection.

Specified by:

toLoadBalancedConnection in interface HttpLoadBalancerFactory<ResolvedAddress>

Parameters:

connection - FilterableStreamingHttpConnection to convert.

Returns:

FilterableStreamingHttpLoadBalancedConnection for the passed FilterableStreamingHttpConnection.

influenceStrategy

public HttpExecutionStrategy influenceStrategy(HttpExecutionStrategy strategy)

Description copied from interface: HttpExecutionStrategyInfluencer

Optionally modify the passed HttpExecutionStrategy to a new HttpExecutionStrategy that suits this HttpExecutionStrategyInfluencer.

Specified by:

influenceStrategy in interface HttpExecutionStrategyInfluencer

Parameters:

strategy - HttpExecutionStrategy to influence.

Returns:

HttpExecutionStrategy that suits this HttpExecutionStrategyInfluencer