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
• Scanner example: ./avro/scanner.go
• Cache example: ./redis/cache.go
• Buffer example: ./sql/buffer_sqlite.go
• Rate Limit example: ./redis/rate_limit.go
• Metrics Exporter example: ./prometheus/metrics_prometheus.go
• Tracer Provider example: ./otlp/tracer_otlp.go