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 class
CassandraStorage.Builder
static interface
CassandraStorage.SessionFactory
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AutocompleteTags
autocompleteTags()
CheckResult
check()
void
close()
boolean
isOverCapacity(Throwable e)
static CassandraStorage.Builder
newBuilder()
ServiceAndSpanNames
serviceAndSpanNames()
SpanConsumer
spanConsumer()
SpanStore
spanStore()
Memoized in order to avoid re-preparing statementsString
toString()
Traces
traces()
-
-
-
Method Detail
-
newBuilder
public static CassandraStorage.Builder newBuilder()
-
spanStore
public SpanStore spanStore()
Memoized in order to avoid re-preparing statements- Specified by:
spanStore
in classStorageComponent
-
traces
public Traces traces()
- Overrides:
traces
in classStorageComponent
-
serviceAndSpanNames
public ServiceAndSpanNames serviceAndSpanNames()
- Overrides:
serviceAndSpanNames
in classStorageComponent
-
autocompleteTags
public AutocompleteTags autocompleteTags()
- Overrides:
autocompleteTags
in classStorageComponent
-
spanConsumer
public SpanConsumer spanConsumer()
- Specified by:
spanConsumer
in classStorageComponent
-
isOverCapacity
public boolean isOverCapacity(Throwable e)
- Overrides:
isOverCapacity
in classStorageComponent
-
check
public CheckResult check()
-
-