pub enum InvariantCheck {
SetByThisWorker,
Matched,
Mismatched {
diff: String,
},
}Expand description
Outcome of comparing a worker’s first packet against the rung’s
codec invariant. The caller — run_encoder_worker_blocking —
branches on this to decide whether to keep encoding, soft-fail
(requeue the chunk for another worker), or hard-fail (parse error
from a malformed bitstream).
Variants§
SetByThisWorker
First worker on the rung. Invariant has been recorded.
Matched
Matches the rung’s invariant. Proceed to publish.
Mismatched
Mandatory fields mismatch. Worker should requeue its chunk and exit cleanly; the rung continues with workers whose vendors agree with the invariant the first worker set. Mission- critical jobs DO NOT abort on this — only this one helper’s contribution is lost, and another worker picks up the chunk.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for InvariantCheck
impl RefUnwindSafe for InvariantCheck
impl Send for InvariantCheck
impl Sync for InvariantCheck
impl Unpin for InvariantCheck
impl UnsafeUnpin for InvariantCheck
impl UnwindSafe for InvariantCheck
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more