Struct Subscription 

pub struct Subscription {
    pub id: String,
    pub aggregate_type_filter: Option<String>,
    pub event_type_filter: Option<String>,
    pub from_timestamp: Option<DateTime<Utc>>,
}

Event stream subscription configuration.

Subscriptions define which events a consumer wants to receive from the event stream. They support filtering by aggregate type, event type, and time ranges.

Example

use eventuali_core::SubscriptionBuilder;

let subscription = SubscriptionBuilder::new()
    .aggregate_type("User".to_string())
    .event_type("UserRegistered".to_string())
    .build();

Fields

id: String

aggregate_type_filter: Option<String>

event_type_filter: Option<String>

from_timestamp: Option<DateTime<Utc>>

Trait Implementations

impl Clone for Subscription

fn clone(&self) -> Subscription

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Subscription

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

Formats the value using the given formatter.