Skip to main content

plan_catalog_replay_inputs

Function plan_catalog_replay_inputs 

Source
pub fn plan_catalog_replay_inputs<B, C>(
    reader: &EventStoreReader<B>,
    catalog: &mut C,
    range: ReplaySeqRange,
    catalog_slices: &[CatalogSliceSelector],
) -> Result<ReplayInputPlan, ReplayInputError>
Expand description

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

The event-store range supplies durable replay order. Catalog slices are contextual input selected by the caller; their timestamps bound data lookup but never replace seq ordering.

ยงErrors

Returns an error if:

  • No catalog slices are selected.
  • range is invalid.
  • An unbounded selector cannot inherit bounds from an empty event-store scan.
  • A resolved slice has start > end.
  • Catalog planning fails.
  • The reader scan fails.