Struct FileSplitStore 

pub struct FileSplitStore { /* private fields */ }

File-backed split store for persistent runs (metadata + epoch/sampler state).

Implementations

impl FileSplitStore

pub fn open<P: Into<PathBuf>>( path: P, ratios: SplitRatios, seed: u64, ) -> Result<Self, SamplerError>

pub fn default_path() -> PathBuf

pub fn default_path_in_dir<P: AsRef<Path>>(dir: P) -> PathBuf

Trait Implementations

impl Debug for FileSplitStore

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

Formats the value using the given formatter.

impl EpochStateStore for FileSplitStore

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

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

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

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

impl SamplerStateStore for FileSplitStore

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

fn store_sampler_state( &self, state: &PersistedSamplerState, ) -> Result<(), SamplerError>

impl SplitStore for FileSplitStore

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

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

fn ratios(&self) -> SplitRatios

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

Returns the split label for id.