Struct Prepared 

pub struct Prepared { /* private fields */ }

A compiled graph prepared for a set of engine targets.

A prepared program holds the execution plan and the requirements each target slot puts on its engine; it holds no engine, stream or event state, so any engines that report the same targets can run it, and several callers can run it at the same time on their own engines. It is tied to the runtime epoch that created it and becomes stale after runtime reconfiguration.

Examples

use tenferro_runtime::Prepared;

fn target_count(prepared: &Prepared) -> usize {
    prepared.targets().len()
}

Implementations

impl Prepared

pub fn targets(&self) -> &[EngineTarget]

The engine targets this program was prepared for, in slot order.

crate::Runtime::run binds slot i to the i-th engine it receives.

Examples

use tenferro_runtime::Prepared;

fn first_engine(prepared: &Prepared) -> Option<&str> {
    prepared.targets().first().map(|target| target.engine_id().as_str())
}

Trait Implementations

impl Clone for Prepared

fn clone(&self) -> Prepared

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Prepared

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

Formats the value using the given formatter.