tracing

Documentation

Index

• func RegisterRequestTracer(requestTracer RequestTracer) error
• type ListenerTracerComponent
• type NoopTracer
  • func (tracer *NoopTracer) RequestSpan(parentContext RequestSpanContext, operationName string) RequestSpan
• type ObserverLabels
  • func NewObserverLabels(vbID uint16, collectionIDs map[uint32]string) *ObserverLabels
• type RequestSpan
• type RequestSpanContext
• type RequestTracer
• type Trace
  • func (t *Trace) Finish()
  • func (t *Trace) RootContext() RequestSpanContext
• type TracerComponent
  • func NewTracerComponent() *TracerComponent
  • func (tc *TracerComponent) NewListenerTracerComponent(opTracerContext RequestSpanContext) ListenerTracerComponent
  • func (tc *TracerComponent) ResponseValueRecord(service, operation string, start time.Time)
  • func (tc *TracerComponent) StartOpTelemeteryHandler(service string, operation string, traceContext RequestSpanContext, ...) *opTelemetryHandler

Functions

func RegisterRequestTracer

func RegisterRequestTracer(requestTracer RequestTracer) error

Types

type ListenerTracerComponent

type ListenerTracerComponent interface {
	InitializeListenerTrace(operationName string, attributes map[string]interface{}) *listenerTracer
	CreateListenerTrace(trace *listenerTracer, operationName string, attributes map[string]interface{}) *listenerTracer
}

type NoopTracer

type NoopTracer struct{}

func (*NoopTracer) RequestSpan

func (tracer *NoopTracer) RequestSpan(parentContext RequestSpanContext, operationName string) RequestSpan

RequestSpan creates a new RequestSpan.

type ObserverLabels

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

func NewObserverLabels

func NewObserverLabels(vbID uint16, collectionIDs map[uint32]string) *ObserverLabels

type RequestSpan

type RequestSpan interface {
	End()
	Context() RequestSpanContext
	AddEvent(name string, timestamp time.Time)

	SetAttribute(key string, value interface{})
}

type RequestSpanContext

type RequestSpanContext struct {
	RefCtx context.Context
	Value  interface{}
}

type RequestTracer

type RequestTracer interface {
	RequestSpan(parentContext RequestSpanContext, operationName string) RequestSpan
}

type Trace

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

func (*Trace) Finish

func (t *Trace) Finish()

func (*Trace) RootContext

func (t *Trace) RootContext() RequestSpanContext

type TracerComponent

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

func NewTracerComponent

func NewTracerComponent() *TracerComponent

func (*TracerComponent) NewListenerTracerComponent

func (tc *TracerComponent) NewListenerTracerComponent(opTracerContext RequestSpanContext) ListenerTracerComponent

func (*TracerComponent) ResponseValueRecord

func (tc *TracerComponent) ResponseValueRecord(service, operation string, start time.Time)

func (*TracerComponent) StartOpTelemeteryHandler

func (tc *TracerComponent) StartOpTelemeteryHandler(
	service string,
	operation string,
	traceContext RequestSpanContext,
	observerLabels *ObserverLabels,
) *opTelemetryHandler