Struct CaptureWriter 

pub struct CaptureWriter { /* private fields */ }

A ShardWriter that records every attempt and resolves it according to the paired SinkScript (default: success). Unscripted writes succeed, so happy-path tests need no scripting.

Trait Implementations

impl Clone for CaptureWriter

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 CaptureWriter

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

Formats the value using the given formatter.

impl ShardWriter for CaptureWriter

type Endpoint = ReplicaTag

A connected replica endpoint (e.g. one HTTP client per replica).

fn attach_metrics(&mut self, cx: SinkMetricsCtx)

Receive the SinkMetricsCtx for the writer’s own metric families. Called once by the builder before the writer is shared across shard workers; resolve handles here and store them (they are Arc-backed, so write_batch’s &self can touch them). See SinkMetricsCtx::meter for when it carries no Meter. The default ignores it.

fn write_batch( &self, endpoint: &ReplicaTag, batch: &SealedBatch, ) -> impl Future<Output = Result<(), SinkError>> + Send

Write batch to endpoint durably.

fn probe( &self, endpoint: &ReplicaTag, ) -> impl Future<Output = Result<(), SinkError>> + Send

Connectivity probe for readiness. Defaults to healthy.