pub struct Selector {
pub instance_key: Option<[u8; 16]>,
pub seq_from: Option<u64>,
pub seq_to: Option<u64>,
pub time_from: Option<SystemTime>,
pub time_to: Option<SystemTime>,
pub after: Option<Cursor>,
pub limit: Option<usize>,
}Expand description
A read selector for crate::DurabilityStore::query. All filters are
optional and combine with AND. after + limit drive pagination.
An empty selector (Selector::default()) plus paging therefore yields the
full contracted history for a topic, ordered by (instance_key, sequence).
Fields§
§instance_key: Option<[u8; 16]>Restrict to a single instance.
seq_from: Option<u64>Inclusive lower sequence bound.
seq_to: Option<u64>Inclusive upper sequence bound.
time_from: Option<SystemTime>Inclusive lower created_at bound.
time_to: Option<SystemTime>Inclusive upper created_at bound.
after: Option<Cursor>Return only samples strictly after this (instance_key, sequence).
limit: Option<usize>Maximum samples in the returned page. None = adapter default.
Implementations§
Source§impl Selector
impl Selector
Sourcepub fn after_cursor(&self, cursor: Cursor) -> Self
pub fn after_cursor(&self, cursor: Cursor) -> Self
Builds the selector for the next page after a returned Cursor,
preserving the filter predicate but advancing the pagination anchor.
Sourcepub fn matches(&self, sample: &DurabilitySample) -> bool
pub fn matches(&self, sample: &DurabilitySample) -> bool
Returns true if sample matches the filter predicate (ignores
after/limit, which are pagination, not predicate).