Class SeedHostsResolver

All Implemented Interfaces:
Closeable, AutoCloseable, LifecycleComponent, Releasable, ConfiguredHostsResolver

public class SeedHostsResolver extends AbstractLifecycleComponent implements ConfiguredHostsResolver
  • Field Details

    • LEGACY_DISCOVERY_ZEN_PING_UNICAST_CONCURRENT_CONNECTS_SETTING

      public static final Setting<Integer> LEGACY_DISCOVERY_ZEN_PING_UNICAST_CONCURRENT_CONNECTS_SETTING
    • LEGACY_DISCOVERY_ZEN_PING_UNICAST_HOSTS_RESOLVE_TIMEOUT

      public static final Setting<TimeValue> LEGACY_DISCOVERY_ZEN_PING_UNICAST_HOSTS_RESOLVE_TIMEOUT
    • 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<TimeValue> DISCOVERY_SEED_RESOLVER_TIMEOUT_SETTING
  • Constructor Details

  • Method Details

    • getMaxConcurrentResolvers

      public static int getMaxConcurrentResolvers(Settings settings)
    • getResolveTimeout

      public static TimeValue getResolveTimeout(Settings settings)
    • resolveHostsLists

      public static List<TransportAddress> resolveHostsLists(CancellableThreads cancellableThreads, ExecutorService executorService, org.apache.logging.log4j.Logger logger, List<String> hosts, TransportService transportService, 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(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.