utils

Documentation

Index

• func AddNewTagKey(views []*view.View, key *tag.Key) []*view.View
• func AddTagKeyToCtx(ctx context.Context, key tag.Key, value string) context.Context
• func BinaryFromSpanContext(sc trace.SpanContext) []byte
• func GetTraceSamplingRate(rate string) float64
• func IsTracingEnabled(rate string) bool
• func NewMeasureView(measure stats.Measure, keys []tag.Key, aggregation *view.Aggregation) *view.View
• func SpanContextFromBinary(b []byte) (sc trace.SpanContext, ok bool)
• func SpanFromContext(ctx context.Context) trace.Span
• func SpanToFastHTTPContext(ctx *fasthttp.RequestCtx, span trace.Span)
• func TraceSampler(samplingRate string) sdktrace.Sampler
• func WithTags(opts ...interface{}) []tag.Mutator
• type StdoutExporter
  • func NewStdOutExporter() *StdoutExporter
  • func (e *StdoutExporter) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error
  • func (e *StdoutExporter) Shutdown(ctx context.Context) error

Functions

func AddNewTagKey

func AddNewTagKey(views []*view.View, key *tag.Key) []*view.View

AddNewTagKey adds new tag keys to existing view.

func AddTagKeyToCtx

func AddTagKeyToCtx(ctx context.Context, key tag.Key, value string) context.Context

AddTagKeyToCtx assigns opencensus tag key value to context.

func BinaryFromSpanContext

func BinaryFromSpanContext(sc trace.SpanContext) []byte

BinaryFromSpanContext returns the binary format representation of a SpanContext.

If sc is the zero value, Binary returns nil.

func GetTraceSamplingRate

func GetTraceSamplingRate(rate string) float64

GetTraceSamplingRate parses the given rate and returns the parsed rate.

func IsTracingEnabled

func IsTracingEnabled(rate string) bool

IsTracingEnabled parses the given rate and returns false if sampling rate is explicitly set 0.

func NewMeasureView

func NewMeasureView(measure stats.Measure, keys []tag.Key, aggregation *view.Aggregation) *view.View

NewMeasureView creates opencensus View instance using stats.Measure.

func SpanContextFromBinary

func SpanContextFromBinary(b []byte) (sc trace.SpanContext, ok bool)

SpanContextFromBinary returns the SpanContext represented by b.

If b has an unsupported version ID or contains no TraceID, SpanContextFromBinary returns with ok==false.

func SpanFromContext

func SpanFromContext(ctx context.Context) trace.Span

SpanFromContext returns the SpanContext stored in a context, or nil or trace.nooSpan{} if there isn't one. - TODO

func SpanToFastHTTPContext

func SpanToFastHTTPContext(ctx *fasthttp.RequestCtx, span trace.Span)

SpanToFastHTTPContext sets span into fasthttp.RequestCtx.

func TraceSampler

func TraceSampler(samplingRate string) sdktrace.Sampler

TraceSampler returns Probability Sampler option.

func WithTags

func WithTags(opts ...interface{}) []tag.Mutator

WithTags converts tag key and value pairs to tag.Mutator array. WithTags(key1, value1, key2, value2) returns []tag.Mutator{tag.Upsert(key1, value1), tag.Upsert(key2, value2)}.

Types

type StdoutExporter

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

StdoutExporter implements an open telemetry span exporter that writes to stdout.

func NewStdOutExporter

func NewStdOutExporter() *StdoutExporter

NewStdOutExporter returns a StdOutExporter

func (*StdoutExporter) ExportSpans

func (e *StdoutExporter) ExportSpans(ctx context.Context, spans []sdktrace.ReadOnlySpan) error

ExportSpans implements the open telemetry span exporter interface.

func (*StdoutExporter) Shutdown

func (e *StdoutExporter) Shutdown(ctx context.Context) error

Shutdown implements the open telemetry span exporter interface.