utils

Documentation

Index

• func AddNewTagKey(views []*view.View, key *tag.Key) []*view.View
• func BinaryFromSpanContext(sc trace.SpanContext) []byte
• func CreateRulesMap(rules []config.MetricsRule) error
• 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 WithTags(name string, 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 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 CreateRulesMap

func CreateRulesMap(rules []config.MetricsRule) error

CreateRulesMap generates a fast lookup map for metrics regex.

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 WithTags

func WithTags(name string, 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.