sinks

Documentation

Index

• type CompositeSink
  • func (cs *CompositeSink) Add(s Sink)
  • func (cs *CompositeSink) Send(spans []*types.Span) error
  • func (cs *CompositeSink) Start() error
  • func (cs *CompositeSink) Stop() error
• type HoneycombSink
  • func (hs *HoneycombSink) Send(spans []*types.Span) error
  • func (hs *HoneycombSink) Start() error
  • func (hs *HoneycombSink) Stop() error
• type Sink
• type StdoutSink
  • func (s *StdoutSink) Send(spans []*types.Span) error
  • func (s *StdoutSink) Start() error
  • func (s *StdoutSink) Stop() error

Types

type CompositeSink

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

CompositeSink is an implementation of Sink that sends spans to each provided individual sink.

func (*CompositeSink) Add

func (cs *CompositeSink) Add(s Sink)

func (*CompositeSink) Send

func (cs *CompositeSink) Send(spans []*types.Span) error

func (*CompositeSink) Start

func (cs *CompositeSink) Start() error

func (*CompositeSink) Stop

func (cs *CompositeSink) Stop() error

type HoneycombSink

type HoneycombSink struct {
	Writekey   string
	Dataset    string
	APIHost    string
	SampleRate uint
	DropFields []string
	// contains filtered or unexported fields
}

HoneycombSink implements the Sink interface. It sends spans to the Honeycomb API.

func (*HoneycombSink) Send

func (hs *HoneycombSink) Send(spans []*types.Span) error

func (*HoneycombSink) Start

func (hs *HoneycombSink) Start() error

func (*HoneycombSink) Stop

func (hs *HoneycombSink) Stop() error

type Sink

type Sink interface {
	Send([]*types.Span) error
	startstop.Starter
	startstop.Stopper
}

Sink is the interface for doing something with Spans, e.g. sending them to Honeycomb or writing them to stdout.

type StdoutSink

type StdoutSink struct{}

StdoutSink implements the Sink interface. It writes span data to stdout.

func (*StdoutSink) Send

func (s *StdoutSink) Send(spans []*types.Span) error

func (*StdoutSink) Start

func (s *StdoutSink) Start() error

func (*StdoutSink) Stop

func (s *StdoutSink) Stop() error