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.

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

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

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 order.

Trait Implementations

impl Clone for SinkScript

fn clone(&self) -> SinkScript

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.