Struct FilterCaps 

pub struct FilterCaps {
    pub native: bool,
    pub catalog: bool,
    pub group_policy_reads: bool,
    pub evaluation: Option<FilterAnnounce>,
}

Server-side consumer filters.

Fields

native: bool

Filtered reads, fenced acknowledgments, previews, sample tests, and validation. Served by the streaming server itself, advertised by the CONSUMER_FILTERS feature bit, so it needs no managed backend.

catalog: bool

Saved filters, revisions, group bindings, and mutation outcomes. Needs a ready managed backend that advertises the filter op version.

group_policy_reads: bool

Group-aware reads: the server resolves a consumer group’s own policy, delivers an unbound group unfiltered, and fences acknowledgments by policy generation. Advertised by the GROUP_POLICY_READS feature bit. A normal group consumer needs it on a server that serves filters.

evaluation: Option<FilterAnnounce>

The evaluator version and codecs the server announced. None from a server that predates the announcement, which then evaluates as this build does.

Implementations

impl FilterCaps

pub fn evaluates(&self, evaluator_version: u32, codec: FilterCodec) -> bool

Whether the server evaluates a filter built for evaluator_version with codec exactly as this build does.

Trait Implementations

impl Clone for FilterCaps

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 FilterCaps

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

Formats the value using the given formatter.

impl Default for FilterCaps

fn default() -> Self

Returns the “default value” for a type.

impl Eq for FilterCaps

impl PartialEq for FilterCaps

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FilterCaps