demultiplexer

Documentation

Index

• type Demultiplexer
  • func New(sendTo []dpsink.Sink) *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 {
	// contains filtered or unexported fields
}

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

func New

func New(sendTo []dpsink.Sink) *Demultiplexer

New creates a new forwarder that sends datapoints to multiple recievers

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.