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 batch contains internal utilities for interacting with message batches.
|
Package batch contains internal utilities for interacting with message batches. |
|
policy
Package policy provides tooling for creating and executing Benthos message batch policies.
|
Package policy provides tooling for creating and executing Benthos message batch policies. |
|
field
Package field implements a bloblang interpolation function templating syntax used in some dynamic fields within Benthos.
|
Package field implements a bloblang interpolation function templating syntax used in some dynamic fields within Benthos. |
|
mapping
Package mapping provides a parser for the full bloblang mapping spec.
|
Package mapping provides a parser for the full bloblang mapping spec. |
|
query
Package query provides a parser for the right-hand side query part of the bloblang spec.
|
Package query provides a parser for the right-hand side query part of the bloblang spec. |
|
Package bundle contains singletons referenced throughout the Benthos codebase that allow imported components to add their constructors and documentation to a service.
|
Package bundle contains singletons referenced throughout the Benthos codebase that allow imported components to add their constructors and documentation to a service. |
|
Package checkpoint implements a mechanism for tracking checkpointed integer offsets for sequential read at-least-once queue systems such as Kafka or Kinesis.
|
Package checkpoint implements a mechanism for tracking checkpointed integer offsets for sequential read at-least-once queue systems such as Kafka or Kinesis. |
|
input/config
Package config contains reusable config definitions and parsers for inputs defined via the public/service package.
|
Package config contains reusable config definitions and parsers for inputs defined via the public/service package. |
|
Package docs provides useful functions for creating documentation from Benthos components
|
Package docs provides useful functions for creating documentation from Benthos components |
|
impl
|
|
|
azure
Package azure will eventually contain all implementations of Azure components (that are currently within ./internal/old)
|
Package azure will eventually contain all implementations of Azure components (that are currently within ./internal/old) |
|
io
Package io contains component implementations that have a small dependency footprint (mostly standard library) and interact with external systems via the filesystem and/or network sockets.
|
Package io contains component implementations that have a small dependency footprint (mostly standard library) and interact with external systems via the filesystem and/or network sockets. |
|
mqtt
Package mqtt will eventually contain all implementations of MQTT components (that are currently within ./internal/old)
|
Package mqtt will eventually contain all implementations of MQTT components (that are currently within ./internal/old) |
|
pure
Package pure contains all component implementations that are pure, in that they do not interact with external systems.
|
Package pure contains all component implementations that are pure, in that they do not interact with external systems. |
|
sftp
Package sftp will eventually contain all implementations of SFTP components (that are currently within ./internal/old)
|
Package sftp will eventually contain all implementations of SFTP components (that are currently within ./internal/old) |
|
xml
Package xml is a temporary way to convert XML to JSON.
|
Package xml is a temporary way to convert XML to JSON. |
|
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. |
|
old
|
|
|
util/throttle
Package throttle implements throttle strategies.
|
Package throttle implements throttle strategies. |
|
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 serverless contains shared components for serverless distributions of Benthos.
|
Package serverless contains shared components for serverless distributions of Benthos. |
|
lambda
Package lambda contains the execution logic for running Benthos as an AWS lambda function.
|
Package lambda contains the execution logic for running Benthos as an AWS lambda function. |
|
manager
Package manager creates and manages multiple streams, providing an API for performing CRUD operations.
|
Package manager creates and manages multiple streams, providing an API for performing CRUD operations. |
|
Package tls provides Benthos configuration fields and wrappers for a crypto/tls config.
|
Package tls provides Benthos configuration fields and wrappers for a crypto/tls config. |
|
Package tracing implements utility functions for interacting with a global tracing system.
|
Package tracing implements utility functions for interacting with a global tracing system. |
|
v2
Package tracing implements utility functions for interacting with a global tracing system.
|
Package tracing implements utility functions for interacting with a global tracing system. |
Click to show internal directories.
Click to hide internal directories.