Trait eventio::Input[−][src]

pub trait Input {
    type Data;
    type Ack;
    fn run(self) -> Result<(), Error>;
}

Expand description

A trait for a data source that produces messages of type Data.

Associated Types

type Data[src]

type Ack[src]

fn run(self) -> Result<(), Error>[src]

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.

impl Input for eventio::kafka::Input[src]

fn run(self) -> Result<(), Error>[src]

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.

type Data = Event

type Ack = EntryLocation

impl Input for eventio::pcap::Input[src]

type Data = Event

type Ack = u64

fn run(self) -> Result<(), Error>[src]

impl<T: Read> Input for eventio::mbox::Input<T>[src]

fn run(self) -> Result<(), Error>[src]

Reads emails from mbox and forwards them through data_channel.

Returns an error if reading an email from mbox fails.

type Data = Event

type Ack = u64

impl<T: Read> Input for eventio::text::Input<T>[src]

type Data = Event

type Ack = u64

fn run(self) -> Result<(), Error>[src]