sinks

package
v2.1.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 3, 2020 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL