Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + var ErrDurationAndTagQueryNotSupported = errors.New("Cannot query for duration and tags simultaneously") + var ErrDurationMinGreaterThanMax = errors.New("Duration Minimum is above Maximum") + var ErrMalformedRequestObject = errors.New("Malformed request object") + var ErrServiceNameNotSet = errors.New("Service Name must be set") + var ErrStartAndEndTimeNotSet = errors.New("Start and End Time must be set") + var ErrStartTimeMinGreaterThanMax = errors.New("Start Time Minimum is above Maximum") + type OperationNamesStorage struct + InsertStmt string + QueryStmt string + func NewOperationNamesStorage(session cassandra.Session, writeCacheTTL time.Duration, ...) *OperationNamesStorage + func (s *OperationNamesStorage) GetOperations(service string) ([]string, error) + func (s *OperationNamesStorage) Write(serviceName string, operationName string) error + type Option func(c *Options) + func IndexFilter(indexFilter dbmodel.IndexFilter) Option + func StoreIndexesOnly() Option + func StoreWithoutIndexing() Option + func TagFilter(tagFilter dbmodel.TagFilter) Option + type Options struct + type ServiceNamesStorage struct + InsertStmt string + QueryStmt string + func NewServiceNamesStorage(session cassandra.Session, writeCacheTTL time.Duration, ...) *ServiceNamesStorage + func (s *ServiceNamesStorage) GetServices() ([]string, error) + func (s *ServiceNamesStorage) Write(serviceName string) error + type SpanReader struct + func NewSpanReader(session cassandra.Session, metricsFactory metrics.Factory, logger *zap.Logger) *SpanReader + func (s *SpanReader) FindTraceIDs(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]model.TraceID, error) + func (s *SpanReader) FindTraces(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error) + func (s *SpanReader) GetOperations(ctx context.Context, service string) ([]string, error) + func (s *SpanReader) GetServices(ctx context.Context) ([]string, error) + func (s *SpanReader) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error) + type SpanWriter struct + func NewSpanWriter(session cassandra.Session, writeCacheTTL time.Duration, ...) *SpanWriter + func (s *SpanWriter) Close() error + func (s *SpanWriter) WriteSpan(span *model.Span) error
Go to main page