Enum Iq2Query 

pub enum Iq2Query {
    Key {
        key: Box<dyn Any + Send + Sync>,
    },
    Range {
        lo: Option<Box<dyn Any + Send + Sync>>,
        hi: Option<Box<dyn Any + Send + Sync>>,
        descending: bool,
    },
    WindowKey {
        key: Box<dyn Any + Send + Sync>,
        from_ts: i64,
        to_ts: i64,
    },
    WindowRange {
        lo: Option<Box<dyn Any + Send + Sync>>,
        hi: Option<Box<dyn Any + Send + Sync>>,
        from_ts: i64,
        to_ts: i64,
    },
    VersionedKey {
        key: Box<dyn Any + Send + Sync>,
        as_of: Option<i64>,
    },
    MultiVersionedKey {
        key: Box<dyn Any + Send + Sync>,
        from_ts: Option<i64>,
        to_ts: Option<i64>,
        descending: bool,
    },
}

A typed IQv2 query lowered to the store boundary.

Keys travel as Box<dyn Any + Send + Sync>, which holds the raw K. The concrete store downcasts to its own K, serializes with its own key serde, runs the op, and returns the typed result boxed as Box<dyn Any + Send>. That result is an Option<V>, a Vec<(K,V)>, or a similar type.

Time bounds are plain i64, and the ordering and bound choices are flags. No serde and no K or V appear here. That is the whole point of the byte-level boundary.

Variants

Key

KeyQuery: single key. Result: Option<V>.

Fields

key: Box<dyn Any + Send + Sync>

Range

RangeQuery: a None bound is unbounded on that side. Result: Vec<(K,V)>.

Fields

lo: Option<Box<dyn Any + Send + Sync>>

hi: Option<Box<dyn Any + Send + Sync>>

descending: bool

WindowKey

WindowKeyQuery: one key, window starts in [from_ts, to_ts]. Result: Vec<(i64 /*windowStart*/, V)>, ascending by start.

Fields

key: Box<dyn Any + Send + Sync>

from_ts: i64

to_ts: i64

WindowRange

WindowRangeQuery: key range by window-start range. A None bound is unbounded on that side. Result: Vec<((K, i64 /*windowStart*/), V)>, ascending by (key bytes, windowStart).

Fields

lo: Option<Box<dyn Any + Send + Sync>>

hi: Option<Box<dyn Any + Send + Sync>>

from_ts: i64

to_ts: i64

VersionedKey

VersionedKeyQuery (KIP-960): one key. as_of = None gives the latest live version, and Some(t) gives the version valid at t. Result: Option<VersionedRecord<V>>.

Fields

key: Box<dyn Any + Send + Sync>

as_of: Option<i64>

MultiVersionedKey

MultiVersionedKeyQuery (KIP-968): one key, and every version whose validity [valid_from, valid_to) overlaps [from_ts, to_ts]. A None bound is unbounded on that side. The order is ascending by valid_from, unless descending is set. Result: Vec<VersionedRecord<V>>.

Fields

key: Box<dyn Any + Send + Sync>

from_ts: Option<i64>

to_ts: Option<i64>

descending: bool