store

Documentation

Index

• type Store
  • func NewStore() *Store
  • func (s *Store) DependencyReader() dependencystore.Reader
  • func (s *Store) FindTraceIDs(_ context.Context, query *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (s *Store) FindTraces(_ context.Context, query *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(_ context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s *Store) GetServices(_ context.Context) ([]string, error)
  • func (s *Store) GetTrace(_ context.Context, traceID model.TraceID) (*model.Trace, error)
  • func (s *Store) SpanReader() spanstore.Reader
  • func (s *Store) SpanWriter() spanstore.Writer
  • func (s *Store) WriteDependencies(ts time.Time, dependencies []model.DependencyLink) error
  • func (s *Store) WriteSpan(_ context.Context, span *model.Span) error

Types

type Store

type Store struct{}

func NewStore

func NewStore() *Store

func (*Store) DependencyReader

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

func (*Store) FindTraceIDs

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

func (*Store) FindTraces

func (s *Store) FindTraces(_ context.Context, query *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(_ context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)

func (*Store) GetServices

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

func (*Store) GetTrace

func (s *Store) GetTrace(_ 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

func (*Store) WriteDependencies

func (s *Store) WriteDependencies(ts time.Time, dependencies []model.DependencyLink) error

func (*Store) WriteSpan

func (s *Store) WriteSpan(_ context.Context, span *model.Span) error