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 at all.

Trait Implementations

impl Clone for CaptureWriter

fn clone(&self) -> CaptureWriter

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, meter: Option<Meter>)

Receive a Meter scoped spate_<component_type>_sink_* for the sink’s own metric families, pre-labelled with the standard pipeline/component/component_type. 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). None when the sink’s component_type cannot scope a family: the default "custom" (reserved for pipeline-author metrics) or a reserved root opts out silently, and a malformed value is logged and also yields None — so declare a distinct component_type via SinkParts::with_component_type to receive a scope. Defaults to ignoring 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.