kmp-domain 0.18.6

Domain model of the Kernel Memory Protocol: aggregates, value objects, repositories and projections, with no IO
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

use super::{ConsolidatedView, ConsolidationRead, ConsolidationSource, ConsolidationWrite};
use crate::PortError;
use std::{fmt::Debug, future::Future, pin::Pin};

pub type ConsolidationFuture<'a, T> =
    Pin<Box<dyn Future<Output = Result<T, PortError>> + Send + 'a>>;

/// Capture and read each use one snapshot. Admission, CAS, source checks,
/// idempotency receipt and immutable revision insertion share one transaction.
pub trait ConsolidationStore: Debug + Send + Sync {
    fn consolidation_sources(
        &self,
        about: String,
        refs: Vec<String>,
    ) -> ConsolidationFuture<'_, Vec<ConsolidationSource>>;
    fn write_consolidation(
        &self,
        command: ConsolidationWrite,
    ) -> ConsolidationFuture<'_, ConsolidatedView>;
    /// An explicit revision is an audit, never current evidence. Current reads
    /// return no derived claims if any declared dependency has changed.
    fn read_consolidation(
        &self,
        about: String,
        view: String,
        revision: Option<u64>,
    ) -> ConsolidationFuture<'_, ConsolidationRead>;
}