Struct mz_persist_client::internal::state::LeasedReaderState

pub struct LeasedReaderState<T> {
    pub seqno: SeqNo,
    pub since: Antichain<T>,
    pub last_heartbeat_timestamp_ms: u64,
    pub lease_duration_ms: u64,
    pub debug: HandleDebugState,
}

Fields

seqno: SeqNo

The seqno capability of this reader.

since: Antichain<T>

The since capability of this reader.

last_heartbeat_timestamp_ms: u64

UNIX_EPOCH timestamp (in millis) of this reader’s most recent heartbeat

lease_duration_ms: u64

Duration (in millis) allowed after Self::last_heartbeat_timestamp_ms after which this reader may be expired

debug: HandleDebugState

For debugging.

Trait Implementations

impl<T: Clone> Clone for LeasedReaderState<T>

fn clone(&self) -> LeasedReaderState<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for LeasedReaderState<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for LeasedReaderState<T>

fn eq(&self, other: &LeasedReaderState<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T: Timestamp + Codec64> RustType<ProtoLeasedReaderState> for LeasedReaderState<T>

fn into_proto(&self) -> ProtoLeasedReaderState

Convert a Self into a Proto value.

fn from_proto(proto: ProtoLeasedReaderState) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

fn into_proto_owned(self) -> Proto

A zero clone version of Self::into_proto that types can optionally implement, otherwise, the default implementation delegates to Self::into_proto.

impl<T> Serialize for LeasedReaderState<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> StructuralPartialEq for LeasedReaderState<T>