pub enum CortexAdapterError {
Redex(RedexError),
Closed,
FoldStopped {
seq: u64,
},
FoldStoppedBeforeSeq {
wanted: u64,
folded_through: Option<u64>,
},
InvalidStartPosition(&'static str),
}Expand description
Errors produced by super::CortexAdapter operations.
Variants§
Redex(RedexError)
Underlying RedEX storage error.
Closed
The adapter has been closed.
FoldStopped
The fold task has stopped (first fold error under
super::FoldErrorPolicy::Stop). Holds the RedEX sequence
at which the fold stopped.
FoldStoppedBeforeSeq
wait_for_seq was asked to wait past a seq the fold task
will never reach: the task halted (close, Stop-policy halt,
retention-evicted tail lag) with the folded watermark in
folded_through. Pre-fix this manifested as
wait_for_seq silently returning () and the caller
reading state that did not reflect the requested seq.
Fields
InvalidStartPosition(&'static str)
open was called with a StartPosition that requires
externally-rehydrated state — FromSeq(n) for n > 0 or
LiveOnly. Callers using these positions must construct
the adapter via super::CortexAdapter::open_from_snapshot
instead so the watermark and state are properly anchored
to the prior events the adapter is going to skip.
Accepting these positions in open would set
initial_watermark = start_seq - 1, making
wait_for_seq(k) for k <= start_seq-1 return immediately
— the adapter would claim those seqs were “applied” while
state had never seen them.
Trait Implementations§
Source§impl Debug for CortexAdapterError
impl Debug for CortexAdapterError
Source§impl Display for CortexAdapterError
impl Display for CortexAdapterError
Source§impl Error for CortexAdapterError
impl Error for CortexAdapterError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
use the Display impl or to_string()