Struct EncodedChunk 

pub struct EncodedChunk {
    pub frame: Bytes,
    pub rows: u32,
    pub acks: AckSet,
    pub oldest_ingest: Instant,
    pub oldest_event_ms: i64,
}

A small frame of encoded rows produced on a pipeline thread, the unit shipped over the per-shard queues. Wire frames are concatenable — either the format is headerless (RowBinary rows appended back-to-back) or each frame is one complete, self-describing block (ClickHouse Native), and a concatenation of complete blocks is itself a legal insert stream — so workers accumulate chunks without re-encoding.

Teardown safety: acks is an AckSet — dropping a chunk anywhere (a closed queue, an aborted worker, a parked chunk at teardown) fails its batches so their offsets never commit; only a completed durable write delivers them.

Fields

frame: Bytes

Encoded rows in the sink’s wire format.

rows: u32

Number of rows in frame.

acks: AckSet

Acknowledgement handles of the source batches represented in frame. Consecutive records usually share a batch, so this stays short (the encoder dedupes consecutive identical handles).

oldest_ingest: Instant

When the oldest record in frame entered the terminal stage (ingest-basis end-to-end latency).

oldest_event_ms: i64

Smallest record event time in frame, milliseconds since the epoch (event-basis end-to-end latency).

Trait Implementations

impl Debug for EncodedChunk

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

Formats the value using the given formatter.