Package zipkin2.storage.cassandra.v1
Class CassandraStorage
- java.lang.Object
-
- zipkin2.Component
-
- zipkin2.storage.StorageComponent
-
- zipkin2.storage.cassandra.v1.CassandraStorage
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public 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.
Redundant requests to store service or span names are ignored for an hour to reduce load. This feature is implemented by
DeduplicatingVoidCallFactory
.Schema is installed by default from "/cassandra-schema.cql"
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CassandraStorage.Builder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AutocompleteTags
autocompleteTags()
CheckResult
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()
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()
Memoized in order to avoid re-preparing statements- Specified by:
spanConsumer
in classStorageComponent
-
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
-
check
public CheckResult check()
-
-