demultiplexer

Documentation

Index

• type Demultiplexer
  • func (streamer *Demultiplexer) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (streamer *Demultiplexer) AddEvents(ctx context.Context, points []*event.Event) error

Types

type Demultiplexer

type Demultiplexer struct {
	DatapointSinks []dpsink.DSink
	EventSinks     []dpsink.ESink
}

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, points []*event.Event) error

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