Struct PendingMutationOverlayV1

Source

pub struct PendingMutationOverlayV1 {Show 13 fields
    pub format_version: u16,
    pub shard_key: ShardKey,
    pub writer_epoch: Epoch,
    pub registered_through: SeqNo,
    pub indexed_through: SeqNo,
    pub get_overlay_through: SeqNo,
    pub conditional_write_through: SeqNo,
    pub collector_visibility_through: SeqNo,
    pub subscription_through: SeqNo,
    pub pending_documents: u64,
    pub pending_tombstones: u64,
    pub pending_bytes: u64,
    pub oldest_age_millis: u64,
}

Expand description

Exact collector-level pending-mutation coverage derived from registered WAL records.

Fields§

§format_version: u16§shard_key: ShardKey§writer_epoch: Epoch§registered_through: SeqNo§indexed_through: SeqNo§get_overlay_through: SeqNo§conditional_write_through: SeqNo§collector_visibility_through: SeqNo§subscription_through: SeqNo§pending_documents: u64§pending_tombstones: u64§pending_bytes: u64§oldest_age_millis: u64

Struct PendingMutationOverlayV1 Copy item path

Fields§

Implementations§

impl PendingMutationOverlayV1

pub fn validate(self) -> Result<(), DerivedContractError>

pub fn lag_operations(self) -> Result<u64, DerivedContractError>

Trait Implementations§

impl Clone for PendingMutationOverlayV1

fn clone(&self) -> Self

fn clone_from(&mut self, source: &Self)

impl Copy for PendingMutationOverlayV1

impl Debug for PendingMutationOverlayV1

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

impl<'de> Deserialize<'de> for PendingMutationOverlayV1

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl Eq for PendingMutationOverlayV1

impl PartialEq for PendingMutationOverlayV1

fn eq(&self, other: &Self) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for PendingMutationOverlayV1

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for PendingMutationOverlayV1

Auto Trait Implementations§

impl Freeze for PendingMutationOverlayV1

impl RefUnwindSafe for PendingMutationOverlayV1

impl Send for PendingMutationOverlayV1

impl Sync for PendingMutationOverlayV1

impl Unpin for PendingMutationOverlayV1

impl UnsafeUnpin for PendingMutationOverlayV1

impl UnwindSafe for PendingMutationOverlayV1

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> From<T> for T

fn from(t: T) -> T

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

fn into(self) -> U

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = !

fn try_from(value: U) -> Result<T, !>

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

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

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

Struct PendingMutationOverlayV1

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

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

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

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

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

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

impl<T> ToOwned for T
where T: Clone,

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

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