Documentation ¶
Index ¶
- func CreateSpanSink(server *veneur.Server, name string, logger *logrus.Entry, config veneur.Config, ...) (sinks.SpanSink, error)
- func MigrateConfig(conf *veneur.Config)
- func ParseSpanConfig(name string, config interface{}) (veneur.SpanSinkConfig, error)
- type LightStepSpanSink
- type LightStepSpanSinkConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateSpanSink ¶ added in v14.2.0
func CreateSpanSink( server *veneur.Server, name string, logger *logrus.Entry, config veneur.Config, sinkConfig veneur.SpanSinkConfig, ) (sinks.SpanSink, error)
NewLightStepSpanSink creates a new instance of a LightStepSpanSink.
func MigrateConfig ¶ added in v14.2.0
TODO(awb): Remove this once the old configuration format has been removed.
func ParseSpanConfig ¶ added in v14.2.0
func ParseSpanConfig( name string, config interface{}, ) (veneur.SpanSinkConfig, error)
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 (*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.
type LightStepSpanSinkConfig ¶ added in v14.2.0
type LightStepSpanSinkConfig struct { AccessToken util.StringSecret `yaml:"lightstep_access_token"` CollectorHost util.Url `yaml:"lightstep_collector_host"` MaximumSpans int `yaml:"lightstep_maximum_spans"` NumClients int `yaml:"lightstep_num_clients"` ReconnectPeriod time.Duration `yaml:"lightstep_reconnect_period"` }
Click to show internal directories.
Click to hide internal directories.