Skip to main content

load_catalog_replay_inputs

Function load_catalog_replay_inputs 

Source
pub fn load_catalog_replay_inputs<B, C>(
    reader: &EventStoreReader<B>,
    catalog: &mut C,
    plan: &ReplayInputPlan,
) -> Result<ReplayInputs, ReplayInputError>
Expand description

Loads catalog replay inputs from an existing plan.

Event-store entries are returned in durable seq order. Catalog records are loaded through the caller-provided catalog source only; this function does not query live venues or run engine logic.

ยงErrors

Returns ReplayInputError::MissingCatalogSlice when a required slice is missing, ReplayInputError::Catalog when catalog loading fails, and ReplayInputError::EventStore when the reader scan fails.