Struct DeterministicSplitStore 

pub struct DeterministicSplitStore { /* private fields */ }

In-memory split store with deterministic assignment derivation.

Implementations

impl DeterministicSplitStore

pub fn new(ratios: SplitRatios, seed: u64) -> Result<Self, SamplerError>

Create an in-memory split store configured with ratios and seed.

Trait Implementations

impl EpochStateStore for DeterministicSplitStore

fn load_epoch_meta( &self, ) -> Result<HashMap<SplitLabel, PersistedSplitMeta>, SamplerError>

Load split→epoch metadata map.

fn load_epoch_hashes( &self, label: SplitLabel, ) -> Result<Option<PersistedSplitHashes>, SamplerError>

Load persisted epoch hashes for one split, if available.

fn save_epoch_meta( &self, meta: &HashMap<SplitLabel, PersistedSplitMeta>, ) -> Result<(), SamplerError>

Persist split→epoch metadata map.

fn save_epoch_hashes( &self, label: SplitLabel, hashes: &PersistedSplitHashes, ) -> Result<(), SamplerError>

Persist epoch hash list for one split.

impl SamplerStateStore for DeterministicSplitStore

fn load_sampler_state( &self, ) -> Result<Option<PersistedSamplerState>, SamplerError>

Load persisted sampler runtime state, if present.

fn save_sampler_state( &self, state: &PersistedSamplerState, _save_path: Option<&Path>, ) -> Result<(), SamplerError>

Save sampler runtime state, optionally mirroring to save_path.

impl SplitStore for DeterministicSplitStore

fn label_for(&self, id: &RecordId) -> Option<SplitLabel>

Return split label for id if known/derivable.

fn upsert(&self, id: RecordId, label: SplitLabel) -> Result<(), SamplerError>

Persist an explicit split assignment for id.

fn ratios(&self) -> SplitRatios

Return configured split ratios.

fn ensure(&self, id: RecordId) -> Result<SplitLabel, SamplerError>

Return the split label for id, creating/deriving one when needed.