Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broadcast ¶
type Broadcast struct {
core.StreamBase
}
Broadcast stream plugin Messages will be sent to all producers attached to this stream.
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.
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 (*RoundRobin) Configure ¶
func (stream *RoundRobin) Configure(conf core.PluginConfig) error
Configure initializes this distributor with values from a plugin config.
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.
Source Files