tracing

Documentation

Index

• func ConvertEventToHttpHeader(message *event.Event) http.Header
• func ConvertNatsMsgToEvent(logger *zap.Logger, msg *nats.Msg) *event.Event
• func ConvertNatssMsgToEvent(logger *zap.Logger, msg *stan.Msg) *event.Event
• func ParseSpanContext(message *event.Event) (sc trace.SpanContext, ok bool)
• func SerializeTraceTransformers(spanContext trace.SpanContext) []binding.Transformer
• func StartTraceFromMessage(logger *zap.Logger, inCtx context.Context, message *event.Event, ...) (context.Context, *trace.Span)

Functions

func ConvertEventToHttpHeader

func ConvertEventToHttpHeader(message *event.Event) http.Header

func ConvertNatsMsgToEvent

func ConvertNatsMsgToEvent(logger *zap.Logger, msg *nats.Msg) *event.Event

func ConvertNatssMsgToEvent

func ConvertNatssMsgToEvent(logger *zap.Logger, msg *stan.Msg) *event.Event

func ParseSpanContext

func ParseSpanContext(message *event.Event) (sc trace.SpanContext, ok bool)

func SerializeTraceTransformers

func SerializeTraceTransformers(spanContext trace.SpanContext) []binding.Transformer

func StartTraceFromMessage

func StartTraceFromMessage(logger *zap.Logger, inCtx context.Context, message *event.Event, spanName string) (context.Context, *trace.Span)