runkon-flow 0.6.1-alpha

Portable workflow execution engine — DSL, traits, and in-memory reference implementations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::collections::HashMap;
use std::sync::Arc;

use crate::dsl::WorkflowDef;
use crate::engine_error::EngineError;
use crate::traits::workflow_resolver::WorkflowResolver;

pub struct InMemoryWorkflowResolver {
    defs: HashMap<String, WorkflowDef>,
}

impl InMemoryWorkflowResolver {
    pub fn new(defs: impl IntoIterator<Item = (impl Into<String>, WorkflowDef)>) -> Self {
        Self {
            defs: defs.into_iter().map(|(k, v)| (k.into(), v)).collect(),
        }
    }
}

impl WorkflowResolver for InMemoryWorkflowResolver {
    fn resolve(&self, name: &str) -> Result<Arc<WorkflowDef>, EngineError> {
        self.defs
            .get(name)
            .map(|d| Arc::new(d.clone()))
            .ok_or_else(|| EngineError::WorkflowNotFound(name.to_string()))
    }
}