stream

type Broadcast ¶

type Broadcast struct {
	core.StreamBase
}

Broadcast stream plugin Messages will be sent to all producers attached to this stream.

func (stream *Broadcast) Configure(conf core.PluginConfig) error

type Random ¶

type Random struct {
	core.StreamBase
}

Random stream plugin Messages will be sent to one of the producers attached to this stream. The concrete producer is chosen randomly with each message.

func (stream *Random) Configure(conf core.PluginConfig) error

type RoundRobin ¶

type RoundRobin struct {
	core.StreamBase
	// contains filtered or unexported fields
}

RoundRobin stream plugin Messages will be sent to one of the producers attached to this stream. Producers will be switched one-by-one.

func (stream *RoundRobin) Configure(conf core.PluginConfig) error

type Route ¶ added in v0.4.0

type Route struct {
	core.StreamBase
	// contains filtered or unexported fields
}

Route stream plugin Messages will be routed to all streams configured. Each target stream can hold another stream configuration, too, so this is not directly sending to the producers attached to the target streams. Configuration example

• "stream.Route": Routes:
• "foo"
• "bar"

Routes defines a 1:n stream remapping. Messages are reassigned to all of stream(s) in this list. If no route is set messages are forwarded on the incoming stream. When routing to multiple streams, the incoming stream has to be listed explicitly to be used.

func (stream *Route) Configure(conf core.PluginConfig) error

func (stream *Route) Enqueue(msg core.Message)