Struct mz_storage_client::controller::statistics::StatsInitState
source · pub(super) struct StatsInitState<T>(pub BTreeMap<usize, T>);Expand description
An enum that tracks the lifecycle of statistics objects in the controller.
When sources/sinks are dropped, some state (including statistics) are
cleaned up later, as part of processing the storage controller. This
means that a new statistics update could happen between DROP SOURCE
and cleanup, which is we need to distinguished Uninitialized from
“explicitly removed” so that we no longer consolidate stats for an
item into the shared_stats shared map.
Tuple Fields§
§0: BTreeMap<usize, T>Implementations§
source§impl<T> StatsInitState<T>
impl<T> StatsInitState<T>
sourcepub(super) fn set_if_not_removed(
this: Option<&mut Self>,
worker_id: usize,
val: T
)
pub(super) fn set_if_not_removed( this: Option<&mut Self>, worker_id: usize, val: T )
Set the value for the given id, overriding it if it already exists, and doing nothing if its been removed.
Trait Implementations§
Auto Trait Implementations§
impl<T> RefUnwindSafe for StatsInitState<T>where T: RefUnwindSafe,
impl<T> Send for StatsInitState<T>where T: Send,
impl<T> Sync for StatsInitState<T>where T: Sync,
impl<T> Unpin for StatsInitState<T>
impl<T> UnwindSafe for StatsInitState<T>where T: 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::Requestsource§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.