pub struct ChurnHarness { /* private fields */ }Expand description
Deterministic fake host boundary for recovery conformance tests.
Implementations§
Source§impl ChurnHarness
impl ChurnHarness
Sourcepub const fn kernel(&self) -> &HostSessionKernel
pub const fn kernel(&self) -> &HostSessionKernel
Returns the underlying kernel for precise assertions.
Sourcepub fn dispatched(&self) -> &[FramedMessage]
pub fn dispatched(&self) -> &[FramedMessage]
Returns every frame that crossed the fake worker dispatch boundary.
Sourcepub fn dispatch_first(
&mut self,
frame: &FramedMessage,
contract: ReplayContract,
pending_capacity: usize,
) -> Result<RequestId, HostRejection>
pub fn dispatch_first( &mut self, frame: &FramedMessage, contract: ReplayContract, pending_capacity: usize, ) -> Result<RequestId, HostRejection>
Begins and records one first worker dispatch.
Sourcepub fn kill_worker(&mut self, budget: ReplayBudget) -> ReplayRequeueOutcome
pub fn kill_worker(&mut self, budget: ReplayBudget) -> ReplayRequeueOutcome
Applies worker loss and rebuilds the recovery queue.
Sourcepub fn dispatch_next(&mut self) -> Result<DispatchQueueOutcome, HostRejection>
pub fn dispatch_next(&mut self) -> Result<DispatchQueueOutcome, HostRejection>
Takes one recovery-ordered dispatch and records actual redispatches.
Sourcepub fn resolve_probe(
&mut self,
request_id: &RequestId,
resolution: ProbeResolution,
max_attempts: u8,
) -> Result<ProbeResolutionOutcome, HostRejection>
pub fn resolve_probe( &mut self, request_id: &RequestId, resolution: ProbeResolution, max_attempts: u8, ) -> Result<ProbeResolutionOutcome, HostRejection>
Supplies explicit evidence for one held probe-required invocation.
Sourcepub fn complete(
&mut self,
response: &FramedMessage,
) -> Result<CompletedPendingRequest, HostRejection>
pub fn complete( &mut self, response: &FramedMessage, ) -> Result<CompletedPendingRequest, HostRejection>
Records one terminal public response.
Trait Implementations§
Source§impl Clone for ChurnHarness
impl Clone for ChurnHarness
Auto Trait Implementations§
impl Freeze for ChurnHarness
impl RefUnwindSafe for ChurnHarness
impl Send for ChurnHarness
impl Sync for ChurnHarness
impl Unpin for ChurnHarness
impl UnsafeUnpin for ChurnHarness
impl UnwindSafe for ChurnHarness
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