demultiplexer

package
Version: v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Sep 3, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Demultiplexer

type Demultiplexer struct {
	DatapointSinks []dpsink.DSink
	EventSinks     []dpsink.ESink
	TraceSinks     []trace.Sink
	Logger         log.Logger
	LateDuration   *time.Duration
	FutureDuration *time.Duration
	// contains filtered or unexported fields
}

Demultiplexer is a sink that forwards points it sees to multiple sinks

func (*Demultiplexer) AddDatapoints

func (streamer *Demultiplexer) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints forwards all points to each sendTo sink. Returns the error message of the last sink to have an error.

func (*Demultiplexer) AddEvents

func (streamer *Demultiplexer) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents forwards all events to each sendTo sink. Returns the error message of the last sink to have an error.

func (*Demultiplexer) AddSpans

func (streamer *Demultiplexer) AddSpans(ctx context.Context, spans []*trace.Span) error

AddSpans forwards all traces to each sentTo sink. Returns the error of the last sink to have an error. to avoid conflicts with adding tags in forwarders, each span needs to be a copy to avoid concurrent modification issues

func (*Demultiplexer) Datapoints

func (streamer *Demultiplexer) Datapoints() []*datapoint.Datapoint

Datapoints adheres to the sfxclient.Collector interface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL