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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! Store snapshot construction helpers.

use crate::io::{NodeGraphInteractionConfig, NodeGraphRuntimeTuning, NodeGraphViewState};
use crate::runtime::events::NodeGraphStoreSnapshot;
use jellyflow_core::core::Graph;
use jellyflow_core::ops::GraphHistory;

use super::NodeGraphStore;

pub(super) struct StoreSnapshotParts<'a> {
    graph: &'a Graph,
    graph_revision: u64,
    layout_facts_revision: u64,
    view_state: &'a NodeGraphViewState,
    interaction: &'a NodeGraphInteractionConfig,
    runtime_tuning: &'a NodeGraphRuntimeTuning,
    history: &'a GraphHistory,
}

impl<'a> StoreSnapshotParts<'a> {
    pub(super) fn from_store_fields(
        graph: &'a Graph,
        graph_revision: u64,
        layout_facts_revision: u64,
        view_state: &'a NodeGraphViewState,
        interaction: &'a NodeGraphInteractionConfig,
        runtime_tuning: &'a NodeGraphRuntimeTuning,
        history: &'a GraphHistory,
    ) -> Self {
        Self {
            graph,
            graph_revision,
            layout_facts_revision,
            view_state,
            interaction,
            runtime_tuning,
            history,
        }
    }

    fn from_store(store: &'a NodeGraphStore) -> Self {
        Self::from_store_fields(
            &store.graph,
            store.graph_revision,
            store.layout_facts_revision,
            &store.view_state,
            &store.interaction,
            &store.runtime_tuning,
            &store.history,
        )
    }

    pub(super) fn snapshot(&self) -> NodeGraphStoreSnapshot<'a> {
        NodeGraphStoreSnapshot::new(
            self.graph,
            self.graph_revision,
            self.layout_facts_revision,
            self.view_state,
            self.interaction,
            self.runtime_tuning,
            self.history,
        )
    }
}

impl NodeGraphStore {
    pub(super) fn snapshot(&self) -> NodeGraphStoreSnapshot<'_> {
        StoreSnapshotParts::from_store(self).snapshot()
    }
}