tellus 0.2.1

A resilient world of actors for Rust: typed messages, supervision trees, death watch, event sourcing.
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

pub(crate) mod codec;
pub(crate) mod effect;
pub(crate) mod event_sourced;
pub(crate) mod persistence_id;
pub(crate) mod schema_version;
pub(crate) mod seq_no;
pub(crate) mod spawn;
pub(crate) mod store;
pub(crate) mod versioned;

use crate::persistence::{
    codec::{Cbor, Codec},
    store::{EventStore, NoSnapshots, SnapshotStore},
};

/// The persistence wiring for an event-sourced actor: an event store, a snapshot store,
/// [NoSnapshots] unless one is set, and a codec, [Cbor] unless one is set. The codec reading a
/// stream must be the one which wrote it.
#[derive(Debug, Clone)]
pub struct Persistence<E, S = NoSnapshots, C = Cbor> {
    pub(crate) event_store: E,
    pub(crate) snapshot_store: S,
    pub(crate) codec: C,
}

impl<E> Persistence<E>
where
    E: EventStore,
{
    /// Create the persistence wiring with the given event store, without a snapshot store and
    /// with the default [Cbor] codec.
    pub fn new(event_store: E) -> Self {
        Self {
            event_store,
            snapshot_store: NoSnapshots,
            codec: Cbor,
        }
    }
}

impl<E, S, C> Persistence<E, S, C> {
    /// Use the given snapshot store.
    pub fn with_snapshot_store<T>(self, snapshot_store: T) -> Persistence<E, T, C>
    where
        T: SnapshotStore,
    {
        Persistence {
            event_store: self.event_store,
            snapshot_store,
            codec: self.codec,
        }
    }

    /// Use the given codec instead of the default [Cbor].
    pub fn with_codec<T>(self, codec: T) -> Persistence<E, S, T>
    where
        T: Codec,
    {
        Persistence {
            event_store: self.event_store,
            snapshot_store: self.snapshot_store,
            codec,
        }
    }
}