Package org.elasticsearch.discovery

Class SeedHostsResolver

java.lang.Object

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.discovery.SeedHostsResolver

All Implemented Interfaces:

Closeable, AutoCloseable, LifecycleComponent, org.elasticsearch.core.Releasable, ConfiguredHostsResolver, SeedHostsProvider.HostsResolver

public class SeedHostsResolver
extends AbstractLifecycleComponent
implements ConfiguredHostsResolver, SeedHostsProvider.HostsResolver

Field Summary

Fields

Modifier and Type	Field	Description
static final Setting<Integer>	DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING
static final Setting<org.elasticsearch.core.TimeValue>	DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING

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

lifecycle

Constructor Summary

Constructors

Constructor	Description
SeedHostsResolver(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.core.TimeValue	getResolveTimeout(Settings settings)
void	resolveConfiguredHosts(Consumer<List<TransportAddress>> consumer)	Attempt to resolve the configured hosts list to a list of transport addresses.
List<TransportAddress>	resolveHosts(List<String> hosts)

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

DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING

public static final Setting<Integer> DISCOVERY_SEED_RESOLVER_MAX_CONCURRENT_RESOLVERS_SETTING

DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING

public static final Setting<org.elasticsearch.core.TimeValue> DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING

Constructor Details

SeedHostsResolver

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

Method Details

getMaxConcurrentResolvers

public static int getMaxConcurrentResolvers(Settings settings)

getResolveTimeout

public static org.elasticsearch.core.TimeValue getResolveTimeout(Settings settings)

resolveHosts

public List<TransportAddress> resolveHosts(List<String> hosts)

Specified by:

resolveHosts in interface SeedHostsProvider.HostsResolver

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(Consumer<List<TransportAddress>> consumer)

Description copied from interface: ConfiguredHostsResolver

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

Specified by:

resolveConfiguredHosts in interface ConfiguredHostsResolver

Parameters:

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