Module sink 

The transport-neutral delivery seam: Sink, Receipt, OffsetSpan, and SinkError (ADR-0012/0038).

A Sink accepts an Arrow batch together with the source position it covers and returns a Receipt as soon as the payload is accepted — not when it is durably acknowledged. Durability is confirmed asynchronously and reported by advancing per-sink coverage (twg-offset-store), never by blocking send. This is the fire-and-forget contract ADR-0060 requires; a sink that waits for durability inline serialises itself to one in-flight batch.

OffsetSpan is the source position range a batch covers (topic / partition / [start, end)), transport-neutral so every source and sink share one correlation vocabulary.

Structs

OffsetSpan

A half-open range of source positions [start, end) on one topic partition.

Receipt

The acknowledgement send returns once the payload is accepted by the transport. It carries the submitted source span; durability is reported later by advancing coverage, so a Receipt is emphatically not a durable ack (ADR-0038/0060).

SinkId

Identifies a sink instance for ownership/coverage bookkeeping.

Enums

SinkError

Errors a sink can return from send / flush.

Traits

Sink

A transport-neutral sink: accept Arrow batches fire-and-forget, confirm durability out of band.