querysvc

Documentation

Index

• Variables
• type QueryService
  • func NewQueryService(spanReader spanstore.Reader, dependencyReader dependencystore.Reader, ...) *QueryService
  • func (qs QueryService) Adjust(trace *model.Trace) (*model.Trace, error)
  • func (qs QueryService) ArchiveTrace(ctx context.Context, traceID model.TraceID) error
  • func (qs QueryService) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (qs QueryService) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
  • func (qs QueryService) GetOperations(ctx context.Context, service string) ([]string, error)
  • func (qs QueryService) GetServices(ctx context.Context) ([]string, error)
  • func (qs QueryService) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type QueryServiceOptions
  • func (opts *QueryServiceOptions) InitArchiveStorage(storageFactory storage.Factory, logger *zap.Logger) bool

Variables

var StandardAdjusters = []adjuster.Adjuster{
	adjuster.SpanIDDeduper(),
	adjuster.ClockSkew(),
	adjuster.IPTagAdjuster(),
	adjuster.SortLogFields(),
	adjuster.SpanReferences(),
}

StandardAdjusters is a list of model adjusters applied by the query service before returning the data to the API clients.

Types

type QueryService

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

QueryService contains span utils required by the query-service.

func NewQueryService

func NewQueryService(spanReader spanstore.Reader, dependencyReader dependencystore.Reader, options QueryServiceOptions) *QueryService

NewQueryService returns a new QueryService.

func (QueryService) Adjust

func (qs QueryService) Adjust(trace *model.Trace) (*model.Trace, error)

Adjust applies adjusters to the trace.

func (QueryService) ArchiveTrace

func (qs QueryService) ArchiveTrace(ctx context.Context, traceID model.TraceID) error

ArchiveTrace is the queryService utility to archive traces.

func (QueryService) FindTraces

func (qs QueryService) FindTraces(ctx context.Context, query *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces is the queryService implementation of spanstore.Reader.FindTraces

func (QueryService) GetDependencies

func (qs QueryService) GetDependencies(endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)

GetDependencies implements dependencystore.Reader.GetDependencies

func (QueryService) GetOperations

func (qs QueryService) GetOperations(ctx context.Context, service string) ([]string, error)

GetOperations is the queryService implementation of spanstore.Reader.GetOperations

func (QueryService) GetServices

func (qs QueryService) GetServices(ctx context.Context) ([]string, error)

GetServices is the queryService implementation of spanstore.Reader.GetServices

func (QueryService) GetTrace

func (qs QueryService) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace is the queryService implementation of spanstore.Reader.GetTrace

type QueryServiceOptions

type QueryServiceOptions struct {
	ArchiveSpanReader spanstore.Reader
	ArchiveSpanWriter spanstore.Writer
	Adjuster          adjuster.Adjuster
}

QueryServiceOptions has optional members of QueryService

func (*QueryServiceOptions) InitArchiveStorage

func (opts *QueryServiceOptions) InitArchiveStorage(storageFactory storage.Factory, logger *zap.Logger) bool

InitArchiveStorage tries to initialize archive storage reader/writer if storage factory supports them.