[−][src]Trait eventio::Input
A trait for a data source that produces messages of type Data
.
Associated Types
Loading content...Required methods
fn run(self) -> Result<(), Error>
Fetches events and send them as Data
. It also receives and processes
Ack
, which acknowledges the receipt of a certain Data
.
Errors
Returns an error if it fails to fetch events, or receives an invalid
Data
or Ack
.
Implementors
impl Input for eventio::kafka::Input
[src]
type Data = Event
type Ack = EntryLocation
fn run(self) -> Result<(), Error>
[src]
Reads events from Kafak and forwards them through data_channel
.
Errors
Returns an error if it cannot fetch messages from Kafka, receives an
invalid message, or receives an invalid ACK from ack_channel
.
impl<R: Read> Input for eventio::pcap::Input<R>
[src]
impl<T: Read> Input for eventio::mbox::Input<T>
[src]
type Data = Event
type Ack = u64
fn run(self) -> Result<(), Error>
[src]
Reads emails from mbox and forwards them through data_channel
.
Errors
Returns an error if reading an email from mbox fails.