org.twitter.zipkin.storage.cassandra

Class Repository

java.lang.Object

org.twitter.zipkin.storage.cassandra.Repository

All Implemented Interfaces:

java.lang.AutoCloseable

public final class Repository
extends java.lang.Object
implements java.lang.AutoCloseable

Field Summary

Fields

Modifier and Type	Field and Description
static short	BUCKETS
static java.lang.String	KEYSPACE

Constructor Summary

Constructors

Constructor and Description
Repository(java.lang.String keyspace, com.datastax.driver.core.Cluster cluster)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
java.util.List<java.nio.ByteBuffer>	getDependencies(long startDate, long endDate)
java.util.Set<java.lang.String>	getServiceNames()
java.util.Set<java.lang.String>	getSpanNames(java.lang.String serviceName)
java.util.Map<java.lang.Long,java.util.List<java.nio.ByteBuffer>>	getSpansByTraceIds(java.lang.Long[] traceIds, int limit) Get the available trace information from the storage system.
long	getSpanTtlSeconds(long traceId)
java.util.List<java.lang.String>	getTopAnnotations(java.lang.String key)
java.util.Map<java.lang.Long,java.lang.Long>	getTraceDuration(boolean head, long[] traceIds)
java.util.Map<java.lang.Long,java.lang.Long>	getTraceIdsByAnnotation(java.nio.ByteBuffer annotationKey, long from, int limit)
java.util.Map<java.lang.Long,java.lang.Long>	getTraceIdsByServiceName(java.lang.String serviceName, long to, int limit)
java.util.Map<java.lang.Long,java.lang.Long>	getTraceIdsBySpanName(java.lang.String serviceName, java.lang.String spanName, long to, int limit)
void	storeDependencies(long startFlooredToDay, java.nio.ByteBuffer dependencies)
void	storeServiceName(java.lang.String serviceName, int ttl)
void	storeSpan(long traceId, long timestamp, java.lang.String spanName, java.nio.ByteBuffer span, int ttl) Store the span in the underlying storage for later retrieval.
void	storeSpanName(java.lang.String serviceName, java.lang.String spanName, int ttl)
void	storeTopAnnotations(java.lang.String key, java.util.List<java.lang.String> annotations)
void	storeTraceDuration(long traceId, long timestamp, int ttl)
void	storeTraceIdByAnnotation(java.nio.ByteBuffer annotationKey, long timestamp, long traceId, int ttl)
void	storeTraceIdByServiceName(java.lang.String serviceName, long timestamp, long traceId, int ttl)
void	storeTraceIdBySpanName(java.lang.String serviceName, java.lang.String spanName, long timestamp, long traceId, int ttl)
java.util.Set<java.lang.Long>	tracesExist(java.lang.Long[] traceIds)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KEYSPACE

public static final java.lang.String KEYSPACE

See Also:

Constant Field Values

BUCKETS

public static final short BUCKETS

See Also:

Constant Field Values

Constructor Detail

Repository

public Repository(java.lang.String keyspace,
          com.datastax.driver.core.Cluster cluster)

Method Detail

storeSpan

public void storeSpan(long traceId,
             long timestamp,
             java.lang.String spanName,
             java.nio.ByteBuffer span,
             int ttl)

Store the span in the underlying storage for later retrieval.

tracesExist

public java.util.Set<java.lang.Long> tracesExist(java.lang.Long[] traceIds)

getSpansByTraceIds

public java.util.Map<java.lang.Long,java.util.List<java.nio.ByteBuffer>> getSpansByTraceIds(java.lang.Long[] traceIds,
                                                                                   int limit)

Get the available trace information from the storage system. Spans in trace should be sorted by the first annotation timestamp in that span. First event should be first in the spans list. The return list will contain only spans that have been found, thus the return list may not match the provided list of ids.

getSpanTtlSeconds

public long getSpanTtlSeconds(long traceId)

getTopAnnotations

public java.util.List<java.lang.String> getTopAnnotations(java.lang.String key)

storeTopAnnotations

public void storeTopAnnotations(java.lang.String key,
                       java.util.List<java.lang.String> annotations)

storeDependencies

public void storeDependencies(long startFlooredToDay,
                     java.nio.ByteBuffer dependencies)

getDependencies

public java.util.List<java.nio.ByteBuffer> getDependencies(long startDate,
                                                  long endDate)

getServiceNames

public java.util.Set<java.lang.String> getServiceNames()

storeServiceName

public void storeServiceName(java.lang.String serviceName,
                    int ttl)

getSpanNames

public java.util.Set<java.lang.String> getSpanNames(java.lang.String serviceName)

storeSpanName

public void storeSpanName(java.lang.String serviceName,
                 java.lang.String spanName,
                 int ttl)

getTraceIdsByServiceName

public java.util.Map<java.lang.Long,java.lang.Long> getTraceIdsByServiceName(java.lang.String serviceName,
                                                                    long to,
                                                                    int limit)

storeTraceIdByServiceName

public void storeTraceIdByServiceName(java.lang.String serviceName,
                             long timestamp,
                             long traceId,
                             int ttl)

getTraceIdsBySpanName

public java.util.Map<java.lang.Long,java.lang.Long> getTraceIdsBySpanName(java.lang.String serviceName,
                                                                 java.lang.String spanName,
                                                                 long to,
                                                                 int limit)

storeTraceIdBySpanName

public void storeTraceIdBySpanName(java.lang.String serviceName,
                          java.lang.String spanName,
                          long timestamp,
                          long traceId,
                          int ttl)

getTraceIdsByAnnotation

public java.util.Map<java.lang.Long,java.lang.Long> getTraceIdsByAnnotation(java.nio.ByteBuffer annotationKey,
                                                                   long from,
                                                                   int limit)

storeTraceIdByAnnotation

public void storeTraceIdByAnnotation(java.nio.ByteBuffer annotationKey,
                            long timestamp,
                            long traceId,
                            int ttl)

getTraceDuration

public java.util.Map<java.lang.Long,java.lang.Long> getTraceDuration(boolean head,
                                                            long[] traceIds)

storeTraceDuration

public void storeTraceDuration(long traceId,
                      long timestamp,
                      int ttl)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable