Module raft 

Pure KRaft offset-frontier and half-open-window kernels.

Structs

FetchContent

Which mutations the response body carries.

FetchFence

The receiving node’s live fence for one Fetch response.

FetchResponseFacts

Who answered a Fetch, and which leader, epoch and error the answer names.

Enums

FetchResponseMutation

The only response-derived mutation an admitted KRaft Fetch may perform.

Functions

advance_high_watermark

Advance a high watermark monotonically without passing the log end.

control_history_frontier

Return the length of the strictly ordered control-record prefix below a half-open frontier.

fetch_response_mutation

Fence a Fetch response against the live role, leader, and epoch, then select exactly one mutation path.

frontier_reaches

Whether a monotonic frontier has reached a target offset.

in_half_open_window

Whether value lies in [start, end).

metadata_record_offset_deltas

The contiguous offset deltas 0, 1, ..., record_count - 1 of one metadata batch, in record order; the last element is the batch’s lastOffsetDelta.