Package zipkin2.storage.cassandra
Class CassandraStorage
- java.lang.Object
-
- zipkin2.Component
-
- zipkin2.storage.StorageComponent
-
- zipkin2.storage.cassandra.CassandraStorage
-
- All Implemented Interfaces:
Closeable,AutoCloseable
public final class CassandraStorage extends StorageComponent
CQL3 implementation of zipkin storage.Queries are logged to the category "com.datastax.oss.driver.api.core.cql.QueryLogger" when debug or trace is enabled via SLF4J. Trace level includes bound values.
Schema is installed by default from "/zipkin2-schema.cql"
When
StorageComponent.Builder.strictTraceId(boolean)is disabled, span and index data are uniformly written with 64-bit trace ID length. When retrieving data, an extra "trace_id_high" field clarifies if a 128-bit trace ID was sent.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classCassandraStorage.Builderstatic interfaceCassandraStorage.SessionFactory
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AutocompleteTagsautocompleteTags()CheckResultcheck()voidclose()booleanisOverCapacity(Throwable e)static CassandraStorage.BuildernewBuilder()ServiceAndSpanNamesserviceAndSpanNames()SpanConsumerspanConsumer()SpanStorespanStore()Memoized in order to avoid re-preparing statementsStringtoString()Tracestraces()
-
-
-
Method Detail
-
newBuilder
public static CassandraStorage.Builder newBuilder()
-
spanStore
public SpanStore spanStore()
Memoized in order to avoid re-preparing statements- Specified by:
spanStorein classStorageComponent
-
traces
public Traces traces()
- Overrides:
tracesin classStorageComponent
-
serviceAndSpanNames
public ServiceAndSpanNames serviceAndSpanNames()
- Overrides:
serviceAndSpanNamesin classStorageComponent
-
autocompleteTags
public AutocompleteTags autocompleteTags()
- Overrides:
autocompleteTagsin classStorageComponent
-
spanConsumer
public SpanConsumer spanConsumer()
- Specified by:
spanConsumerin classStorageComponent
-
isOverCapacity
public boolean isOverCapacity(Throwable e)
- Overrides:
isOverCapacityin classStorageComponent
-
check
public CheckResult check()
-
-