org.apache.tephra.distributed

Class AbstractClientProvider.RandomEndpointStrategy

java.lang.Object

org.apache.tephra.distributed.AbstractClientProvider.RandomEndpointStrategy

All Implemented Interfaces:

AbstractClientProvider.EndpointStrategy

Enclosing class:

AbstractClientProvider

public final class AbstractClientProvider.RandomEndpointStrategy
extends Object
implements AbstractClientProvider.EndpointStrategy

Randomly picks endpoint from the list of available endpoints.

Constructor Summary

Constructors

Constructor and Description
AbstractClientProvider.RandomEndpointStrategy(Iterable<org.apache.twill.discovery.Discoverable> endpoints) Constructs a random endpoint strategy.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.twill.discovery.Discoverable	pick() Picks a Discoverable using its strategy.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractClientProvider.RandomEndpointStrategy

public AbstractClientProvider.RandomEndpointStrategy(Iterable<org.apache.twill.discovery.Discoverable> endpoints)

Constructs a random endpoint strategy.

Parameters:

endpoints - Endpoints for the strategy to use. Note that this strategy will invoke Iterable.iterator() and traverse through it on every call to the pick() method. One could leverage this behavior with the live Iterable as provided by DiscoveryServiceClient.discover(String) method.

Method Detail

pick

public org.apache.twill.discovery.Discoverable pick()

Description copied from interface: AbstractClientProvider.EndpointStrategy

Picks a Discoverable using its strategy.

Specified by:

pick in interface AbstractClientProvider.EndpointStrategy

Returns:

A Discoverable based on the stragegy or null if no endpoint can be found.