View Source API Reference Broadway v1.1.0

Broadway is a concurrent, multi-stage tool for building data ingestion and data processing pipelines.

A behaviour used to acknowledge that the received messages were successfully processed or failed.

A struct used to hold information about a generated batch.

A simple acknowledger that sends a message back to a caller.

A producer that does nothing, used mostly for testing.

This struct holds all information about a message.

An acknowledger that does nothing.

A Broadway producer is a GenStage producer that emits Broadway.Message structs as events.