pub struct PersistedSamplerState {
pub source_cycle_idx: u64,
pub source_record_cursors: Vec<(SourceId, u64)>,
pub epoch: u64,
pub epoch_step: u64,
pub rng_state: u64,
pub triplet_recipe_rr_idx: u64,
pub text_recipe_rr_idx: u64,
pub source_stream_cursors: Vec<(SourceId, u64)>,
}Expand description
Persisted sampler runtime state (cursors, recipe indices, RNG).
Every field here is restored on resume. Notable things NOT persisted:
emitted_text_hashes— cross-batch text dedup restarts fresh after a save/load boundary. The same text may appear on both sides.source_wrapped— reconstructed from the restored cursors.chunk_index/ role cursors — rebuilt from the ingested pool.
Fields§
§source_cycle_idx: u64Source-cycle round-robin index.
source_record_cursors: Vec<(SourceId, u64)>Per-source record cursors.
epoch: u64Current epoch used for deterministic reshuffle.
epoch_step: u64Epoch step counter — incremented once per next_*_batch call.
rng_state: u64Deterministic RNG internal state.
triplet_recipe_rr_idx: u64Round-robin index for triplet recipes.
text_recipe_rr_idx: u64Round-robin index for text recipes.
source_stream_cursors: Vec<(SourceId, u64)>Per-source I/O stream cursors for restart-resume support.
Trait Implementations§
Source§impl Clone for PersistedSamplerState
impl Clone for PersistedSamplerState
Source§fn clone(&self) -> PersistedSamplerState
fn clone(&self) -> PersistedSamplerState
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for PersistedSamplerState
impl Debug for PersistedSamplerState
impl<'__de> Decode<'__de> for PersistedSamplerStatewhere
'__de:,
impl Encode for PersistedSamplerState
Auto Trait Implementations§
impl Freeze for PersistedSamplerState
impl RefUnwindSafe for PersistedSamplerState
impl Send for PersistedSamplerState
impl Sync for PersistedSamplerState
impl Unpin for PersistedSamplerState
impl UnsafeUnpin for PersistedSamplerState
impl UnwindSafe for PersistedSamplerState
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more