# Functions
NewAmazonS3 creates a new Amazon S3 bucket writer.Type.
NewAmazonS3Config creates a new Config with default values.
NewAmazonSQS creates a new Amazon SQS writer.Type.
NewAmazonSQSConfig creates a new Config with default values.
NewAMQP creates a new AMQP writer type.
NewAMQPConfig creates a new AMQPConfig with default values.
NewElasticsearch creates a new Elasticsearch writer type.
NewElasticsearchConfig creates a new ElasticsearchConfig with default values.
NewFiles creates a new file based writer.Type.
NewFilesConfig creates a new Config with default values.
NewHTTPClient creates a new HTTPClient writer type.
NewHTTPClientConfig creates a new HTTPClientConfig with default values.
NewKafka creates a new Kafka writer type.
NewKafkaConfig creates a new KafkaConfig with default values.
NewKinesis creates a new Amazon SQS writer.Type.
NewKinesisConfig creates a new Config with default values.
NewMQTT creates a new MQTT output type.
NewMQTTConfig creates a new MQTTConfig with default values.
NewRedisList creates a new RedisList output type.
NewRedisListConfig creates a new RedisListConfig with default values.
NewRedisPubSub creates a new RedisPubSub output type.
NewRedisPubSubConfig creates a new RedisPubSubConfig with default values.
NewRedisStreams creates a new RedisStreams output type.
NewRedisStreamsConfig creates a new RedisStreamsConfig with default values.
NewWebsocket creates a new Websocket output type.
NewWebsocketConfig creates a new WebsocketConfig with default values.
NewZMQ4Config returns nil.
# Structs
AmazonAWSCredentialsConfig contains configuration params for AWS credentials.
AmazonS3 is a benthos writer.Type implementation that writes messages to an Amazon S3 bucket.
AmazonS3Config contains configuration fields for the AmazonS3 output type.
AmazonSQS is a benthos writer.Type implementation that writes messages to an Amazon SQS queue.
AmazonSQSConfig contains configuration fields for the output AmazonSQS type.
AMQP is an output type that serves AMQP messages.
AMQPConfig contains configuration fields for the AMQP output type.
AMQPExchangeDeclareConfig contains fields indicating whether the target AMQP exchange needs to be declared, as well as any fields specifying how to accomplish that.
Elasticsearch is a writer type that writes messages into elasticsearch.
ElasticsearchConfig contains configuration fields for the Elasticsearch output type.
Files is a benthos writer.Type implementation that writes message parts each to their own file.
FilesConfig contains configuration fields for the files output type.
HTTPClient is an output type that sends messages as HTTP requests to a target server endpoint.
HTTPClientConfig contains configuration fields for the HTTPClient output type.
Kafka is a writer type that writes messages into kafka.
KafkaConfig contains configuration fields for the Kafka output type.
Kinesis is a benthos writer.Type implementation that writes messages to an Amazon SQS queue.
KinesisConfig contains configuration fields for the output Kinesis type.
MQTT is an output type that serves MQTT messages.
MQTTConfig contains configuration fields for the MQTT output type.
RedisList is an output type that serves RedisList messages.
RedisListConfig contains configuration fields for the RedisList output type.
RedisPubSub is an output type that serves RedisPubSub messages.
RedisPubSubConfig contains configuration fields for the RedisPubSub output type.
RedisStreams is an output type that serves RedisStreams messages.
RedisStreamsConfig contains configuration fields for the RedisStreams output type.
Websocket is an output type that serves Websocket messages.
WebsocketConfig contains configuration fields for the Websocket output type.
ZMQ4Config empty stub for when ZMQ4 is not compiled.
# Interfaces
Type is a type that writes Benthos messages to a third party sink.