Struct QueuedMonitor

pub struct QueuedMonitor<Source, Mode, Verdict = Incremental, VerdictTime = RelativeFloat>
where
    Source: EventFactory,
    Mode: ExecutionMode,
    Verdict: VerdictRepresentation,
    VerdictTime: OutputTimeRepresentation + 'static,
{ /* private fields */ }

The QueuedMonitor is a threaded version of the Api allowing deadlines to be evaluated immediately.

The QueuedMonitor accepts new events and computes streams. It can compute streams based on new events through accept_event once the start function was invoked. Timed streams are evaluated automatically at their deadline. The resulting verdicts of events and deadlines are returned through a Receiver which can be obtained through output_queue. Note that the start function has to be invoked before any event can be evaluated. Finally, a calling end will block until all events have been evaluated.

The generic argument Source implements the EventFactory trait describing the input source of the API. The generic argument SourceTime implements the TimeRepresentation trait defining the input time format. The generic argument Verdict implements the VerdictRepresentation trait describing the output format of the API that is by default Incremental. The generic argument VerdictTime implements the TimeRepresentation trait defining the output time format. It defaults to RelativeFloat

Implementations

impl<Source, Mode, Verdict, VerdictTime> QueuedMonitor<Source, Mode, Verdict, VerdictTime>

where Source: EventFactory + 'static, Mode: ExecutionMode, Verdict: VerdictRepresentation, VerdictTime: OutputTimeRepresentation,

pub fn start(&mut self) -> Result<(), QueueError>

Starts the evaluation process. This method has to be called before any event is accepted.

pub fn output_queue(&self) -> Receiver<QueuedVerdict<Verdict, VerdictTime>>

This method returns the queue through which the verdicts can be received.

pub fn accept_event( &mut self, ev: Source::Record, ts: <Mode::SourceTime as TimeRepresentation>::InnerTime, ) -> Result<(), QueueError>

Schedules a new event for evaluation. The verdict can be received through the Queue return by the QueuedMonitor::output_queue.

pub fn end(self) -> Result<(), QueueError>

Ends the evaluation process and blocks until all events are processed.

pub fn ir(&self) -> &RtLolaMir

Returns the underlying representation of the specification as an RtLolaMir

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_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.

impl<Source, SourceTime, Verdict, VerdictTime> QueuedMonitor<Source, OfflineMode<SourceTime>, Verdict, VerdictTime>

where Source: EventFactory + 'static, SourceTime: TimeRepresentation, Verdict: VerdictRepresentation, VerdictTime: OutputTimeRepresentation,

pub fn bounded_setup( config: Config<OfflineMode<SourceTime>, VerdictTime>, setup_data: Source::CreationData, input_queue_bound: QueueLength, output_queue_bound: QueueLength, ) -> QueuedMonitor<Source, OfflineMode<SourceTime>, Verdict, VerdictTime>

setup the api, while providing bounds for the queues.

pub fn setup( config: Config<OfflineMode<SourceTime>, VerdictTime>, setup_data: Source::CreationData, ) -> QueuedMonitor<Source, OfflineMode<SourceTime>, Verdict, VerdictTime>

setup the api with unbounded queues

impl<Source, Verdict, VerdictTime> QueuedMonitor<Source, OnlineMode, Verdict, VerdictTime>

where Source: EventFactory + 'static, Verdict: VerdictRepresentation, VerdictTime: OutputTimeRepresentation,

pub fn bounded_setup( config: Config<OnlineMode, VerdictTime>, setup_data: Source::CreationData, input_queue_bound: QueueLength, output_queue_bound: QueueLength, ) -> QueuedMonitor<Source, OnlineMode, Verdict, VerdictTime>

setup the api, while providing bounds for the queues.

pub fn setup( config: Config<OnlineMode, VerdictTime>, setup_data: Source::CreationData, ) -> QueuedMonitor<Source, OnlineMode, Verdict, VerdictTime>

setup the api with unbounded queues