Struct rtlola_interpreter::Monitor

pub struct Monitor<V: VerdictRepresentation = Incremental> {
    pub ir: RtLolaMir,
    // some fields omitted
}

The Monitor accepts new events and computes streams.

The Monitor is the central object exposed by the API. It can compute event-based streams based on new events through accept_event. It can also simply advance periodic streams up to a given timestamp through accept_time. The generic argument V implements the VerdictRepresentation trait describing the outputformat of the API that is by default Incremental.

Fields

ir: RtLolaMir

Implementations

impl<V: VerdictRepresentation> Monitor<V>

Public interface

pub fn accept_event<E: Into<Event>>(&mut self, ev: E, ts: Time) -> Verdicts<V>

Computes all periodic streams up through the new timestamp and then handles the input event.

The new event is therefore not seen by periodic streams up through the new timestamp.

pub fn accept_time(&mut self, ts: Time) -> Vec<(Time, V)>

Computes all periodic streams up through the new timestamp.

pub fn name_for_input(&self, id: InputReference) -> &str

Get the name of an input stream based on its [InputReference].

The reference is valid for the lifetime of the monitor.

pub fn name_for_output(&self, id: OutputReference) -> &str

Get the name of an output stream based on its [OutputReference].

The reference is valid for the lifetime of the monitor.

pub fn trigger_message(&self, id: usize) -> &str

Get the message of a trigger based on its index.

The reference is valid for the lifetime of the monitor.

pub fn trigger_stream_index(&self, id: usize) -> usize

Get the [OutputReference] of a trigger based on its index.

pub fn number_of_input_streams(&self) -> usize

Get the number of input streams.

pub fn number_of_output_streams(&self) -> usize

Get the number of output streams (this includes one output stream for each trigger).

pub fn number_of_triggers(&self) -> usize

Get the number of triggers.

pub fn type_of_input(&self, id: InputReference) -> &Type

Get the type of an input stream based on its [InputReference].

The reference is valid for the lifetime of the monitor.

pub fn type_of_output(&self, id: OutputReference) -> &Type

Get the type of an output stream based on its [OutputReference].

The reference is valid for the lifetime of the monitor.

pub fn extend_rate_of_output(&self, id: OutputReference) -> Option<Duration>

Get the extend rate of an output stream based on its [OutputReference].

The reference is valid for the lifetime of the monitor.

pub fn with_verdict_representation<T: VerdictRepresentation>(self) -> Monitor<T>

Switch VerdictRepresentations of the Monitor.