Struct ConfigBuilder

pub struct ConfigBuilder<S: ConfigState, OutputTime: OutputTimeRepresentation> { /* private fields */ }

The main entry point of the application. Use the various methods to construct a configuration either for running the interpreter directly or to use the Monitor API interface.

An example construction of the API:

use std::convert::Infallible;
use rtlola_interpreter::monitor::Incremental;
use rtlola_interpreter::input::ArrayFactory;
use rtlola_interpreter::time::RelativeFloat;
use rtlola_interpreter::{ConfigBuilder, Monitor, Value};

let monitor: Monitor<_, _, Incremental, _> = ConfigBuilder::new()
    .spec_str("input i: Int64")
    .offline::<RelativeFloat>()
    .with_array_events::<1, Infallible, [Value; 1]>()
    .with_verdict::<Incremental>()
    .monitor().expect("Failed to create monitor.");

Implementations

impl ConfigBuilder<ConfigureIR, RelativeFloat>

pub fn new() -> Self

Creates a new configuration to be used with the API.

impl<S: ConfigState, OutputTime: OutputTimeRepresentation> ConfigBuilder<S, OutputTime>

pub fn output_time<T: OutputTimeRepresentation>(self) -> ConfigBuilder<S, T>

Sets the format in which time is returned. See the README for more details on time formats. For possible formats see the OutputTimeRepresentation trait.

pub fn start_time(self, time: SystemTime) -> Self

Sets the start time of the execution.

impl<OutputTime: OutputTimeRepresentation> ConfigBuilder<ConfigureIR, OutputTime>

pub fn with_ir(self, ir: RtLolaMir) -> ConfigBuilder<IrConfigured, OutputTime>

Use an existing ir with the configuration

pub fn spec_file(self, path: PathBuf) -> ConfigBuilder<IrConfigured, OutputTime>

Read the specification from a file at the given path.

pub fn spec_str(self, spec: &str) -> ConfigBuilder<IrConfigured, OutputTime>

Read the specification from the given string.

impl<OutputTime: OutputTimeRepresentation> ConfigBuilder<IrConfigured, OutputTime>

pub fn online(self) -> ConfigBuilder<ModeConfigured<OnlineMode>, OutputTime>

Sets the execute mode to be online, i.e. the time of events is taken by the interpreter.

pub fn offline<InputTime: TimeRepresentation>( self, ) -> ConfigBuilder<ModeConfigured<OfflineMode<InputTime>>, OutputTime>

Sets the execute mode to be offline, i.e. takes the time of events from the input source. How the input timestamps are interpreted is defined by the type parameter. See the README for further details on timestamp representations. For possible TimeRepresentations see the Time Module.

impl<Mode: ExecutionMode, OutputTime: OutputTimeRepresentation> ConfigBuilder<ModeConfigured<Mode>, OutputTime>

pub fn with_array_events<const N: usize, I: Error + Send + 'static, E: TryInto<[Value; N], Error = I> + CondSerialize + CondDeserialize + Send>( self, ) -> ConfigBuilder<InputConfigured<Mode, ArrayFactory<N, I, E>>, OutputTime>

Use the predefined ArrayFactory method to provide inputs to the API.

pub fn with_mapped_events<Inner: InputMap>( self, ) -> ConfigBuilder<InputConfigured<Mode, MappedFactory<Inner>>, OutputTime>

Use the predefined MappedFactory method to provide inputs to the API. Requires implementing InputMap for your type defining how the values of input streams are extracted from it.

pub fn with_event_factory<Source: EventFactory>( self, ) -> ConfigBuilder<InputConfigured<Mode, Source>, OutputTime>

Use a custom input method to provide inputs to the API.

impl<Mode: ExecutionMode, OutputTime: OutputTimeRepresentation, Source: EventFactory> ConfigBuilder<InputConfigured<Mode, Source>, OutputTime>

pub fn with_verdict<Verdict: VerdictRepresentation>( self, ) -> ConfigBuilder<VerdictConfigured<Mode, Source, Verdict>, OutputTime>

Sets the VerdictRepresentation for the monitor

impl<Source: EventFactory + 'static, Mode: ExecutionMode, Verdict: VerdictRepresentation<Tracing = NoTracer>, OutputTime: OutputTimeRepresentation> ConfigBuilder<VerdictConfigured<Mode, Source, Verdict>, OutputTime>

pub fn with_tracer<T: Tracer>( self, ) -> ConfigBuilder<VerdictConfigured<Mode, Source, TracingVerdict<T, Verdict>>, OutputTime>

Adds tracing functionality to the evaluator

impl<Source: EventFactory + 'static, Mode: ExecutionMode, Verdict: VerdictRepresentation, OutputTime: OutputTimeRepresentation> ConfigBuilder<VerdictConfigured<Mode, Source, Verdict>, OutputTime>

pub fn build(self) -> MonitorConfig<Source, Mode, Verdict, OutputTime>

Finalize the configuration and generate a configuration.

pub fn monitor_with_data( self, data: Source::CreationData, ) -> Result<Monitor<Source, Mode, Verdict, OutputTime>, EventFactoryError>

Create a Monitor from the configuration. The entrypoint of the API. The data is provided to the Input source at creation.

pub fn monitor( self, ) -> Result<Monitor<Source, Mode, Verdict, OutputTime>, EventFactoryError>

where Source: EventFactory<CreationData = ()> + 'static,

Create a Monitor from the configuration. The entrypoint of the API.

impl<Source: EventFactory + 'static, SourceTime: TimeRepresentation, Verdict: VerdictRepresentation, OutputTime: OutputTimeRepresentation> ConfigBuilder<VerdictConfigured<OfflineMode<SourceTime>, Source, Verdict>, OutputTime>

pub fn queued_monitor_with_data( self, data: Source::CreationData, ) -> QueuedMonitor<Source, OfflineMode<SourceTime>, Verdict, OutputTime>

Create a QueuedMonitor from the configuration. The entrypoint of the API. The data is provided to the Input source at creation.

pub fn queued_monitor( self, ) -> QueuedMonitor<Source, OfflineMode<SourceTime>, Verdict, OutputTime>

where Source: EventFactory<CreationData = ()> + 'static,

Create a QueuedMonitor from the configuration. The entrypoint of the API.

impl<Source: EventFactory + 'static, Verdict: VerdictRepresentation, OutputTime: OutputTimeRepresentation> ConfigBuilder<VerdictConfigured<OnlineMode, Source, Verdict>, OutputTime>

pub fn queued_monitor_with_data( self, data: Source::CreationData, ) -> QueuedMonitor<Source, OnlineMode, Verdict, OutputTime>

Create a QueuedMonitor from the configuration. The entrypoint of the API. The data is provided to the Input source at creation.

pub fn queued_monitor( self, ) -> QueuedMonitor<Source, OnlineMode, Verdict, OutputTime>

where Source: EventFactory<CreationData = ()> + 'static,

Create a QueuedMonitor from the configuration. The entrypoint of the API.

Trait Implementations

impl<S: Clone + ConfigState, OutputTime: Clone + OutputTimeRepresentation> Clone for ConfigBuilder<S, OutputTime>

fn clone(&self) -> ConfigBuilder<S, OutputTime>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug + ConfigState, OutputTime: Debug + OutputTimeRepresentation> Debug for ConfigBuilder<S, OutputTime>

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

Formats the value using the given formatter.

impl Default for ConfigBuilder<ConfigureIR, RelativeFloat>

fn default() -> Self

Returns the “default value” for a type.