Struct ReplicationPlanner 

pub struct ReplicationPlanner;

Simple range/visibility-based replication planner.

Implementations

impl ReplicationPlanner

pub fn plan_for_viewer_configured_into<F, E, L>( station: &Station, index: &CellIndex, policies: &PolicyTable, viewer: &ViewerQuery, filter: &F, budget: ReplicationBudget, mode: ReplicationSelectionMode, eligible: E, last_sent: L, scratch: &mut ReplicationScratch, plan: &mut ReplicationPlan, )

where F: VisibilityFilter, E: Fn(&ViewerQuery, EntityHandle, &EntityRecord) -> bool, L: Fn(&ViewerQuery, EntityHandle) -> Option<Tick>,

Plans one viewer through the canonical allocation-light configured kernel.

eligible applies caller-owned dirty or delivery state before budget consumption. last_sent supplies optional caller-owned cadence state; returning None admits the candidate without prior-send delay.

pub fn plan_for_viewers_configured_into<'a, F, E, L>( station: &Station, index: &CellIndex, policies: &PolicyTable, viewers: &[ViewerQuery], filter: &F, budget: ReplicationBudget, mode: ReplicationSelectionMode, max_cached_query_ranges: usize, eligible: E, last_sent: L, scratch: &mut ReplicationScratch, batch: &'a mut ReplicationBatchScratch, ) -> ReplicationBatchView<'a>

where F: VisibilityFilter, E: Fn(&ViewerQuery, EntityHandle, &EntityRecord) -> bool, L: Fn(&ViewerQuery, EntityHandle) -> Option<Tick>,

Plans viewers in input order through the configured reusable kernel.

pub fn plan_for_viewer_into<F: VisibilityFilter>( station: &Station, index: &CellIndex, policies: &PolicyTable, viewer: &ViewerQuery, filter: &F, budget: ReplicationBudget, scratch: &mut ReplicationScratch, plan: &mut ReplicationPlan, )

Plans one viewer into caller-owned scratch and output storage.

pub fn plan_for_viewers_into<'a, F: VisibilityFilter>( station: &Station, index: &CellIndex, policies: &PolicyTable, viewers: &[ViewerQuery], filter: &F, budget: ReplicationBudget, scratch: &mut ReplicationScratch, batch: &'a mut ReplicationBatchScratch, ) -> ReplicationBatchView<'a>

Plans viewers into caller-owned scratch and ordered output storage.

pub fn plan_for_viewer_range_into( station: &Station, index: &CellIndex, policies: &PolicyTable, viewer: &ViewerQuery, budget: ReplicationBudget, scratch: &mut ReplicationScratch, plan: &mut ReplicationPlan, )

Plans one range-only viewer into reusable output with optional SIMD filtering.

pub fn plan_for_viewers_range_into<'a>( station: &Station, index: &CellIndex, policies: &PolicyTable, viewers: &[ViewerQuery], budget: ReplicationBudget, scratch: &mut ReplicationScratch, batch: &'a mut ReplicationBatchScratch, ) -> ReplicationBatchView<'a>

Plans a range-only viewer batch into caller-owned reusable output slots.

Trait Implementations

impl Clone for ReplicationPlanner

fn clone(&self) -> ReplicationPlanner

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for ReplicationPlanner

impl Debug for ReplicationPlanner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ReplicationPlanner

fn default() -> ReplicationPlanner

Returns the “default value” for a type.