lightstep

package
v13.2.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Sep 1, 2020 License: MIT Imports: 16 Imported by: 8

README

LightStep Sink

This sink sends Veneur spans to LightStep.

Configuration

See the various lightstep_* keys in example.yaml for all available configuration options.

Status

This sink is stable.

Capabilities

Spans

Enabled if lightstep_access_token is set to non-empty value.

The following rules manage how SSF spans and tags are mapped to LightStep spans:

  • The SSF indicator field is converted a tag.
  • The SSF service field is mapped to LightStep's component field.

Collector Distribution

Veneur can create lightstep_num_clients number of connections to LightStep collectors. Veneur will then distribute spans to each of these connections. This is useful if you don't have a appropriate load-balancer for balancing gRPC connections. You can also set the lightstep_reconnect_period to change how often each of these connections reconnect. Using these together can help facilitate an even distribution of spans across collectors.

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LightStepSpanSink

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

LightStepSpanSink is a sink for spans to be sent to the LightStep client.

func NewLightStepSpanSink

func NewLightStepSpanSink(collector string, reconnectPeriod string, maximumSpans int, numClients int, accessToken string, log *logrus.Logger) (*LightStepSpanSink, error)

NewLightStepSpanSink creates a new instance of a LightStepSpanSink.

func (*LightStepSpanSink) Flush

func (ls *LightStepSpanSink) Flush()

Flush doesn't need to do anything to the LS tracer, so we emit metrics instead.

func (*LightStepSpanSink) Ingest

func (ls *LightStepSpanSink) Ingest(ssfSpan *ssf.SSFSpan) error

Ingest takes in a span and passed it along to the LS client after some sanity checks and improvements are made.

func (*LightStepSpanSink) Name

func (ls *LightStepSpanSink) Name() string

Name returns this sink's name.

func (*LightStepSpanSink) Start

func (ls *LightStepSpanSink) Start(cl *trace.Client) error

Start performs final adjustments on the sink.

Jump to

Keyboard shortcuts

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