Struct SinkScript 

pub struct SinkScript { /* private fields */ }

Scripts outcomes for a CaptureWriter and reads back its captures. Cloneable; all clones address the same writer.

Implementations

impl SinkScript

pub fn enqueue_global(&self, outcome: WriteOutcome)

Queue an outcome consumed by the next otherwise-unscripted write to any endpoint (FIFO). Endpoint-specific scripts take precedence.

Panics

If outcome.result is Pending.

pub fn enqueue_for(&self, shard: usize, replica: usize, outcome: WriteOutcome)

Queue an outcome for the next write to (shard, replica) (FIFO).

Panics

If outcome.result is Pending.

pub fn fail_probe( &self, shard: usize, replica: usize, reason: impl Into<String>, )

Make ShardWriter::probe of (shard, replica) fail with a retryable error until heal_probe.

pub fn heal_probe(&self, shard: usize, replica: usize)

Let (shard, replica)’s probe succeed again.

pub fn writes(&self) -> Vec<CapturedWrite>

Every write attempt so far, in the order they started.

An attempt reads Pending until its write resolves.

pub fn release_held(&self)

Release every write currently held by a held outcome.

A held outcome that a later write consumes holds again until the next call.

pub fn held_writes(&self) -> usize

How many writes are waiting on release_held.

Trait Implementations

impl Clone for SinkScript

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SinkScript

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

Formats the value using the given formatter.