Expand description
The Zerobus transport seam: the one boundary the sink inverts so its correctness core (ack lane, pool, coverage) is testable without a live Databricks workspace.
ZerobusTransport is a single long-lived stream. submit accepts an
Arrow-IPC-encoded batch fire-and-forget and returns the assigned offset;
wait_for_offset performs one round-trip that confirms every record at or
below that offset (Zerobus acks the highest committed offset, and offsets are
monotonic per stream — this is what makes ADR-0060’s coalescing correct).
The real implementation is crate::databricks (behind the databricks-sdk
feature); a controllable fake drives the tests.
Traits§
- Transport
Factory - Opens (and re-opens, on rebuild) a stream for a target table.
- Zerobus
Transport - One long-lived Zerobus stream.
Type Aliases§
- Offset
- A per-stream logical offset (monotonic for the connection’s lifetime).