eventcore 0.7.0

Type-driven event sourcing library for Rust with atomic multi-stream commands
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

use std::time::Duration;

use eventcore_types::{
    Event, EventStoreError, EventStreamReader, EventStreamSlice, StreamId, StreamWrites,
};

/// Internal effect yielded by the execute pipeline state machine.
///
/// These effects describe store operations that the shell loop dispatches
/// to the `EventStore` trait. The state machine never performs I/O directly.
#[derive(Debug)]
pub(crate) enum StoreEffect {
    /// Read all events from a stream for state reconstruction.
    ReadStream { stream_id: StreamId },
    /// Atomically append events to one or more streams.
    AppendEvents { writes: StreamWrites },
    /// Sleep for a retry backoff duration.
    Sleep { duration: Duration },
}

/// Result of dispatching a `StoreEffect` to the backend.
pub(crate) enum StoreEffectResult<E: Event> {
    /// Result of a `ReadStream` effect.
    StreamRead(Result<EventStreamReader<E>, EventStoreError>),
    /// Result of an `AppendEvents` effect.
    EventsAppended(Result<EventStreamSlice, EventStoreError>),
    /// Sleep completed.
    Slept,
}