Package reader defines implementations of an interface for generic message reading from various third party sources.

Descriptions returns a formatted string of descriptions for each type.

New creates an input type based on an input configuration.

NewAmazonS3 creates a new AWS S3 input type.

NewAmazonSQS creates a new AWS SQS input type.

NewAMQP creates a new AMQP input type.

NewBroker creates a new Broker input type.

NewBrokerConfig creates a new BrokerConfig with default values.

NewConfig returns a configuration struct fully populated with default values.

NewDynamic creates a new Dynamic input type.

NewDynamicConfig creates a new DynamicConfig with default values.

NewFile creates a new File input type.

NewFileConfig creates a new FileConfig with default values.

NewFiles creates a new Files input type.

NewHTTPClient creates a new HTTPClient input type.

NewHTTPClientConfig creates a new HTTPClientConfig with default values.

NewHTTPServer creates a new HTTPServer input type.

NewHTTPServerConfig creates a new HTTPServerConfig with default values.

NewInproc creates a new Inproc input type.

NewInprocConfig creates a new inproc input config.

NewKafka creates a new Kafka input type.

NewKafkaBalanced creates a new KafkaBalanced input type.

NewKinesis creates a new AWS Kinesis input type.

NewMQTT creates a new MQTT input type.

NewNanomsg creates a new Nanomsg input type.

NewNATS creates a new NATS input type.

NewNATSStream creates a new NATSStream input type.

NewNSQ creates a new NSQ input type.

NewReader creates a new Reader input type.

NewReadUntil creates a new ReadUntil input type.

NewReadUntilConfig creates a new ReadUntilConfig with default values.

NewRedisList creates a new Redis List input type.

NewRedisPubSub creates a new RedisPubSub input type.

NewRedisStreams creates a new Redis List input type.

NewSTDIN creates a new STDIN input type.

NewSTDINConfig creates a STDINConfig populated with default values.

NewWebsocket creates a new Websocket input type.

SanitiseConfig returns a sanitised version of the Config, meaning sections that aren't relevant to behaviour are removed.

WrapWithPipeline routes an input directly into a processing pipeline and returns a type that manages both and acts like an ordinary input.

WrapWithPipelines wraps an input with a variadic number of pipelines.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

String constants representing each input type.

Constructors is a map of all input types with their specs.

ErrBrokerNoInputs is returned when creating a broker with zero inputs.

BrokerConfig contains configuration fields for the Broker input type.

Config is the all encompassing configuration struct for all input types.

DynamicConfig contains configuration for the Dynamic input type.

FileConfig contains configuration values for the File input type.

HTTPClient is an input type that continuously makes HTTP requests and reads the response bodies as message payloads.

HTTPClientConfig contains configuration for the HTTPClient output type.

HTTPServer is an input type that registers a range of HTTP endpoints where requests can send messages through Benthos.

HTTPServerConfig contains configuration for the HTTPServer input type.

Inproc is an input type that reads from a named pipe, which could be the output of a separate Benthos stream of the same process.

Reader is an input implementation that reads messages from a reader.Type.

ReadUntil is an input type that continuously reads another input type until a condition returns true on a message consumed.

ReadUntilConfig contains configuration values for the ReadUntil input type.

STDINConfig contains config fields for the STDIN input type.

StreamConfig contains fields for specifying consumption behaviour when the body of a request is a constant stream of bytes.

TypeSpec is a struct containing constructors, markdown descriptions and an optional sanitisation function for each input type.

WithPipeline is a type that wraps both an input type and a pipeline type by routing the input through the pipeline, and implements the input.Type interface in order to act like an ordinary input.

Type is the standard interface of an input type.

InprocConfig is a configuration type for the inproc input.