Enum ApplyError 

pub enum ApplyError {
    ChannelMismatch {
        got: ChannelId,
        expected: ChannelId,
    },
    NonMonotonic {
        index: usize,
    },
    FirstSeqMismatch {
        declared: u64,
        observed: u64,
    },
    StaleChunk {
        first_seq: u64,
        local_next: u64,
    },
    GapBeforeChunk {
        first_seq: u64,
        local_next: u64,
        divergence_suspected: bool,
    },
    AppendFailed(String),
}

Errors surfaced by apply_sync_response.

Variants

ChannelMismatch

channel_id in the response didn’t match the local channel the applicator is bound to. Configuration drift — a misrouted chunk arrived at a coordinator for a different channel.

Fields

got: ChannelId

Channel id observed in the response.

expected: ChannelId

Channel id the applicator is bound to.

NonMonotonic

Events within the chunk are not strictly monotonic on event_seq (gaps or out-of-order). Plan §2: “no gaps within a chunk.”

Fields

index: usize

Zero-based index of the offending event in the chunk.

FirstSeqMismatch

First event’s event_seq doesn’t match the response’s declared first_seq. Pin so a corrupted wire payload doesn’t slip through.

Fields

declared: u64

first_seq from the response header.

observed: u64

event_seq of events[0].

StaleChunk

Chunk’s first_seq lies in the past of the local tail. Per plan §5: replicas drive recovery — apply only events that strictly extend the local log.

Fields

first_seq: u64

first_seq from the response.

local_next: u64

Local RedexFile::next_seq() at apply time.

GapBeforeChunk

Chunk’s first_seq is strictly greater than local_next — there’s a gap the catchup didn’t fill. Replica skips ahead per the §8 rejoin path when the gap exceeds skip_threshold; otherwise the caller re-issues a SYNC_REQUEST for the missing range.

divergence_suspected (R-5): the local tail had data in [leader_first_retained_seq, first_seq). The replica’s log diverges from the leader’s; safety still routes through skip-ahead but operators should review.

Fields

first_seq: u64

first_seq from the response.

local_next: u64

Local RedexFile::next_seq() at apply time.

divergence_suspected: bool

R-5 divergence signal: true iff local_next > leader_first_retained_seq AND local_next > 0 — the replica has events in a range the leader has retained, meaning the histories diverge.

AppendFailed(String)

Underlying append_batch errored. Wrapped string because RedexError isn’t Eq.

Trait Implementations

impl Debug for ApplyError

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

Formats the value using the given formatter.

impl Display for ApplyError

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

Formats the value using the given formatter.

impl Eq for ApplyError

impl Error for ApplyError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl PartialEq for ApplyError

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ApplyError