Skip to main content

SnapshotReload

Struct SnapshotReload 

Source
pub struct SnapshotReload<R, W> {
    pub snapshots: Vec<SnapshotSource<R>>,
    pub slots: Vec<IncomingSlot<W>>,
    pub target: u64,
    pub state: StoreState,
    pub provider_access: Vec<ProviderAccessChange>,
    pub cutoffs: Vec<(Slot, StoreChange)>,
    pub boundaries: Vec<BoundaryCoverage>,
    pub operation: Option<OperationUpdate>,
    pub authorship: Arc<dyn Authorship>,
}
Expand description

Complete checked input for an atomic reload. Sync derives the administrative projection from the original signed history carried by the store snapshot and retained slots. Each readable audience reaches target before commit.

Fields§

§snapshots: Vec<SnapshotSource<R>>

Starting snapshot or empty prefix for every readable audience.

§slots: Vec<IncomingSlot<W>>

Consecutive slots after the earliest snapshot through the fixed target.

§target: u64

Greatest selected coverage or required applied slot when loading began.

§state: StoreState

Authenticated membership and keys at the target.

§provider_access: Vec<ProviderAccessChange>

Provider work required by the authenticated state at the fixed target.

§cutoffs: Vec<(Slot, StoreChange)>

Counted admin changes introducing cut-offs, including compacted history.

§boundaries: Vec<BoundaryCoverage>

Activated schema and reset snapshot coverage at the target.

§operation: Option<OperationUpdate>

Initiating operation’s transition committed with the rows.

§authorship: Arc<dyn Authorship>

Authentication of other members’ write evidence.

Auto Trait Implementations§

§

impl<R, W> Freeze for SnapshotReload<R, W>

§

impl<R, W> !RefUnwindSafe for SnapshotReload<R, W>

§

impl<R, W> Send for SnapshotReload<R, W>
where R: Send, W: Send,

§

impl<R, W> Sync for SnapshotReload<R, W>
where R: Sync, W: Sync,

§

impl<R, W> Unpin for SnapshotReload<R, W>
where R: Unpin, W: Unpin,

§

impl<R, W> UnsafeUnpin for SnapshotReload<R, W>

§

impl<R, W> !UnwindSafe for SnapshotReload<R, W>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<T> ErasedDestructor for T
where T: 'static,