Trait eventio::Input

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

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

Associated Types

type Data

type Ack

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.

Loading content...

Implementors

impl Input for eventio::kafka::Input

type Data = Event

type Ack = EntryLocation

fn run(self) -> Result<(), Error>

impl<R: Read> Input for eventio::pcap::Input<R>

type Data = Event

type Ack = u64

fn run(self) -> Result<(), Error>

impl<T: Read> Input for eventio::mbox::Input<T>

type Data = Event

type Ack = u64

fn run(self) -> Result<(), Error>

impl<T: Read> Input for eventio::text::Input<T>

type Data = Event

type Ack = u64

fn run(self) -> Result<(), Error>

Loading content...