Struct CodecSnapshotStore 

pub struct CodecSnapshotStore<SS, C> { /* private fields */ }

Adapter that bridges a byte-level SnapshotStore<Vec<u8>, P> to a typed SnapshotStore<S, P> by encoding/decoding through an Encode<S> + Decode<S> pair.

Use this when your storage backend works with raw bytes (e.g., fjall) but consumers need typed state. The position P is opaque to the bridge — it passes through untouched.

Implementations

impl<SS, C> CodecSnapshotStore<SS, C>

pub const fn new(store: SS, codec: C) -> Self

Create a new codec-bridged snapshot store.

Trait Implementations

impl<S, P, SS, C> SnapshotStore<S, P> for CodecSnapshotStore<SS, C>

where S: Send + Sync + 'static, P: Send, SS: SnapshotStore<Vec<u8>, P>, C: Encode<S> + OwningCodec<S>,

type Error = CodecSnapshotStoreError<<SS as SnapshotStore<Vec<u8>, P>>::Error, <C as Encode<S>>::Error, <C as Decode<S>>::Error>

Adapter-specific error type.

async fn hydrate( &self, id: &impl Id, schema_version: NonZeroU32, ) -> Result<Hydrated<S, P>, Self::Error>

Load the saved state and position from a single consistent snapshot.

async fn commit( &self, id: &impl Id, schema_version: NonZeroU32, position: P, state: &S, ) -> Result<(), Self::Error>

Save state and position together, in a single transaction.