melodium-common 0.10.1

Common Mélodium elements and traits
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
28
29
30
31
32
33
34
35
36
37
38

use crate::{
    descriptor::Collection,
    executive::{
        Context, ContinuousFuture, Input, Level, Log, ModelId, Output, Outputs, TrackFuture, Value,
    },
};
use async_trait::async_trait;
use core::fmt::Debug;
use std::{collections::HashMap, sync::Arc};
use uuid::Uuid;

pub type TrackId = usize;
pub type TrackCreationCallback = Box<dyn FnOnce(Box<dyn Outputs>) -> Vec<TrackFuture> + Send>;
pub type DirectCreationCallback = Box<
    dyn FnOnce(
            HashMap<String, Box<dyn Output>>,
            HashMap<String, Box<dyn Input>>,
        ) -> Vec<TrackFuture>
        + Send,
>;

#[async_trait]
pub trait World: Debug + Send + Sync {
    fn collection(&self) -> Arc<Collection>;
    fn add_continuous_task(&self, task: ContinuousFuture);
    async fn create_track(
        &self,
        id: ModelId,
        source: &str,
        params: &HashMap<String, Value>,
        contexts: Vec<Arc<dyn Context>>,
        parent_track: Option<TrackId>,
        callback: Option<TrackCreationCallback>,
    );
    async fn log(&self, level: Level, label: String, message: String, track_id: Option<TrackId>);
    async fn inject_log(&self, log: Log) -> Result<(), ()>;
    async fn inject_debug(&self, run_id: Uuid, data: String) -> Result<(), ()>;
}