Struct rtlola_frontend::ir::RTLolaIR

pub struct RTLolaIR {
    pub inputs: Vec<InputStream>,
    pub outputs: Vec<OutputStream>,
    pub time_driven: Vec<TimeDrivenStream>,
    pub event_driven: Vec<EventDrivenStream>,
    pub sliding_windows: Vec<SlidingWindow>,
    pub triggers: Vec<Trigger>,
}

Intermediate representation of an RTLola specification. Contains all relevant information found in the underlying specification and is enriched with information collected in semantic analyses.

Fields

inputs: Vec<InputStream>

All input streams.

outputs: Vec<OutputStream>

All output streams with the bare minimum of information.

time_driven: Vec<TimeDrivenStream>

References to all time-driven streams.

event_driven: Vec<EventDrivenStream>

References to all event-driven streams.

sliding_windows: Vec<SlidingWindow>

A collection of all sliding windows.

triggers: Vec<Trigger>

A collection of triggers

Implementations

impl RTLolaIR

pub fn input_refs(&self) -> Vec<InputReference>

Returns a Vec containing a reference for each input stream in the specification.

pub fn output_refs(&self) -> Vec<OutputReference>

Returns a Vec containing a reference for each output stream in the specification.

pub fn get_in_mut(&mut self, reference: StreamReference) -> &mut InputStream

Provides mutable access to an input stream.

pub fn get_in(&self, reference: StreamReference) -> &InputStream

Provides immutable access to an input stream.

pub fn get_out_mut(&mut self, reference: StreamReference) -> &mut OutputStream

Provides mutable access to an output stream.

pub fn get_out(&self, reference: StreamReference) -> &OutputStream

Provides immutable access to an output stream.

pub fn all_streams(&self) -> Vec<StreamReference>

Returns a Vec containing a reference for each stream in the specification.

pub fn get_triggers(&self) -> Vec<&OutputStream>

Returns a Vec containing a reference to an output stream representing a trigger in the specification.

pub fn get_event_driven(&self) -> Vec<&OutputStream>

Returns a Vec containing a reference for each event-driven output stream in the specification.

pub fn get_time_driven(&self) -> Vec<&OutputStream>

Returns a Vec containing a reference for each time-driven output stream in the specification.

pub fn get_window(&self, window: WindowReference) -> &SlidingWindow

Returns a Vec containing a reference for each sliding window in the specification.

pub fn get_event_driven_layers(&self) -> Vec<Vec<OutputReference>>

Provides a representation for the evaluation layers of all event-driven output streams. Each element of the outer Vec represents a layer, each element of the inner Vec a stream in the layer.

pub fn compute_schedule(&self) -> Result<Schedule, String>

Computes a schedule for all time-driven streams.

Trait Implementations

impl Clone for RTLolaIR

fn clone(&self) -> RTLolaIR

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RTLolaIR

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl PartialEq<RTLolaIR> for RTLolaIR

fn eq(&self, other: &RTLolaIR) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &RTLolaIR) -> bool

This method tests for !=.

impl StructuralPartialEq for RTLolaIR