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.

func (*Demultiplexer) Datapoints

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

Datapoints adheres to the sfxclient.Collector interface