trellis-core 0.2.1

Deterministic reconciler: state changes in; resource commands, output frames, and auditable receipts out.
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

use crate::{
    CollectionNode, GraphError, GraphResult, MapDiff, PlanContext, PlanError, ResourceKey,
    ResourcePlan, SetDiff, Transaction, resource::ResourcePlanner,
};

impl<C: 'static> Transaction<'_, C> {
    /// Stages a map-diff resource planner.
    pub fn map_resource_planner<K, V>(
        &mut self,
        collection: CollectionNode<K, V>,
        scope: crate::ScopeId,
        planner: impl for<'ctx> Fn(
            &PlanContext<'ctx, MapDiff<K, V>>,
        ) -> Result<ResourcePlan<C>, PlanError>
        + Send
        + Sync
        + 'static,
    ) -> GraphResult<()>
    where
        K: Clone + Ord + Send + Sync + 'static,
        V: Clone + PartialEq + Send + Sync + 'static,
    {
        self.ensure_open()?;
        self.working.require_scope_open(scope)?;
        self.working
            .validate_map_collection_read::<K, V>(collection.id())?;
        let resource_planner = ResourcePlanner::new(collection.id(), scope, move |graph| {
            let Some(diff) = graph.map_diff(collection)? else {
                return Ok(ResourcePlan::new());
            };
            let ctx = PlanContext::new(scope, diff);
            planner(&ctx).map_err(|error| GraphError::PlanFailed(scope, error))
        });
        self.staged_resource_planner_collections
            .push(collection.id());
        self.working.resource_planners.push(resource_planner);
        self.graph_mutated = true;
        Ok(())
    }

    /// Stages a set-diff resource planner.
    pub fn set_resource_planner<K>(
        &mut self,
        collection: CollectionNode<K, ()>,
        scope: crate::ScopeId,
        planner: impl for<'ctx> Fn(&PlanContext<'ctx, SetDiff<K>>) -> Result<ResourcePlan<C>, PlanError>
        + Send
        + Sync
        + 'static,
    ) -> GraphResult<()>
    where
        K: Clone + Ord + Send + Sync + 'static,
    {
        self.ensure_open()?;
        self.working.require_scope_open(scope)?;
        self.working
            .validate_set_collection_read::<K>(collection.id())?;
        let resource_planner = ResourcePlanner::new(collection.id(), scope, move |graph| {
            let Some(diff) = graph.set_diff(collection)? else {
                return Ok(ResourcePlan::new());
            };
            let ctx = PlanContext::new(scope, diff);
            planner(&ctx).map_err(|error| GraphError::PlanFailed(scope, error))
        });
        self.staged_resource_planner_collections
            .push(collection.id());
        self.working.resource_planners.push(resource_planner);
        self.graph_mutated = true;
        Ok(())
    }

    /// Stages a set-diff planner that opens added members and closes removed members.
    pub fn open_close_planner<K>(
        &mut self,
        collection: CollectionNode<K, ()>,
        scope: crate::ScopeId,
        key: impl Fn(&K) -> ResourceKey + Send + Sync + 'static,
        open: impl Fn(&K) -> C + Send + Sync + 'static,
    ) -> GraphResult<()>
    where
        K: Clone + Ord + Send + Sync + 'static,
    {
        self.set_resource_planner(collection, scope, move |ctx| {
            let mut plan = ResourcePlan::new();
            for added in &ctx.diff().added {
                plan.open(key(&added.value), ctx.scope(), open(&added.value));
            }
            for removed in &ctx.diff().removed {
                plan.close(key(&removed.value), ctx.scope());
            }
            Ok(plan)
        })
    }
}