Struct Encoder 

pub struct Encoder<T> { /* private fields */ }

Encodes window edits into frame payloads, deciding where the group boundaries fall.

The track-free core of Producer. It owns the retained window, so it can restate it whenever a group rolls; that restatement is the whole point of the mode, and is what an append-only log cannot do.

Frames must reach the wire in the order they were encoded, and a frame with keyframe set must open a new group: both the positional indices and the group-scoped DEFLATE window depend on it.

Implementations

impl<T> Encoder<T>

pub fn new(config: ProducerConfig) -> Self

Create an encoder with an empty window, so the first edit opens a group.

pub fn window(&self) -> Vec<Value>

The retained window, oldest first.

The encoder holds this to restate it on a roll, so a caller needs no parallel copy.

pub fn range(&self) -> Range<u64>

Absolute index of the oldest retained record, and of the next one to be pushed.

pub fn pop(&mut self, count: u64) -> Result<Option<Pending<'_, T>>>

Drop count records from the front of the window.

Returns None when there is nothing to drop, so a caller can trim unconditionally. Emits a pop into the open group, or a header restating what is left in a new group.

impl<T: Serialize> Encoder<T>

pub fn push(&mut self, value: &T) -> Result<Pending<'_, T>>

Append one record to the back of the window.

Emits a push into the open group, or a header restating the window (the new record included) when the op budget is spent or a frame was lost.