Expand description
A trait for a data source that produces messages of type Data
.
Fetches events and send them as Data
. It also receives and processes
Ack
, which acknowledges the receipt of a certain Data
.
Returns an error if it fails to fetch events, or receives an invalid
Data
or Ack
.
Reads events from Kafak and forwards them through data_channel
.
Returns an error if it cannot fetch messages from Kafka, receives an
invalid message, or receives an invalid ACK from ack_channel
.
Reads emails from mbox and forwards them through data_channel
.
Returns an error if reading an email from mbox fails.