Struct rtlola_input_plugins::csv_plugin::CsvEventSource

pub struct CsvEventSource<InputTime: TimeRepresentation> { /* private fields */ }

Parses events in CSV format.

Implementations

impl<InputTime: TimeRepresentation> CsvEventSource<InputTime>

pub fn setup(
    time_col: Option<usize>,
    kind: CsvInputSourceKind,
    ir: &RtLolaMir
) -> Result<CsvEventSource<InputTime>, Box<dyn Error>>

Trait Implementations

impl<InputTime: TimeRepresentation> EventSource<InputTime> for CsvEventSource<InputTime>

type Error = CsvError

type Rec = CsvRecord

fn init_data(&self) -> Result<<CsvRecord as Record>::CreationData, CsvError>

Return the data needed by the monitor to initialize the input source.

fn next_event(
    &mut self
) -> Result<Option<(CsvRecord, InputTime::InnerTime)>, CsvError>

Queries the event source for a new Record(Event) in a blocking fashion. If there are no more records, None is returned.