batpak 0.5.0

Event sourcing with causal graphs and policy gates. Sync API, zero async.
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

use crate::event::StoredEvent;
use crate::store::Store;

#[cfg(not(feature = "blake3"))]
#[path = "ancestors_clock.rs"]
mod ancestors_clock;
#[cfg(feature = "blake3")]
#[path = "ancestors_hash.rs"]
mod ancestors_hash;

pub(crate) fn walk_ancestors<State>(
    store: &Store<State>,
    event_id: u128,
    limit: usize,
) -> Vec<StoredEvent<serde_json::Value>> {
    #[cfg(feature = "blake3")]
    {
        ancestors_hash::walk_ancestors_by_hash(store, event_id, limit)
    }

    #[cfg(not(feature = "blake3"))]
    {
        ancestors_clock::walk_ancestors_by_clock(store, event_id, limit)
    }
}