Package zipkin2.storage.cassandra.v1
Class CassandraStorage
- java.lang.Object
- 
- zipkin2.Component
- 
- zipkin2.storage.StorageComponent
- 
- zipkin2.storage.cassandra.v1.CassandraStorage
 
 
 
- 
- All Implemented Interfaces:
- Closeable,- 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 SummaryNested Classes Modifier and Type Class Description static classCassandraStorage.Builder
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AutocompleteTagsautocompleteTags()CheckResultcheck()voidclose()booleanisOverCapacity(Throwable e)static CassandraStorage.BuildernewBuilder()ServiceAndSpanNamesserviceAndSpanNames()SpanConsumerspanConsumer()Memoized in order to avoid re-preparing statementsSpanStorespanStore()Memoized in order to avoid re-preparing statementsStringtoString()Tracestraces()
 
- 
- 
- 
Method Detail- 
newBuilderpublic static CassandraStorage.Builder newBuilder() 
 - 
spanStorepublic SpanStore spanStore() Memoized in order to avoid re-preparing statements- Specified by:
- spanStorein class- StorageComponent
 
 - 
tracespublic Traces traces() - Overrides:
- tracesin class- StorageComponent
 
 - 
serviceAndSpanNamespublic ServiceAndSpanNames serviceAndSpanNames() - Overrides:
- serviceAndSpanNamesin class- StorageComponent
 
 - 
autocompleteTagspublic AutocompleteTags autocompleteTags() - Overrides:
- autocompleteTagsin class- StorageComponent
 
 - 
spanConsumerpublic SpanConsumer spanConsumer() Memoized in order to avoid re-preparing statements- Specified by:
- spanConsumerin class- StorageComponent
 
 - 
isOverCapacitypublic boolean isOverCapacity(Throwable e) - Overrides:
- isOverCapacityin class- StorageComponent
 
 - 
checkpublic CheckResult check() 
 
- 
 
-