Package org.elasticsearch.discovery

Class SeedHostsResolver

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.discovery.SeedHostsResolver

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, PeerFinder.ConfiguredHostsResolver

public class SeedHostsResolver
extends AbstractLifecycleComponent
implements PeerFinder.ConfiguredHostsResolver

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<java.lang.Integer>	DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING
static Setting<org.elasticsearch.common.unit.TimeValue>	DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING
static Setting<java.lang.Integer>	LEGACY_DISCOVERY_ZEN_PING_UNICAST_CONCURRENT_CONNECTS_SETTING
static Setting<org.elasticsearch.common.unit.TimeValue>	LEGACY_DISCOVERY_ZEN_PING_UNICAST_HOSTS_RESOLVE_TIMEOUT

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Constructor Summary

Constructors

Constructor	Description
SeedHostsResolver(java.lang.String nodeName, Settings settings, TransportService transportService, SeedHostsProvider seedProvider)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
protected void	doStart()
protected void	doStop()
static int	getMaxConcurrentResolvers(Settings settings)
static org.elasticsearch.common.unit.TimeValue	getResolveTimeout(Settings settings)
void	resolveConfiguredHosts(java.util.function.Consumer<java.util.List<TransportAddress>> consumer)	Attempt to resolve the configured unicast hosts list to a list of transport addresses.
static java.util.List<TransportAddress>	resolveHostsLists(CancellableThreads cancellableThreads, java.util.concurrent.ExecutorService executorService, org.apache.logging.log4j.Logger logger, java.util.List<java.lang.String> hosts, TransportService transportService, org.elasticsearch.common.unit.TimeValue resolveTimeout)	Resolves a list of hosts to a list of transport addresses.

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

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

Field Details

LEGACY_DISCOVERY_ZEN_PING_UNICAST_CONCURRENT_CONNECTS_SETTING

public static final Setting<java.lang.Integer> LEGACY_DISCOVERY_ZEN_PING_UNICAST_CONCURRENT_CONNECTS_SETTING

LEGACY_DISCOVERY_ZEN_PING_UNICAST_HOSTS_RESOLVE_TIMEOUT

public static final Setting<org.elasticsearch.common.unit.TimeValue> LEGACY_DISCOVERY_ZEN_PING_UNICAST_HOSTS_RESOLVE_TIMEOUT

DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING

public static final Setting<java.lang.Integer> DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING

DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING

public static final Setting<org.elasticsearch.common.unit.TimeValue> DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING

Constructor Details

SeedHostsResolver

public SeedHostsResolver(java.lang.String nodeName,
Settings settings,
TransportService transportService,
SeedHostsProvider seedProvider)

Method Details

getMaxConcurrentResolvers

public static int getMaxConcurrentResolvers(Settings settings)

getResolveTimeout

public static org.elasticsearch.common.unit.TimeValue getResolveTimeout(Settings settings)

resolveHostsLists

public static java.util.List<TransportAddress> resolveHostsLists(CancellableThreads cancellableThreads,
java.util.concurrent.ExecutorService executorService,
org.apache.logging.log4j.Logger logger,
java.util.List<java.lang.String> hosts,
TransportService transportService,
org.elasticsearch.common.unit.TimeValue resolveTimeout)

Resolves a list of hosts to a list of transport addresses. Each host is resolved into a transport address (or a collection of addresses if the number of ports is greater than one). Host lookups are done in parallel using specified executor service up to the specified resolve timeout.

Parameters:

executorService - the executor service used to parallelize hostname lookups

logger - logger used for logging messages regarding hostname lookups

hosts - the hosts to resolve

transportService - the transport service

resolveTimeout - the timeout before returning from hostname lookups

Returns:

a list of resolved transport addresses

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class AbstractLifecycleComponent

resolveConfiguredHosts

public void resolveConfiguredHosts(java.util.function.Consumer<java.util.List<TransportAddress>> consumer)

Description copied from interface: PeerFinder.ConfiguredHostsResolver

Attempt to resolve the configured unicast hosts list to a list of transport addresses.

Specified by:

resolveConfiguredHosts in interface PeerFinder.ConfiguredHostsResolver

Parameters:

consumer - Consumer for the resolved list. May not be called if an error occurs or if another resolution attempt is in progress.