Trait eventsourced::SnapshotStore

pub trait SnapshotStore: Clone + 'static + Send {
    type Id: Debug;
    type Error: StdError + Send + Sync + 'static;

    // Required methods
    fn save<S, ToBytes, ToBytesError>(
        &mut self,
        id: &Self::Id,
        seq_no: NonZeroU64,
        state: &S,
        to_bytes: &ToBytes
    ) -> impl Future<Output = Result<(), Self::Error>> + Send
       where S: Send + Sync,
             ToBytes: Fn(&S) -> Result<Bytes, ToBytesError> + Sync,
             ToBytesError: StdError + Send + Sync + 'static;
    fn load<S, FromBytes, FromBytesError>(
        &self,
        id: &Self::Id,
        from_bytes: FromBytes
    ) -> impl Future<Output = Result<Option<Snapshot<S>>, Self::Error>> + Send
       where FromBytes: Fn(Bytes) -> Result<S, FromBytesError> + Send,
             FromBytesError: StdError + Send + Sync + 'static;
}

Persistence for snapshots.

Required Associated Types

type Id: Debug

type Error: StdError + Send + Sync + 'static

Required Methods

fn save<S, ToBytes, ToBytesError>( &mut self, id: &Self::Id, seq_no: NonZeroU64, state: &S, to_bytes: &ToBytes ) -> impl Future<Output = Result<(), Self::Error>> + Send

where S: Send + Sync, ToBytes: Fn(&S) -> Result<Bytes, ToBytesError> + Sync, ToBytesError: StdError + Send + Sync + 'static,

Save the given snapshot state for the given entity ID and sequence number.

fn load<S, FromBytes, FromBytesError>( &self, id: &Self::Id, from_bytes: FromBytes ) -> impl Future<Output = Result<Option<Snapshot<S>>, Self::Error>> + Send

where FromBytes: Fn(Bytes) -> Result<S, FromBytesError> + Send, FromBytesError: StdError + Send + Sync + 'static,

Find and possibly load the Snapshot for the given entity ID.

Object Safety

This trait is not object safe.

Implementors

impl<I> SnapshotStore for NoopSnapshotStore<I>

where I: Debug + Clone + Send + Sync + 'static,

type Id = I

type Error = Infallible