Module storage 

Storage-transition admission decisions.

Structs

LocalTruncationPlan

Segment-prefix and active-segment selection for a tail truncation.

Enums

RemoteCacheAction

Mutation of the primary remote-metadata cache and its derived epoch index.

RemotePartitionDeleteLifecycle

KIP-405 RemotePartitionDeleteState.

RemoteSegmentLifecycle

KIP-405 RemoteLogSegmentState, shared by every remote-segment kernel so the host maps its state onto one type.

Functions

future_log_swap_admission

A future log may replace the current log only at the exact same frontier.

local_append_coordinates

Admit one batch at the expected logical frontier or beyond it, and compute its inclusive last offset and exclusive successor without signed overflow.

local_truncation_plan

Keep exactly the sealed-segment prefix whose bases precede the cut and keep the current active segment exactly when its base also precedes the cut.

remote_cache_action

Classify one remote-segment cache update against the cached state, None when the cache holds no such segment.

remote_partition_delete_transition

Kafka’s RemotePartitionDeleteState.isValidTransition: with no prior state only DELETE_PARTITION_MARKED is admitted; otherwise a forward edge or an idempotent self transition.

remote_segment_transition

Kafka’s RemoteLogSegmentState.isValidTransition for a known source state: a forward lifecycle edge, or a self transition, which Kafka admits so retries and failover stay idempotent.

truncation_batch_retained

One decoded batch belongs to the exact retained prefix iff its inclusive last offset is below the exclusive cut.

truncation_frontier

Clamp a dependent frontier to the new log end.

truncation_relative_offset

Convert an absolute cut to a segment-relative offset without signed or u32 overflow. Segment bases and log cuts are nonnegative Kafka offsets.