Enum mz_persist_client::fetch::FetchBatchFilter

pub(crate) enum FetchBatchFilter<T> {
    Snapshot {
        as_of: Antichain<T>,
    },
    Listen {
        as_of: Antichain<T>,
        lower: Antichain<T>,
    },
    Compaction {
        since: Antichain<T>,
    },
}

Variants

Snapshot

Fields

as_of: Antichain<T>

Listen

Fields

as_of: Antichain<T>

lower: Antichain<T>

Compaction

Fields

since: Antichain<T>

Implementations

impl<T: Timestamp + Lattice> FetchBatchFilter<T>

pub(crate) fn filter_ts(&self, t: &mut T) -> bool

Trait Implementations

impl<T: Clone> Clone for FetchBatchFilter<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for FetchBatchFilter<T>

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

Formats the value using the given formatter.

impl<T: Timestamp + Codec64> RustType<ProtoFetchBatchFilter> for FetchBatchFilter<T>

fn into_proto(&self) -> ProtoFetchBatchFilter

Convert a Self into a Proto value.

fn from_proto(proto: ProtoFetchBatchFilter) -> 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.