Directories ¶
Path | Synopsis |
---|---|
Package api implements a type used for creating the Benthos HTTP API.
|
Package api implements a type used for creating the Benthos HTTP API. |
Package broker implements types used for routing inputs to outputs in non-trivial arrangements, such as fan-out or fan-in models.
|
Package broker implements types used for routing inputs to outputs in non-trivial arrangements, such as fan-out or fan-in models. |
Package buffer links an input and an output together and buffers messages in between.
|
Package buffer links an input and an output together and buffers messages in between. |
sequential
Package sequential contains implementations of various buffer types where the buffer can only be consumed once in a set sequence.
|
Package sequential contains implementations of various buffer types where the buffer can only be consumed once in a set sequence. |
Package cache implements the types.Cache interface for storing and retrieving key/value pairs from a range of storage strategies.
|
Package cache implements the types.Cache interface for storing and retrieving key/value pairs from a range of storage strategies. |
Package input defines consumers for aggregating data from a variety of sources.
|
Package input defines consumers for aggregating data from a variety of sources. |
reader
Package reader defines implementations of an interface for generic message reading from various third party sources.
|
Package reader defines implementations of an interface for generic message reading from various third party sources. |
Package manager implements the types.Manager interface used for creating and sharing resources across a Benthos service.
|
Package manager implements the types.Manager interface used for creating and sharing resources across a Benthos service. |
Package output defines dispatchers of data for a variety of targets.
|
Package output defines dispatchers of data for a variety of targets. |
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 pipeline contains structures that implement both the Producer and Consumer interfaces.
|
Package pipeline contains structures that implement both the Producer and Consumer interfaces. |
Package processor contains logical message processors that can be pipelined within benthos using the pipeline.Processor type.
|
Package processor contains logical message processors that can be pipelined within benthos using the pipeline.Processor type. |
condition
Package condition contains logical operators that, based on their configuration, return boolean values from messages under certain circumstances.
|
Package condition contains logical operators that, based on their configuration, return boolean values from messages under certain circumstances. |
Package types defines any general structs and interfaces used throughout the benthos code base.
|
Package types defines any general structs and interfaces used throughout the benthos code base. |
disk
Package disk contains cross platform disk statistics utilities.
|
Package disk contains cross platform disk statistics utilities. |
http/auth
Package auth provides configuration fields and implementations of HTTP request authentication strategies.
|
Package auth provides configuration fields and implementations of HTTP request authentication strategies. |
service
Package service contains utilities for bootstrapping a server such as config, logging and metrics.
|
Package service contains utilities for bootstrapping a server such as config, logging and metrics. |
service/config
Package config contains utilities for reading and parsing service configuration files.
|
Package config contains utilities for reading and parsing service configuration files. |
service/log
Package log contains utilities for logging in a modular interface.
|
Package log contains utilities for logging in a modular interface. |
service/metrics
Package metrics contains a type for aggregating and propagating metrics to various services based on configuration.
|
Package metrics contains a type for aggregating and propagating metrics to various services based on configuration. |
test
Package test contains helpers for setting up test utilties.
|
Package test contains helpers for setting up test utilties. |
text
Package text includes utilities for working with text that might contain variables.
|
Package text includes utilities for working with text that might contain variables. |
throttle
Package throttle implements throttle strategies.
|
Package throttle implements throttle strategies. |
Click to show internal directories.
Click to hide internal directories.