Directories
¶
| Path | Synopsis |
|---|---|
|
Package input defines consumers for aggregating data from a variety of sources.
|
Package input defines consumers for aggregating data from a variety of sources. |
|
Package output defines all sinks for sending Benthos messages to a variety of third party destinations.
|
Package output defines all sinks for sending Benthos messages to a variety of third party destinations. |
|
writer
Package writer defines implementations of an interface for generic message writing that outputs to various third party sinks.
|
Package writer defines implementations of an interface for generic message writing that outputs to various third party sinks. |
|
Package processor contains implementations of types.Processor, which perform an arbitrary operation on a message and either returns >0 messages to be propagated towards a sink, or a response to be sent back to the message source.
|
Package processor contains implementations of types.Processor, which perform an arbitrary operation on a message and either returns >0 messages to be propagated towards a sink, or a response to be sent back to the message source. |
|
util
|
|
|
retries
Package retries implements backoff strategies around a standard configuration scheme.
|
Package retries implements backoff strategies around a standard configuration scheme. |
|
throttle
Package throttle implements throttle strategies.
|
Package throttle implements throttle strategies. |
Click to show internal directories.
Click to hide internal directories.