Struct Recovery 

pub struct Recovery {
    pub from: WalSeqNo,
    pub end: WalSeqNo,
    pub timings: RecoveryTimings,
    /* private fields */
}

Startup recovery stream and capability to resume from a fenced frontier.

Recovery claims an epoch, adopts the directory, and walks the manifest’s ordered [tail, pending?] candidates with takeover-before-size fencing. This stream then emits the fixed range [from, end). Consume it through None before calling start, which resumes the takeover handle for the first empty frontier or conditionally creates the bootstrap object for a new log.

Fields

from: WalSeqNo

Inclusive database checkpoint supplied to recovery.

end: WalSeqNo

Exclusive recovered boundary and base of the resumed empty frontier.

timings: RecoveryTimings

Phase timings collected up to the point the replay stream is returned.

Implementations

impl Recovery

pub fn sealed_segment_count(&self) -> usize

Number of sealed segments in the recovered chain. Diagnostic only.

pub async fn start(self, config: WalEngineConfig) -> Result<WalHandle, Error>

Conditionally create the segment at end and start the WAL.

This consumes the recovery so startup replay cannot overlap append admission. Calling it before the stream reaches None, or after a replay item failed, returns crate::Error::RecoveryIncomplete.

Trait Implementations

impl Stream for Recovery

type Item = Result<WalRecord, Error>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, context: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.