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 classCassandraStorage.Builder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AutocompleteTagsautocompleteTags()CheckResultcheck()voidclose()booleanisOverCapacity(java.lang.Throwable e)static CassandraStorage.BuildernewBuilder()ServiceAndSpanNamesserviceAndSpanNames()SpanConsumerspanConsumer()Memoized in order to avoid re-preparing statementsSpanStorespanStore()Memoized in order to avoid re-preparing statementsjava.lang.StringtoString()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()
Memoized in order to avoid re-preparing statements- Specified by:
spanConsumerin classStorageComponent
-
isOverCapacity
public boolean isOverCapacity(java.lang.Throwable e)
- Overrides:
isOverCapacityin classStorageComponent
-
toString
public final java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
check
public CheckResult check()
-
-