telemetry

Documentation

Index

• func HeaderFromContext(ctx context.Context) nats.Header
• func NATSHeaderToOTLP(header nats.Header) propagation.HeaderCarrier
• func NewMeterNoopProvider(res *resource.Resource) *metric.MeterProvider
• func NewMetergRPCProvider(ctx context.Context, res *resource.Resource) *metric.MeterProvider
• func NewPropagator() propagation.TextMapPropagator
• func NewResource(serviceName, serviceVersion string) *resource.Resource
• func NewTraceNoopProvider(res *resource.Resource) *trace.TracerProvider
• func NewTracegRPCProvider(ctx context.Context, res *resource.Resource) *trace.TracerProvider
• func OTLPHeaderToNATS(header propagation.HeaderCarrier) nats.Header
• func SetupOtelSDK(ctx context.Context, res *resource.Resource, log logr.Logger) func(context.Context) error
• func TracedHandler(ctx context.Context, handler func(ctx context.Context, req micro.Request)) micro.Handler
• func TracedMsg(ctx context.Context, subject string, data []byte) *nats.Msg

Functions

func HeaderFromContext

func HeaderFromContext(ctx context.Context) nats.Header

func NATSHeaderToOTLP

func NATSHeaderToOTLP(header nats.Header) propagation.HeaderCarrier

func NewMeterNoopProvider

func NewMeterNoopProvider(res *resource.Resource) *metric.MeterProvider

func NewMetergRPCProvider

func NewMetergRPCProvider(ctx context.Context, res *resource.Resource) *metric.MeterProvider

func NewPropagator

func NewPropagator() propagation.TextMapPropagator

func NewResource

func NewResource(serviceName, serviceVersion string) *resource.Resource

func NewTraceNoopProvider

func NewTraceNoopProvider(res *resource.Resource) *trace.TracerProvider

func NewTracegRPCProvider

func NewTracegRPCProvider(ctx context.Context, res *resource.Resource) *trace.TracerProvider

func OTLPHeaderToNATS

func OTLPHeaderToNATS(header propagation.HeaderCarrier) nats.Header

func SetupOtelSDK

func SetupOtelSDK(ctx context.Context, res *resource.Resource, log logr.Logger) func(context.Context) error

func TracedHandler

func TracedHandler(ctx context.Context, handler func(ctx context.Context, req micro.Request)) micro.Handler

func TracedMsg

func TracedMsg(ctx context.Context, subject string, data []byte) *nats.Msg