Package org.elasticsearch.client.sniff

Class Sniffer

java.lang.Object

org.elasticsearch.client.sniff.Sniffer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class Sniffer
extends java.lang.Object
implements java.io.Closeable

Class responsible for sniffing nodes from some source (default is elasticsearch itself) and setting them to a provided instance of RestClient. Must be created via SnifferBuilder, which allows to set all of the different options or rely on defaults. A background task fetches the nodes through the HostsSniffer and sets them to the RestClient instance. It is possible to perform sniffing on failure by creating a SniffOnFailureListener and providing it as an argument to RestClientBuilder.setFailureListener(RestClient.FailureListener). The Sniffer implementation needs to be lazily set to the previously created SniffOnFailureListener through SniffOnFailureListener.setSniffer(Sniffer).

Method Summary

Modifier and Type	Method	Description
static SnifferBuilder	builder(RestClient restClient)	Returns a new SnifferBuilder to help with Sniffer creation.
void	close()
void	sniffOnFailure(org.apache.http.HttpHost failedHost)	Triggers a new sniffing round and explicitly takes out the failed host provided as argument

Methods inherited from class java.lang.Object

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

Method Detail

sniffOnFailure

public void sniffOnFailure(org.apache.http.HttpHost failedHost)

Triggers a new sniffing round and explicitly takes out the failed host provided as argument

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

builder

public static SnifferBuilder builder(RestClient restClient)

Returns a new SnifferBuilder to help with Sniffer creation.

Parameters:

restClient - the client that gets its hosts set (via RestClient.setHosts(HttpHost...)) once they are fetched

Returns:

a new instance of SnifferBuilder