Struct ReadAggregator 

pub struct ReadAggregator {
    pub aggregator_type: String,
    pub aggregator_id: Option<String>,
    pub name: Option<String>,
}

Filter for querying events by aggregator.

Use the constructor methods to create filters:

Example

// All events for an aggregator type
let filter = ReadAggregator::aggregator("myapp/User");

// Events for a specific aggregate instance
let filter = ReadAggregator::id("myapp/User", "user-123");

// Events of a specific type
let filter = ReadAggregator::event("myapp/User", "UserCreated");

Fields

aggregator_type: String

Aggregator type (e.g., “myapp/User”)

aggregator_id: Option<String>

Optional specific aggregate ID

name: Option<String>

Optional event name filter

Implementations

impl ReadAggregator

pub fn new( aggregator_type: impl Into<String>, id: impl Into<String>, name: impl Into<String>, ) -> Self

Creates a filter with all fields specified.

Filters events by aggregator type, specific aggregate ID, and event name.

pub fn aggregator(value: impl Into<String>) -> Self

Creates a filter for all events of an aggregator type.

Returns all events regardless of aggregate ID or event name.

pub fn id(aggregator_type: impl Into<String>, id: impl Into<String>) -> Self

Creates a filter for a specific aggregate instance.

Returns all events for the given aggregator type and ID.

pub fn event( aggregator_type: impl Into<String>, name: impl Into<String>, ) -> Self

Creates a filter for a specific event type.

Returns all events of the given name for an aggregator type.

Trait Implementations

impl Clone for ReadAggregator

fn clone(&self) -> ReadAggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Hash for ReadAggregator

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ReadAggregator

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ReadAggregator

impl StructuralPartialEq for ReadAggregator