Struct mz_persist_client::internal::state::TypedState
source · pub struct TypedState<K, V, T, D> {
pub(crate) state: State<T>,
pub(crate) _phantom: PhantomData<fn() -> (K, V, D)>,
}
Expand description
A newtype wrapper of State that guarantees the K, V, and D codecs match the ones in durable storage.
Fields§
§state: State<T>
§_phantom: PhantomData<fn() -> (K, V, D)>
Implementations§
source§impl<K, V, T: Clone, D> TypedState<K, V, T, D>
impl<K, V, T: Clone, D> TypedState<K, V, T, D>
source§impl<K, V, T, D> TypedState<K, V, T, D>where
K: Codec,
V: Codec,
T: Timestamp + Lattice + Codec64,
D: Codec64,
impl<K, V, T, D> TypedState<K, V, T, D>where K: Codec, V: Codec, T: Timestamp + Lattice + Codec64, D: Codec64,
pub fn new( applier_version: Version, shard_id: ShardId, hostname: String, walltime_ms: u64 ) -> Self
pub fn clone_apply<R, E, WorkFn>( &self, cfg: &PersistConfig, work_fn: &mut WorkFn ) -> ControlFlow<E, (R, Self)>where WorkFn: FnMut(SeqNo, &PersistConfig, &mut StateCollections<T>) -> ControlFlow<E, R>,
Methods from Deref<Target = State<T>>§
pub fn shard_id(&self) -> ShardId
pub fn seqno(&self) -> SeqNo
pub fn since(&self) -> &Antichain<T>
pub fn upper(&self) -> &Antichain<T>
pub fn spine_batch_count(&self) -> usize
pub fn size_metrics(&self) -> StateSizeMetrics
pub fn latest_rollup(&self) -> (&SeqNo, &HollowRollup)
pub(crate) fn seqno_since(&self) -> SeqNo
pub fn maybe_gc(&mut self, is_write: bool) -> Option<GcReq>
sourcepub fn seqnos_held(&self) -> usize
pub fn seqnos_held(&self) -> usize
Return the number of gc-ineligible state versions.
sourcepub fn expire_at(&mut self, walltime_ms: EpochMillis) -> ExpiryMetrics
pub fn expire_at(&mut self, walltime_ms: EpochMillis) -> ExpiryMetrics
Expire all readers and writers up to the given walltime_ms.
sourcepub fn snapshot(
&self,
as_of: &Antichain<T>
) -> Result<Vec<HollowBatch<T>>, SnapshotErr<T>>
pub fn snapshot( &self, as_of: &Antichain<T> ) -> Result<Vec<HollowBatch<T>>, SnapshotErr<T>>
Returns the batches that contain updates up to (and including) the given as_of
. The
result Vec
contains blob keys, along with a Description
of what updates in the
referenced parts are valid to read.
pub fn verify_listen( &self, as_of: &Antichain<T> ) -> Result<Result<(), Upper<T>>, Since<T>>
pub fn next_listen_batch( &self, frontier: &Antichain<T> ) -> Result<HollowBatch<T>, SeqNo>
pub fn need_rollup(&self, threshold: usize) -> Option<SeqNo>
pub(crate) fn map_blobs<F: for<'a> FnMut(HollowBlobRef<'a, T>)>(&self, f: F)
pub fn apply_encoded_diffs<'a, I: IntoIterator<Item = &'a VersionedData>>( &mut self, cfg: &PersistConfig, metrics: &Metrics, diffs: I )
pub fn apply_diffs<I: IntoIterator<Item = (StateDiff<T>, Bytes)>>( &mut self, metrics: &Metrics, diffs: I )
fn apply_diff( &mut self, metrics: &Metrics, diff: StateDiff<T> ) -> Result<(), String>
Trait Implementations§
source§impl<K, V, T: Debug, D> Debug for TypedState<K, V, T, D>
impl<K, V, T: Debug, D> Debug for TypedState<K, V, T, D>
source§impl<K, V, T, D> Deref for TypedState<K, V, T, D>
impl<K, V, T, D> Deref for TypedState<K, V, T, D>
source§impl<K, V, T, D> DerefMut for TypedState<K, V, T, D>
impl<K, V, T, D> DerefMut for TypedState<K, V, T, D>
source§impl<K, V, T, D> From<TypedState<K, V, T, D>> for UntypedState<T>where
K: Codec,
V: Codec,
T: Codec64,
D: Codec64,
impl<K, V, T, D> From<TypedState<K, V, T, D>> for UntypedState<T>where K: Codec, V: Codec, T: Codec64, D: Codec64,
source§fn from(typed_state: TypedState<K, V, T, D>) -> Self
fn from(typed_state: TypedState<K, V, T, D>) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl<K, V, T, D> RefUnwindSafe for TypedState<K, V, T, D>where T: RefUnwindSafe,
impl<K, V, T, D> Send for TypedState<K, V, T, D>where T: Send + Sync,
impl<K, V, T, D> Sync for TypedState<K, V, T, D>where T: Send + Sync,
impl<K, V, T, D> Unpin for TypedState<K, V, T, D>where T: Unpin,
impl<K, V, T, D> UnwindSafe for TypedState<K, V, T, D>where T: UnwindSafe + RefUnwindSafe,
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> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.