public class ZenPingService extends AbstractLifecycleComponent<ZenPing> implements ZenPing
ZenPing.PingCollection, ZenPing.PingListener, ZenPing.PingResponse
lifecycle
componentSettings, logger, settings
Constructor and Description |
---|
ZenPingService(Settings settings,
ThreadPool threadPool,
TransportService transportService,
ClusterName clusterName,
NetworkService networkService,
ElectMasterService electMasterService,
Set<UnicastHostsProvider> unicastHostsProviders) |
ZenPingService(Settings settings,
ThreadPool threadPool,
TransportService transportService,
ClusterName clusterName,
NetworkService networkService,
Version version,
ElectMasterService electMasterService,
Set<UnicastHostsProvider> unicastHostsProviders) |
Modifier and Type | Method and Description |
---|---|
protected void |
doClose() |
protected void |
doStart() |
protected void |
doStop() |
void |
ping(ZenPing.PingListener listener,
TimeValue timeout) |
ZenPing.PingResponse[] |
pingAndWait(TimeValue timeout) |
void |
setPingContextProvider(PingContextProvider contextProvider) |
com.google.common.collect.ImmutableList<? extends ZenPing> |
zenPings() |
void |
zenPings(com.google.common.collect.ImmutableList<? extends ZenPing> pings) |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop
nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
close
public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService, ElectMasterService electMasterService, @Nullable Set<UnicastHostsProvider> unicastHostsProviders)
@Inject public ZenPingService(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterName clusterName, NetworkService networkService, Version version, ElectMasterService electMasterService, @Nullable Set<UnicastHostsProvider> unicastHostsProviders)
public com.google.common.collect.ImmutableList<? extends ZenPing> zenPings()
public void zenPings(com.google.common.collect.ImmutableList<? extends ZenPing> pings)
public void setPingContextProvider(PingContextProvider contextProvider)
setPingContextProvider
in interface ZenPing
protected void doStart() throws ElasticsearchException
doStart
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
protected void doStop() throws ElasticsearchException
doStop
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
protected void doClose() throws ElasticsearchException
doClose
in class AbstractLifecycleComponent<ZenPing>
ElasticsearchException
public ZenPing.PingResponse[] pingAndWait(TimeValue timeout)
public void ping(ZenPing.PingListener listener, TimeValue timeout) throws ElasticsearchException
ping
in interface ZenPing
ElasticsearchException
Copyright © 2009–2015. All rights reserved.