querysvc

Documentation

Index

• func StandardAdjusters(maxClockSkewAdjust time.Duration) []adjuster.Adjuster
• type MetricsQueryService
• 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) GetCapabilities() StorageCapabilities
  • func (qs QueryService) GetDependencies(ctx context.Context, endTs time.Time, lookback time.Duration) ([]model.DependencyLink, error)
  • func (qs QueryService) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, 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
• type StorageCapabilities

Functions

func StandardAdjusters

func StandardAdjusters(maxClockSkewAdjust time.Duration) []adjuster.Adjuster

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

Types

type MetricsQueryService

type MetricsQueryService interface {
	metricsstore.Reader
}

MetricsQueryService provides a means of querying R.E.D metrics from an underlying metrics store.

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) GetCapabilities

func (qs QueryService) GetCapabilities() StorageCapabilities

GetCapabilities returns the features supported by the query service.

func (QueryService) GetDependencies

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

GetDependencies implements dependencystore.Reader.GetDependencies

func (QueryService) GetOperations

func (qs QueryService) GetOperations(
	ctx context.Context,
	query spanstore.OperationQueryParameters,
) ([]spanstore.Operation, 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.

type StorageCapabilities

type StorageCapabilities struct {
	ArchiveStorage bool `json:"archiveStorage"`
}

StorageCapabilities is a feature flag for query service