zipkin2.elasticsearch

Class ElasticsearchStorage

java.lang.Object

zipkin2.Component

zipkin2.storage.StorageComponent

zipkin2.elasticsearch.ElasticsearchStorage

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class ElasticsearchStorage
extends StorageComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ElasticsearchStorage.Builder
static interface	ElasticsearchStorage.HostsSupplier A list of elasticsearch nodes to connect to, in http://host:port or https://host:port format.

Method Summary

Modifier and Type	Method and Description
CheckResult	check() This is blocking so that we can determine if the cluster is healthy or not
void	clear() This is a blocking call, only used in tests.
void	close()
static void	flush(HttpCall.Factory factory, String index) This is a blocking call, only used in tests.
abstract boolean	flushOnWrites()
abstract ElasticsearchStorage.HostsSupplier	hostsSupplier()
HttpCall.Factory	http()
abstract IndexNameFormatter	indexNameFormatter()
abstract int	maxRequests()
abstract int	namesLookback()
static ElasticsearchStorage.Builder	newBuilder()
static ElasticsearchStorage.Builder	newBuilder(okhttp3.OkHttpClient client)
abstract String	pipeline()
SpanConsumer	spanConsumer()
SpanStore	spanStore()
abstract boolean	strictTraceId()
float	version() Returns the Elasticsearch version of the connected cluster.

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static ElasticsearchStorage.Builder newBuilder(okhttp3.OkHttpClient client)

newBuilder

public static ElasticsearchStorage.Builder newBuilder()

hostsSupplier

public abstract ElasticsearchStorage.HostsSupplier hostsSupplier()

pipeline

@Nullable
public abstract String pipeline()

flushOnWrites

public abstract boolean flushOnWrites()

maxRequests

public abstract int maxRequests()

strictTraceId

public abstract boolean strictTraceId()

indexNameFormatter

public abstract IndexNameFormatter indexNameFormatter()

namesLookback

public abstract int namesLookback()

spanStore

public SpanStore spanStore()

Specified by:

spanStore in class StorageComponent

spanConsumer

public SpanConsumer spanConsumer()

Specified by:

spanConsumer in class StorageComponent

version

public float version()

Returns the Elasticsearch version of the connected cluster. Internal use only

clear

public void clear()
           throws IOException

This is a blocking call, only used in tests.

Throws:

IOException

flush

public static void flush(HttpCall.Factory factory,
                         String index)
                  throws IOException

This is a blocking call, only used in tests.

Throws:

IOException

check

public CheckResult check()

This is blocking so that we can determine if the cluster is healthy or not

Overrides:

check in class Component

http

@Memoized
public HttpCall.Factory http()

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class Component