Struct FilteredPage 

pub struct FilteredPage {

    pub v: u32,
    pub partition_id: u32,
    pub policy: AppliedPolicy,
    pub generation: SourceGeneration,
    pub ack_context: AckContext,
    pub next_scan_offset: Option<u64>,
    pub safe_ack_offset: Option<u64>,
    pub frontier: u64,
    pub examined: u32,
    pub matched: u32,
    pub stop: StopReason,
    pub fault: Option<RecordFault>,
    pub unevaluated: Vec<u64>,
    pub evaluation_limits: Option<Box<FilterDecodeLimits>>,
    pub records: Vec<u8>,
}

One page of a filtered read.

records is a standard polled-messages body: its head names the partition, the head offset, the record count and the partition context the page was served under, and the matching records keep their original offsets, ids, timestamps, headers, and payload bytes. next_scan_offset is the first record the server has not examined, None when nothing was examined and the start selector must be sent again. safe_ack_offset is the last examined offset. The reader may store it, with ack_context, only after every returned record at or below it is fully handled.

Fields

v: u32

partition_id: u32

policy: AppliedPolicy

generation: SourceGeneration

ack_context: AckContext

next_scan_offset: Option<u64>

safe_ack_offset: Option<u64>

frontier: u64

The primary’s partition head when the page was read. Reported, never used as scan progress.

examined: u32

matched: u32

stop: StopReason

fault: Option<RecordFault>

unevaluated: Vec<u64>

Offsets of returned records the filter could not evaluate (the pass fault policy).

evaluation_limits: Option<Box<FilterDecodeLimits>>

records: Vec<u8>

Implementations

impl FilteredPage

pub fn next_start(&self, original: &FilteredStart) -> FilteredStart

The start of the next request: continue after this page, or repeat the original selector when nothing was examined.

Trait Implementations

impl Clone for FilteredPage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FilteredPage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FilteredPage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for FilteredPage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for FilteredPage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FilteredPage