Module replay 

Bootstrap replay for restoring cache state after a cache-owned snapshot.

This module is deliberately state-only: it consumes event-store entries, decodes the cache-affecting payloads, and mutates [nautilus_common::cache::Cache] directly. It does not publish to the live message bus, send commands, invoke adapters, or submit entries back into the event store.

Structs

CacheReplayReport

Summary of a cache snapshot-tail replay.

CatalogReplayRecord

Catalog record loaded for replay context.

CatalogReplaySlice

Loaded catalog records for one planned slice.

CatalogSliceCoverage

Catalog file and interval coverage for a planned slice.

CatalogSlicePlan

Planned catalog slice joined to a replay input scan.

CatalogSliceQuery

Resolved catalog query after replay time bounds have been applied.

CatalogSliceSelector

Caller-selected data catalog slice before replay window defaults are applied.

EventStoreReplayReport

Summary of an event-store replay source and cache restore.

ParquetReplayCatalog

Read-only replay catalog adapter backed by [ParquetDataCatalog].

ReplayInputPlan

Planned replay inputs for an event-store scan with optional catalog context.

ReplayInputs

Loaded replay inputs with event-store entries and optional catalog context.

ReplaySeqRange

Inclusive event-store seq bounds for replay input scans.

ReplayTimeRange

Inclusive nanosecond time bounds for catalog slice selection.

Enums

CacheReplayError

Errors surfaced while restoring a cache snapshot tail.

CatalogReplayData

Typed catalog data loaded for replay context.

ReplayInputError

Errors surfaced while planning or loading replay inputs.

Traits

ReplayCatalog

Read-only catalog source used by catalog-joined replay input loaders.

Functions

apply_cache_replay_entry

Applies one event-store entry to cache state when a replay rule exists.

load_catalog_replay_inputs

Loads catalog replay inputs from an existing plan.

load_forensics_replay_inputs

Loads event-store-only forensics replay inputs.

open_event_store_replay_source

Opens a sealed run for replay without touching live venues.

plan_catalog_replay_inputs

Plans replay inputs by joining event-store entries with selected catalog slices.

plan_forensics_replay_inputs

Plans event-store-only forensics replay inputs.

replay_cache_snapshot_tail

Replays the cache snapshot tail when the cache snapshot has already been restored.

restore_cache_from_sealed_run

Restores cache state from a sealed run without publishing to the bus or touching live venues.

restore_cache_snapshot_and_replay_tail

Replays the cache snapshot tail after the caller restores the cache-owned snapshot blob.

restore_cache_snapshot_blob

Restores the cache-owned snapshot blob identified by anchor.

validate_event_store_replay_source

Validates that a configured replay source exists, is sealed, and is not quarantined.