handler

Documentation

Index

• Variables
• type SpanForStorage
• type TraceHandler
  • func NewTraceHandler(config *config.OtlpConfig, factory stores.StoreFactory) (*TraceHandler, error)
  • func (th *TraceHandler) EvalAndStoreZkSpan()
  • func (th *TraceHandler) GetBulkDataFromBadgerForPrefix(prefixList []string) (*zkUtilsOtel.BadgerResponseList, error)
  • func (th *TraceHandler) ProcessTraceData(resourceSpans []*tracev1.ResourceSpans)
  • func (th *TraceHandler) PushDataToRedis()
  • func (th *TraceHandler) ServeHTTP(ctx iris.Context)

Variables

var DefaultNodeJsSchemaUrl = "https://opentelemetry.io/schemas/1.7.0"

Types

type SpanForStorage

type SpanForStorage interface {
	zkUtilsEnrichedSpan.OtelEnrichedRawSpan | model.OTelSpanDetails
}

type TraceHandler

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

func NewTraceHandler

func NewTraceHandler(config *config.OtlpConfig, factory stores.StoreFactory) (*TraceHandler, error)

func (*TraceHandler) EvalAndStoreZkSpan

func (th *TraceHandler) EvalAndStoreZkSpan()

func (*TraceHandler) GetBulkDataFromBadgerForPrefix

func (th *TraceHandler) GetBulkDataFromBadgerForPrefix(prefixList []string) (*zkUtilsOtel.BadgerResponseList, error)

func (*TraceHandler) ProcessTraceData

func (th *TraceHandler) ProcessTraceData(resourceSpans []*tracev1.ResourceSpans)

func (*TraceHandler) PushDataToRedis

func (th *TraceHandler) PushDataToRedis()

func (*TraceHandler) ServeHTTP

func (th *TraceHandler) ServeHTTP(ctx iris.Context)