Skip to main content

SnapshotStore

Struct SnapshotStore 

Source
pub struct SnapshotStore { /* private fields */ }
Expand description

redb-backed store for sealed full-tree snapshots.

The store is policy-free: it persists and retrieves snapshots without filtering by age. Staleness enforcement is the consumer’s responsibility.

Implementations§

Source§

impl SnapshotStore

Source

pub fn open(path: impl AsRef<Path>) -> Result<Self, BootnodeError>

Open or create the snapshot store at path.

Source

pub fn put( &self, header: &SnapshotHeader, body: &[u8], ) -> Result<(), BootnodeError>

Persist a snapshot. Overwrites any existing snapshot at the same sequence_no.

Header and body are written in a single transaction.

Source

pub fn get( &self, sequence_no: u64, ) -> Result<Option<SnapshotHeader>, BootnodeError>

Retrieve the header at exactly sequence_no, if any.

Source

pub fn latest_at_most( &self, up_to: u64, ) -> Result<Option<SnapshotHeader>, BootnodeError>

Return the header with the largest sequence_no <= up_to, if any.

Source

pub fn read_body( &self, sequence_no: u64, writer: &mut impl Write, ) -> Result<Option<u64>, BootnodeError>

Stream the body of snapshot sequence_no into writer.

Both tables are opened from the same read transaction for snapshot isolation. The header is the source of truth for existence:

  • Header missing: returns Ok(None) regardless of BODIES_TABLE state. The canonical “not sealed” signal. An orphan body without a matching header is silently inaccessible through this method — correct, because the only insertion path (put) writes header+body atomically, so an orphan body would be evidence of either external tampering or a redb-internal bug, neither of which read_body should service.
  • Header present, body missing: returns BootnodeError::SnapshotBodyLenMismatch with actual: 0. Indicates a torn write or partial restoration.
  • Header present, body present, lengths differ: returns BootnodeError::SnapshotBodyLenMismatch with the actual length. Indicates corruption or a write-side invariant violation.
  • Header present, body present, lengths match: streams body to writer, returns Ok(Some(body_len)).

Trait Implementations§

Source§

impl Debug for SnapshotStore

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more