io.servicetalk.loadbalancer

Class RoundRobinLoadBalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

java.lang.Object

io.servicetalk.loadbalancer.RoundRobinLoadBalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C>

Type Parameters:

ResolvedAddress - The resolved address type.

C - The type of connection.

All Implemented Interfaces:

LoadBalancerFactory<ResolvedAddress,C>

Enclosing class:

RoundRobinLoadBalancer<ResolvedAddress,C extends LoadBalancedConnection>

public static final class RoundRobinLoadBalancer.RoundRobinLoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>
extends java.lang.Object
implements LoadBalancerFactory<ResolvedAddress,C>

LoadBalancerFactory for RoundRobinLoadBalancer.

Constructor Summary

Constructors

Constructor and Description
RoundRobinLoadBalancerFactory()

Method Summary

Modifier and Type	Method and Description
<T extends C> LoadBalancer<T>	newLoadBalancer(Publisher<? extends ServiceDiscovererEvent<ResolvedAddress>> eventPublisher, ConnectionFactory<ResolvedAddress,T> connectionFactory) Create a new LoadBalancer.

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinLoadBalancerFactory

public RoundRobinLoadBalancerFactory()

Method Detail

newLoadBalancer

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

Description copied from interface: LoadBalancerFactory

Create a new LoadBalancer.

Specified by:

newLoadBalancer in interface LoadBalancerFactory<ResolvedAddress,C extends LoadBalancedConnection>

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.

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