Struct Engine

pub struct Engine { /* private fields */ }

Workflow Engine

Example:

a example to caculate the result from 1 to given input value

 use acts::{Engine, Workflow, Vars};

 #[tokio::main]
 async fn main() {
     let engine = Engine::new();

     let model = include_str!("../examples/simple/model.yml");
     let workflow = Workflow::from_yml(model).unwrap();
     
     engine.channel().on_complete(|e| {
         println!("{:?}", e.outputs);
     });
     let exec = engine.executor();
     exec.model().deploy(&workflow).expect("fail to deploy workflow");

     let mut vars = Vars::new();
     vars.insert("input".into(), 3.into());
     vars.insert("pid".into(), "test1".into());
     exec.proc().start(
        &workflow.id,
        &vars);
 }

Implementations

impl Engine

pub fn new() -> Self

pub fn config(&self) -> Arc<Config>

pub fn adapter(&self) -> Arc<Adapter>

engine executor

pub fn executor(&self) -> Arc<Executor>

engine executor

pub fn channel(&self) -> Arc<Channel>

event channel (default to not support re-send)

pub fn channel_with_options(&self, matcher: &ChannelOptions) -> Arc<Channel>

create named channel to receive messages if setting the emit_id by ChannelOptions it will check the status and re-send when not acking

Example

use acts::{ Engine, ChannelOptions };

let engine = Engine::new();
let chan = engine.channel_with_options(&ChannelOptions {  id: "chan1".to_string(),  ack: true,  r#type: "step".to_string(), key: "my_key*".to_string(), state: "{created, completed}".to_string(), tag: "*".to_string()  });
chan.on_message(|e| {
    // do something
});

pub fn extender(&self) -> Arc<Extender>

engine extender

pub fn close(&self)

close engine

Example

use acts::{Engine, Workflow, Vars};
#[tokio::main]
async fn main() {
    let engine = Engine::new();
    engine.close();
}

pub fn signal<T: Clone>(&self, init: T) -> Signal<T>

pub fn is_running(&self) -> bool

Trait Implementations

impl Clone for Engine

fn clone(&self) -> Engine

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for Engine

fn default() -> Self

Returns the “default value” for a type.