Package org.elasticsearch.test.discovery

Class MockZenPing

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.test.discovery.MockZenPing

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Releasable, ZenPing

public final class MockZenPing
extends AbstractComponent
implements ZenPing

A ZenPing implementation which returns results based on a static in-memory map. This allows pinging to be immediate and can be used to speed up tests.

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.discovery.zen.ZenPing

ZenPing.PingCollection, ZenPing.PingResponse

Field Summary

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor	Description
MockZenPing(Settings settings, PingContextProvider contextProvider)

Method Summary

Modifier and Type	Method	Description
void	close()
void	ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer, TimeValue timeout)
void	start()

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Constructor Detail

MockZenPing

public MockZenPing(Settings settings,
                   PingContextProvider contextProvider)

Method Detail

start

public void start()

Specified by:

start in interface ZenPing

ping

public void ping(java.util.function.Consumer<ZenPing.PingCollection> resultsConsumer,
                 TimeValue timeout)

Specified by:

ping in interface ZenPing

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface Releasable