Package zipkin2.storage.cassandra
Class CassandraStorage
- java.lang.Object
-
- zipkin2.Component
-
- zipkin2.storage.StorageComponent
-
- zipkin2.storage.cassandra.CassandraStorage
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public abstract class CassandraStorage extends StorageComponent
CQL3 implementation of zipkin storage.Queries are logged to the category "com.datastax.driver.core.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()
Memoized in order to avoid re-preparing statementsCheckResult
check()
void
close()
boolean
isOverCapacity(java.lang.Throwable e)
static CassandraStorage.Builder
newBuilder()
ServiceAndSpanNames
serviceAndSpanNames()
SpanConsumer
spanConsumer()
Memoized in order to avoid re-preparing statementsSpanStore
spanStore()
Memoized in order to avoid re-preparing statementsjava.lang.String
toString()
-
-
-
Method Detail
-
newBuilder
public static CassandraStorage.Builder newBuilder()
-
spanStore
@Memoized public SpanStore spanStore()
Memoized in order to avoid re-preparing statements- Specified by:
spanStore
in classStorageComponent
-
serviceAndSpanNames
public ServiceAndSpanNames serviceAndSpanNames()
- Overrides:
serviceAndSpanNames
in classStorageComponent
-
autocompleteTags
@Memoized public AutocompleteTags autocompleteTags()
Memoized in order to avoid re-preparing statements- Overrides:
autocompleteTags
in classStorageComponent
-
spanConsumer
@Memoized public SpanConsumer spanConsumer()
Memoized in order to avoid re-preparing statements- Specified by:
spanConsumer
in classStorageComponent
-
check
public CheckResult check()
-
isOverCapacity
public boolean isOverCapacity(java.lang.Throwable e)
- Overrides:
isOverCapacity
in classStorageComponent
-
toString
public final java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-