Struct ReplayPlan 

pub struct ReplayPlan {
    pub branch: BranchId,
    pub streams: StreamSelector,
    pub from: Bound<u64>,
    pub until: ReplayEnd,
    pub time: Option<Range<i64>>,
    pub max_events: Option<u64>,
    pub verification: VerificationMode,
}

A declarative replay request (spec/04). Resolved against the log and branch catalog by Salamander::read.

Fields

branch: BranchId

Branch whose (inherited) history to read.

streams: StreamSelector

Which streams to include.

from: Bound<u64>

Lower bound on global position.

until: ReplayEnd

Where to stop (exclusive).

time: Option<Range<i64>>

Half-open envelope-timestamp filter (unix nanos). Timestamps are not monotonic in the log, so this is an exact per-record filter; sidecar min/max ranges are used only as a segment-skip hint.

max_events: Option<u64>

Stop after yielding this many events, if set.

verification: VerificationMode

How much integrity re-verification to perform while reading.

Trait Implementations

impl Clone for ReplayPlan

fn clone(&self) -> ReplayPlan

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplayPlan

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

Formats the value using the given formatter.

impl Default for ReplayPlan

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ReplayPlan

impl PartialEq for ReplayPlan

fn eq(&self, other: &ReplayPlan) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ReplayPlan