demultiplexer

Documentation

Index

• type Demultiplexer
  • func (streamer *Demultiplexer) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (streamer *Demultiplexer) AddEvents(ctx context.Context, events []*event.Event) error
  • func (streamer *Demultiplexer) AddSpans(ctx context.Context, spans []*trace.Span) error
  • func (streamer *Demultiplexer) Datapoints() []*datapoint.Datapoint

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