extensions

Documentation

Overview

Package extensions provides implementations of common event extensions.

Index

• Constants
• type DistributedTracingExtension
  • func FromSpanContext(sc trace.SpanContext) DistributedTracingExtension
  • func GetDistributedTracingExtension(event event.Event) (DistributedTracingExtension, bool)
  • func (d DistributedTracingExtension) AddTracingAttributes(e event.EventWriter)
  • func (d *DistributedTracingExtension) ReadTransformer() binding.TransformerFunc
  • func (d DistributedTracingExtension) StartChildSpan(ctx context.Context, name string, opts ...trace.StartOption) (context.Context, *trace.Span)
  • func (d DistributedTracingExtension) ToSpanContext() (trace.SpanContext, error)
  • func (d *DistributedTracingExtension) WriteTransformer() binding.TransformerFunc

Constants

const (
	TraceParentExtension = "traceparent"
	TraceStateExtension  = "tracestate"
)

Types

type DistributedTracingExtension

type DistributedTracingExtension struct {
	TraceParent string `json:"traceparent"`
	TraceState  string `json:"tracestate"`
}

DistributedTracingExtension represents the extension for cloudevents context

func FromSpanContext

func FromSpanContext(sc trace.SpanContext) DistributedTracingExtension

FromSpanContext populates DistributedTracingExtension from a SpanContext.

func GetDistributedTracingExtension

func GetDistributedTracingExtension(event event.Event) (DistributedTracingExtension, bool)

func (DistributedTracingExtension) AddTracingAttributes

func (d DistributedTracingExtension) AddTracingAttributes(e event.EventWriter)

AddTracingAttributes adds the tracing attributes traceparent and tracestate to the cloudevents context

func (*DistributedTracingExtension) ReadTransformer

func (d *DistributedTracingExtension) ReadTransformer() binding.TransformerFunc

func (DistributedTracingExtension) StartChildSpan

func (d DistributedTracingExtension) StartChildSpan(ctx context.Context, name string, opts ...trace.StartOption) (context.Context, *trace.Span)

func (DistributedTracingExtension) ToSpanContext

func (d DistributedTracingExtension) ToSpanContext() (trace.SpanContext, error)

ToSpanContext creates a SpanContext from a DistributedTracingExtension instance.

func (*DistributedTracingExtension) WriteTransformer

func (d *DistributedTracingExtension) WriteTransformer() binding.TransformerFunc