collect

Documentation

Index

• Constants
• Variables
• type Collector
  • func GetCollectorImplementation(c config.Config) Collector
• type InMemCollector
  • func (i *InMemCollector) AddSpan(sp *types.Span) error
  • func (i *InMemCollector) AddSpanFromPeer(sp *types.Span) error
  • func (i *InMemCollector) Start() error
  • func (i *InMemCollector) Stop() error

Constants

const (
	TraceSendGotRoot        = "trace_send_got_root"
	TraceSendExpired        = "trace_send_expired"
	TraceSendEjectedFull    = "trace_send_ejected_full"
	TraceSendEjectedMemsize = "trace_send_ejected_memsize"
)

These are the names of the metrics we use to track our send decisions.

Variables

var ErrWouldBlock = errors.New("not adding span, channel buffer is full")

var Threshold float64

Types

type Collector

type Collector interface {
	// AddSpan adds a span to be collected, buffered, and merged in to a trace.
	// Once the trace is "complete", it'll be passed off to the sampler then
	// scheduled for transmission.
	AddSpan(*types.Span) error
	AddSpanFromPeer(*types.Span) error
}

func GetCollectorImplementation

func GetCollectorImplementation(c config.Config) Collector

type InMemCollector

type InMemCollector struct {
	Config         config.Config          `inject:""`
	Logger         logger.Logger          `inject:""`
	Transmission   transmit.Transmission  `inject:"upstreamTransmission"`
	Metrics        metrics.Metrics        `inject:"metrics"`
	SamplerFactory *sample.SamplerFactory `inject:""`

	// For test use only
	BlockOnAddSpan bool
	// contains filtered or unexported fields
}

InMemCollector is a single threaded collector.

func (*InMemCollector) AddSpan

func (i *InMemCollector) AddSpan(sp *types.Span) error

AddSpan accepts the incoming span to a queue and returns immediately

func (*InMemCollector) AddSpanFromPeer

func (i *InMemCollector) AddSpanFromPeer(sp *types.Span) error

AddSpan accepts the incoming span to a queue and returns immediately

func (*InMemCollector) Start

func (i *InMemCollector) Start() error

func (*InMemCollector) Stop

func (i *InMemCollector) Stop() error