README
¶
Implementations
This is an internal package containing the implementations of Benthos component types (inputs, processors, outputs, etc) organised into sub categories.
If you intend to create a new component type then use the docs at https://pkg.go.dev/github.com/benthosdev/benthos/v4/public/service, and there are some implementations that might be worth using as a reference:
- Input example: ./nats/input_jetstream.go
- Output example: ./nats/output_jetstream.go
- Processor example: ./confluent/processor_schema_registry_encode.go
- Buffer example: ./generic/buffer_system_window.go
Directories
¶
| Path | Synopsis |
|---|---|
|
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) |
|
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). |
|
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) |
|
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). |
|
Package generic contains component implementations that do not require external dependencies.
|
Package generic contains component implementations that do not require external dependencies. |
|
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) |
|
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). |
|
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) |
|
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). |
|
Package xml is a temporary way to convert XML to JSON.
|
Package xml is a temporary way to convert XML to JSON. |
Click to show internal directories.
Click to hide internal directories.