internal/

directory
v4.0.0-rc2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 31, 2022 License: MIT

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.
cli
test
Package test implements the Benthos service unit testing command.
Package test implements the Benthos service unit testing command.
Package docs provides useful functions for creating documentation from Benthos components
Package docs provides useful functions for creating documentation from Benthos components
impl
amqp1
Package amqp1 will eventually contain all implementations of AMQP 1 components (that are currently within ./internal/old)
Package amqp1 will eventually contain all implementations of AMQP 1 components (that are currently within ./internal/old)
amqp1/shared
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
aws
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)
azure/shared
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
gcp
generic
Package generic contains component implementations that do not require external dependencies.
Package generic contains component implementations that do not require external dependencies.
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)
mqtt/shared
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
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)
sftp/shared
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
Package shared contains docs fields that need to be shared across old and new component implementations, it needs to be separate from the parent package in order to avoid circular dependencies (for now).
sql
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
input
Package input defines consumers for aggregating data from a variety of sources.
Package input defines consumers for aggregating data from a variety of sources.
output
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.
output/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.
processor
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.
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL