metrics

Documentation

Index

• type ReadMetricsDecorator
  • func NewReadMetricsDecorator(spanReader spanstore.Reader, metricsFactory metrics.Factory) *ReadMetricsDecorator
  • func (m *ReadMetricsDecorator) FindTraceIDs(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]model.TraceID, error)
  • func (m *ReadMetricsDecorator) FindTraces(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error)
  • func (m *ReadMetricsDecorator) GetOperations(ctx context.Context, query spanstore.OperationQueryParameters) ([]spanstore.Operation, error)
  • func (m *ReadMetricsDecorator) GetServices(ctx context.Context) ([]string, error)
  • func (m *ReadMetricsDecorator) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)
• type WriteMetrics
  • func NewWriteMetrics(factory metrics.Factory, tableName string) *WriteMetrics
  • func (t *WriteMetrics) Emit(err error, latency time.Duration)

Types

type ReadMetricsDecorator

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

ReadMetricsDecorator wraps a spanstore.Reader and collects metrics around each read operation.

func NewReadMetricsDecorator

func NewReadMetricsDecorator(spanReader spanstore.Reader, metricsFactory metrics.Factory) *ReadMetricsDecorator

NewReadMetricsDecorator returns a new ReadMetricsDecorator.

func (*ReadMetricsDecorator) FindTraceIDs

func (m *ReadMetricsDecorator) FindTraceIDs(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]model.TraceID, error)

FindTraceIDs implements spanstore.Reader#FindTraceIDs

func (*ReadMetricsDecorator) FindTraces

func (m *ReadMetricsDecorator) FindTraces(ctx context.Context, traceQuery *spanstore.TraceQueryParameters) ([]*model.Trace, error)

FindTraces implements spanstore.Reader#FindTraces

func (*ReadMetricsDecorator) GetOperations

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

GetOperations implements spanstore.Reader#GetOperations

func (*ReadMetricsDecorator) GetServices

func (m *ReadMetricsDecorator) GetServices(ctx context.Context) ([]string, error)

GetServices implements spanstore.Reader#GetServices

func (*ReadMetricsDecorator) GetTrace

func (m *ReadMetricsDecorator) GetTrace(ctx context.Context, traceID model.TraceID) (*model.Trace, error)

GetTrace implements spanstore.Reader#GetTrace

type WriteMetrics

type WriteMetrics struct {
	Attempts   metrics.Counter `metric:"attempts"`
	Inserts    metrics.Counter `metric:"inserts"`
	Errors     metrics.Counter `metric:"errors"`
	LatencyOk  metrics.Timer   `metric:"latency-ok"`
	LatencyErr metrics.Timer   `metric:"latency-err"`
}

WriteMetrics is a collection of metrics for write operations.

func NewWriteMetrics

func NewWriteMetrics(factory metrics.Factory, tableName string) *WriteMetrics

NewWriteMetrics takes a metrics scope and creates a metrics struct

func (*WriteMetrics) Emit

func (t *WriteMetrics) Emit(err error, latency time.Duration)

Emit will record success or failure counts and latency metrics depending on the passed error.