myko 6.3.0

myko in rust
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

//! Trait for replaying persisted events into a temporary store.

use std::sync::Arc;

use crate::{server::HandlerRegistry, store::StoreRegistry};

/// Provider for replaying historical events into a temporary `StoreRegistry`.
///
/// Implemented by the server layer (e.g., `PostgresHistoryReplayProvider`)
/// to enable point-in-time snapshots without coupling myko to a
/// specific persistence backend.
pub trait HistoryReplayProvider: Send + Sync {
    /// Replay all events with `created_at <= until` into a fresh `StoreRegistry`.
    ///
    /// `until` is an ISO 8601 timestamp string.
    ///
    /// # Errors
    ///
    /// Returns an error when the requested operation cannot be completed.
    fn replay_to_store(
        &self,
        until: &str,
        handler_registry: &HandlerRegistry,
    ) -> Result<Arc<StoreRegistry>, String>;
}