jellyflow-runtime 0.2.0

Headless store, rules, schema, profile, and change pipeline for Jellyflow.
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

use serde_json::Value;

/// A per-kind node payload migrator.
pub trait NodeKindMigrator: Send + Sync {
    /// Migrates a node payload from `from_version` to `to_version`.
    fn migrate(
        &self,
        from_version: u32,
        to_version: u32,
        data: &Value,
    ) -> Result<Value, NodeKindMigrateError>;
}

#[derive(Debug, thiserror::Error)]
pub enum NodeKindMigrateError {
    #[error("{0}")]
    Message(String),
}

impl NodeKindMigrateError {
    pub fn message(msg: impl Into<String>) -> Self {
        Self::Message(msg.into())
    }
}