Struct EngineBuilder 

pub struct EngineBuilder { /* private fields */ }

Implementations

impl EngineBuilder

pub fn new() -> Self

pub fn set_config_source(self, source: &Path) -> Self

pub fn log(self, dir: &str, level: &str) -> Self

pub fn cache_size(self, size: i64) -> Self

pub fn tick_interval_secs(self, secs: i64) -> Self

pub fn max_message_retry_times(self, retry_times: i32) -> Self

pub fn add_plugin<T>(self, plugin: &T) -> Self

where T: ActPlugin + Clone + 'static,

register plugin

Example

use acts::{ActPlugin, Message, Engine, EngineBuilder, Workflow, Result};

#[derive(Clone)]
struct TestPlugin;
impl TestPlugin {
    fn new() -> Self {
        Self
    }
}
#[async_trait::async_trait]
impl ActPlugin for TestPlugin {
    async fn on_init(&self, engine: &Engine) -> Result<()> {
        println!("TestPlugin");
        engine.channel().on_start(|e| {});
        engine.channel().on_complete(|e| {});
        engine.channel().on_message(|e| {});
        Ok(())       
    }
}

#[tokio::main]
async fn main() {
    let engine = EngineBuilder::new().add_plugin(&TestPlugin::new()).build().await.unwrap().start();
}

pub async fn build(&self) -> Result<Engine>

Trait Implementations

impl Default for EngineBuilder

fn default() -> Self

Returns the “default value” for a type.