Versions in this module Expand all Collapse all v1 v1.66.0 Feb 6, 2025 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 + func NewOperationNamesStorage(session cassandra.Session, writeCacheTTL time.Duration, ...) (*OperationNamesStorage, error) + func (s *OperationNamesStorage) GetOperations(query spanstore.OperationQueryParameters) ([]spanstore.Operation, error) + func (s *OperationNamesStorage) Write(operation dbmodel.Operation) 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, error) + 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(_ context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error) + func (s *SpanReader) GetServices(context.Context) ([]string, error) + func (s *SpanReader) GetTrace(ctx context.Context, query spanstore.GetTraceParameters) (*model.Trace, error) + type SpanWriter struct + func NewSpanWriter(session cassandra.Session, writeCacheTTL time.Duration, ...) (*SpanWriter, error) + func (s *SpanWriter) Close() error + func (s *SpanWriter) WriteSpan(_ context.Context, span *model.Span) error
Go to main page