store

Documentation

Index

• type SQLTraceQuery
  • func (q *SQLTraceQuery) BuildTraceIDQuery() string
  • func (q *SQLTraceQuery) DurationMax(durationMax time.Duration) *SQLTraceQuery
  • func (q *SQLTraceQuery) DurationMin(durationMin time.Duration) *SQLTraceQuery
  • func (q *SQLTraceQuery) NumTraces(numTraces int) *SQLTraceQuery
  • func (q *SQLTraceQuery) OperationName(operationName string) *SQLTraceQuery
  • func (q *SQLTraceQuery) ServiceName(serviceName string) *SQLTraceQuery
  • func (q *SQLTraceQuery) StartTimeMax(startTimeMax time.Time) *SQLTraceQuery
  • func (q *SQLTraceQuery) StartTimeMin(startTimeMin time.Time) *SQLTraceQuery
  • func (q *SQLTraceQuery) Tag(k, v string) *SQLTraceQuery
• type Store
  • func NewStore(conf *config.Configuration, logger hclog.Logger) (*Store, error)
  • func (s *Store) DependencyReader() dependencystore.Reader
  • func (s *Store) FindTraceIDs(ctx context.Context, traceQueryParameters *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (s *Store) FindTraces(ctx context.Context, traceQueryParameters *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (s *Store) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
  • func (s *Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s *Store) GetServices(ctx context.Context) ([]string, error)
  • func (s *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
  • func (s *Store) SpanReader() spanstore.Reader
  • func (s *Store) SpanWriter() spanstore.Writer

Types

type SQLTraceQuery

type SQLTraceQuery struct {
	// contains filtered or unexported fields
}

SQLTraceQuery abstracts an SQL query for spans

func (*SQLTraceQuery) BuildTraceIDQuery

func (q *SQLTraceQuery) BuildTraceIDQuery() string

BuildTraceIDQuery builds an SQL query that returns Trace IDs.

func (*SQLTraceQuery) DurationMax

func (q *SQLTraceQuery) DurationMax(durationMax time.Duration) *SQLTraceQuery

DurationMax sets the query max duration threshold.

func (*SQLTraceQuery) DurationMin

func (q *SQLTraceQuery) DurationMin(durationMin time.Duration) *SQLTraceQuery

DurationMin sets the query min duration threshold.

func (*SQLTraceQuery) NumTraces

func (q *SQLTraceQuery) NumTraces(numTraces int) *SQLTraceQuery

NumTraces sets the query max traces threshold.

func (*SQLTraceQuery) OperationName

func (q *SQLTraceQuery) OperationName(operationName string) *SQLTraceQuery

OperationName sets the query operation name.

func (*SQLTraceQuery) ServiceName

func (q *SQLTraceQuery) ServiceName(serviceName string) *SQLTraceQuery

ServiceName sets the query service name.

func (*SQLTraceQuery) StartTimeMax

func (q *SQLTraceQuery) StartTimeMax(startTimeMax time.Time) *SQLTraceQuery

StartTimeMax sets the max start time to query.

func (*SQLTraceQuery) StartTimeMin

func (q *SQLTraceQuery) StartTimeMin(startTimeMin time.Time) *SQLTraceQuery

StartTimeMin sets the min start time to query.

func (*SQLTraceQuery) Tag

func (q *SQLTraceQuery) Tag(k, v string) *SQLTraceQuery

Tag adds a query tag key:value pair.

type Store

type Store struct {
	// contains filtered or unexported fields
}

func NewStore

func NewStore(conf *config.Configuration, logger hclog.Logger) (*Store, error)

func (*Store) DependencyReader

func (s *Store) DependencyReader() dependencystore.Reader

func (*Store) FindTraceIDs

func (s *Store) FindTraceIDs(ctx context.Context, traceQueryParameters *spanstore.TraceQueryParameters) ([]model.TraceID, error)

func (*Store) FindTraces

func (s *Store) FindTraces(ctx context.Context, traceQueryParameters *spanstore.TraceQueryParameters) ([]*model.Trace, error)

func (*Store) GetDependencies

func (s *Store) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

func (*Store) GetOperations

func (s *Store) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

func (*Store) GetServices

func (s *Store) GetServices(ctx context.Context) ([]string, error)

func (*Store) GetTrace

func (s *Store) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

func (*Store) SpanReader

func (s *Store) SpanReader() spanstore.Reader

func (*Store) SpanWriter

func (s *Store) SpanWriter() spanstore.Writer