stream

Documentation

Index

• type Broadcast
• type Random
  • func (stream *Random) Configure(conf core.PluginConfig) error
• type RoundRobin
  • func (stream *RoundRobin) Configure(conf core.PluginConfig) error

Types

type Broadcast

type Broadcast struct {
	core.StreamBase
}

Broadcast stream plugin Configuration example

• "stream.Broadcast": Enable: true Stream: "data" Formatter: "format.Envelope" Filter: "filter.All"

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

Stream defines the streams this stream plugin binds to (i.e. the streams affected by this config).

Formatter defines a formatter that is applied to all messages sent to this stream. This can be used to bring different streams to the same format required by a producer formatter. By default this is set to format.Forward.

Filter defines a filter function that removes or allows certain messages to pass through this stream. By default this is set to filter.All.

type Random

type Random struct {
	core.StreamBase
}

Random stream plugin Configuration example

• "stream.Random": Enable: true Stream: "data" Formatter: "format.Envelope" Filter: "filter.All"

Messages will be sent to one of the producers attached to this stream. The producer used is defined randomly.

This stream defines the same fields as stream.Broadcast.

func (*Random) Configure

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

Configure initializes this distributor with values from a plugin config.

type RoundRobin

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

RoundRobin stream plugin Configuration example

• "stream.RoundRobin": Enable: true Stream: "data" Formatter: "format.Envelope" Filter: "filter.All"

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

This stream defines the same fields as stream.Broadcast.

func (*RoundRobin) Configure

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

Configure initializes this distributor with values from a plugin config.