Module restore 

Batch-offset continuity, record placement, and rewrite admission for offline restore verification.

Structs

RestoreBatchFrame

The batch-header fields that place a record in offset and time.

RestoreContentExclusions

Which content patterns matched one record’s raw key and header bytes.

RestoreExclusions

Which operator exclusion predicates matched one record.

RestoreLayout

Offset layout of one rewritten batch.

RestoreProducer

Producer identity and batch kind of one rewritten batch.

RestoreRecordDeltas

One record’s encoded offset and timestamp deltas.

Enums

RestoreFilterDecision

Batch fate after folding the exact per-record selection results.

RestoreReconcileDecision

What restore does with one segment after comparing scan and snapshot.

RestoreSnapshotState

One remote segment’s lifecycle state in the RLMM snapshot, or its absence.

RestoreTimestampType

Kafka’s batch timestamp type: attributes bit 3 (DefaultRecordBatch.TIMESTAMP_TYPE_MASK).

Functions

restore_archive_reconcile

Reconcile one archive-scan observation with one snapshot lifecycle state.

restore_batch_filter_decision

Fold whether the record walk saw at least one keep and one drop.

restore_batch_past_offset_bound

A sorted batch stream may stop exactly when the next batch base is past an inclusive offset bound.

restore_batch_step

Validate one archived batch and return its exclusive next offset.

restore_record_coordinates

Compute one record’s absolute offset and Kafka timestamp within its batch.

restore_record_selected

Keep one record exactly when it is inside both bounds and no exclusion predicate matches. --to-offset is inclusive; --to-timestamp is exclusive.

restore_rewritten_batch_header

Admit a batch header synthesized or re-encoded by restore and return its exclusive offset frontier.

restore_rewritten_record

Validate one retained record against the synthesized header and return its absolute offset and Kafka timestamp.