Module local_recovery 

Local-log segment-chain and torn-tail recovery decisions.

Structs

LocalRecoveryStep

LocalRecoverySwapFacts

What Log::open observes at one base offset that carries a compaction .swap file, from a single directory listing.

Enums

LocalRecoverySwapAction

Crash-recovery action for one base offset that carries .swap files.

Functions

local_recovery_batch_step

Admit one completely decoded batch into the maximal valid tail prefix.

local_recovery_index_frontier

The exclusive frontier of a recovered segment, relative to its base, when it fits Kafka’s 32-bit relative-offset index.

local_recovery_sealed_last

Close a sealed segment exactly one offset before the next segment base.

local_recovery_segment_chain

Validate the discovered segment bases as one strictly ordered, nonnegative chain.

local_recovery_swap_action

Classify one swap set: abort it only while it is uncommitted, and complete it whenever it is committed, whether or not the original log still exists.

local_recovery_swap_replaces

Whether completing a swap based at swap_base, whose records end before swap_next, replaces the segment based at segment_base.