conductor_rust 0.1.0-alpha.0

A library for building Conductor workers with Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13

use std::collections::HashMap;

use async_trait::async_trait;
use serde_json::Value;

#[async_trait]
pub trait ConductorWorker {
    async fn execute(
        &self,
        task_input: &Option<HashMap<String, Option<Value>>>
    ) -> Result<Option<HashMap<String, Option<Value>>>, String>;
    fn get_task_type(&self) -> String;
}