io.servicetalk.http.api

Interface HttpLoadBalancerFactory<ResolvedAddress>

Type Parameters:

ResolvedAddress - The type of address after resolution.

All Superinterfaces:

LoadBalancerFactory<ResolvedAddress,FilterableStreamingHttpLoadBalancedConnection>

All Known Implementing Classes:

DefaultHttpLoadBalancerFactory

public interface HttpLoadBalancerFactory<ResolvedAddress>
extends LoadBalancerFactory<ResolvedAddress,FilterableStreamingHttpLoadBalancedConnection>

A LoadBalancerFactory for HTTP clients.

Method Summary

Modifier and Type	Method and Description
<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.

Method Detail

newLoadBalancer

<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 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

FilterableStreamingHttpLoadBalancedConnection toLoadBalancedConnection(FilterableStreamingHttpConnection connection)

Converts the passed FilterableStreamingHttpConnection to a FilterableStreamingHttpLoadBalancedConnection.

Parameters:

connection - FilterableStreamingHttpConnection to convert.

Returns:

FilterableStreamingHttpLoadBalancedConnection for the passed FilterableStreamingHttpConnection.