Struct brane_exe::dummy::DummyVm

pub struct DummyVm { /* private fields */ }

Defines a Dummy VM that may be used to test.

Implementations

impl DummyVm

pub fn new() -> Self

Constructor for the DummyVm that initializes it to an never-used-before-but-ready-for-everything VM.

Returns

A new instance of a DummyVm.

pub async fn exec(self, workflow: Workflow) -> (Self, Result<FullValue, Error>)

Runs the given workflow on this VM.

There is a bit of ownership awkwardness going on, but that’s due to the need for the struct to outlive threads.

Arguments

• workflow: The Workflow to execute.

Returns

The result of the workflow, if any. It also returns self again for subsequent runs.

pub fn flush_stdout(&self)

Prints the buffered text, clearing it again.

Returns

Nothing, but does print to stdout.

Trait Implementations

impl Default for DummyVm

fn default() -> Self

Returns the “default value” for a type.

impl Vm for DummyVm

fn store_state( this: &Arc<RwLock<Self>>, state: RunState<Self::GlobalState>, ) -> Result<(), VmError>

A function that stores the given runtime state information in the parent struct.

This is important and will be used later.

Arguments

• state: The current state of the workflow we have executed.

Returns

Nothing, but should change the internals to return this state later upon request.

Errors

This function may error for its own reasons.

fn load_state( this: &Arc<RwLock<Self>>, ) -> Result<RunState<Self::GlobalState>, VmError>

A function that returns the VM’s runtime state in the parent struct.

This is important and will be used later.

Returns

The RunState of this application if it exists, or else None.

Errors

This function may error for its own reasons.

type GlobalState = DummyState

The type of the thread-global extension to the runtime state.

type LocalState = ()

The type of the thread-local extension to the runtime state.

fn new_state(custom: Self::GlobalState) -> RunState<Self::GlobalState>

Initializes a new global state based on the given custom part.

fn run<'life0, 'async_trait, P>( this: Arc<RwLock<Self>>, snippet: Workflow, prof: ProfileScopeHandle<'life0>, ) -> Pin<Box<dyn Future<Output = Result<FullValue, VmError>> + Send + 'async_trait>>

where Self: Sync + Send + 'async_trait, P: 'async_trait + VmPlugin<GlobalState = Self::GlobalState, LocalState = Self::LocalState>, 'life0: 'async_trait,

Runs the given workflow, possibly asynchronously (if a parallel is encountered / there are external functions calls and the given closure runs this asynchronously.)