observation

Documentation

Index

• Variables
• func DoTag(cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) map[string]string
• func DoTagFaster(dst []byte, cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) []byte
• func DoTraceTag(cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) map[string]interface{}
• func NewTracer(serviceName, host string, ratio float64) (opentracing.Tracer, error)
• type AttributeConfiguration
• type Configure
  • func (c *Configure) Do(ctx *context.Context, ed *cb.EventData) (cntL, cntT, cntM int)
  • func (c *Configure) Prepare(ctx *context.Context, ed *cb.EventData)
• type LoggingConfigure
  • func (c *LoggingConfigure) Do(ed *cb.EventData) int
• type MetricsConfigure
  • func (c *MetricsConfigure) Do(ed *cb.EventData) int
• type StackTraceConfigure
  • func (c *StackTraceConfigure) Do()
• type TimestampConfigure
  • func (c *TimestampConfigure) Do()
• type TracingConfigure
  • func (c *TracingConfigure) Do(ctx *context.Context, ed *cb.EventData) int

Variables

var MetricVecStore = &metricVecStore{
	counters:   map[int64]*counterVecWrap{},
	gauges:     map[int64]*gaugeVecWrap{},
	histograms: map[int64]*histogramVecWrap{},
	summaries:  map[int64]*summaryVecWrap{},
}

var ObserveHelper = &observeHelper{}

var PrometheusPusher = push.New(prometheusFakeGateway.URL, "test")

Functions

func DoTag

func DoTag(cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) map[string]string

func DoTagFaster

func DoTagFaster(dst []byte, cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) []byte

func DoTraceTag

func DoTraceTag(cfg []*cb.AttributeConfigure, er *cb.EventRepresentation) map[string]interface{}

func NewTracer

func NewTracer(serviceName, host string, ratio float64) (opentracing.Tracer, error)

NewTracer returns a newly configured tracer

Types

type AttributeConfiguration

type AttributeConfiguration cb.AttributeConfigure

type Configure

type Configure cb.ObservationConfigure

func (*Configure) Do

func (c *Configure) Do(ctx *context.Context, ed *cb.EventData) (cntL, cntT, cntM int)

Do function returns number of log, trace span and metric entries

func (*Configure) Prepare

func (c *Configure) Prepare(ctx *context.Context, ed *cb.EventData)

Prepare pre-allocate SpanID

type LoggingConfigure

type LoggingConfigure cb.LoggingConfigure

func (*LoggingConfigure) Do

func (c *LoggingConfigure) Do(ed *cb.EventData) int

type MetricsConfigure

type MetricsConfigure cb.MetricsConfigure

func (*MetricsConfigure) Do

func (c *MetricsConfigure) Do(ed *cb.EventData) int

type StackTraceConfigure

type StackTraceConfigure cb.StackTraceConfigure

func (*StackTraceConfigure) Do

func (c *StackTraceConfigure) Do()

type TimestampConfigure

type TimestampConfigure cb.TimestampConfigure

func (*TimestampConfigure) Do

func (c *TimestampConfigure) Do()

type TracingConfigure

type TracingConfigure cb.TracingConfigure

func (*TracingConfigure) Do

func (c *TracingConfigure) Do(ctx *context.Context, ed *cb.EventData) int