store

Documentation

Index

• type SpanReader
  • func NewSpanReader(logger hclog.Logger, spanRepository *repository.SpanRepository, ...) *SpanReader
  • func (s *SpanReader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]jModel.TraceID, error)
  • func (s *SpanReader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*jModel.Trace, error)
  • func (s *SpanReader) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]jModel.DependencyLink, error)
  • func (s *SpanReader) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (s *SpanReader) GetServices(ctx context.Context) ([]string, error)
  • func (s *SpanReader) GetTrace(ctx context.Context, traceID jModel.TraceID) (*jModel.Trace, error)
• type SpanWriter
  • func NewSpanWriter(logger hclog.Logger, spanRepository *repository.SpanRepository, ...) *SpanWriter
  • func (s *SpanWriter) WriteSpan(ctx context.Context, span *jModel.Span) error

Types

type SpanReader

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

func NewSpanReader

func NewSpanReader(logger hclog.Logger, spanRepository *repository.SpanRepository, serviceRepository *repository.OperationRepository) *SpanReader

func (*SpanReader) FindTraceIDs

func (s *SpanReader) FindTraceIDs(ctx context.Context, query *spanstore.TraceQueryParameters) ([]jModel.TraceID, error)

func (*SpanReader) FindTraces

func (s *SpanReader) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*jModel.Trace, error)

func (*SpanReader) GetDependencies

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

func (*SpanReader) GetOperations

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

func (*SpanReader) GetServices

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

func (*SpanReader) GetTrace

func (s *SpanReader) GetTrace(ctx context.Context, traceID jModel.TraceID) (*jModel.Trace, error)

type SpanWriter

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

func NewSpanWriter

func NewSpanWriter(logger hclog.Logger, spanRepository *repository.SpanRepository, serviceRepository *repository.OperationRepository) *SpanWriter

func (*SpanWriter) WriteSpan

func (s *SpanWriter) WriteSpan(ctx context.Context, span *jModel.Span) error