Struct EventEvaluator 

pub struct EventEvaluator { /* private fields */ }

Evaluates which subscriptions should receive notifications for a resource event.

Implementations

impl EventEvaluator

pub fn new( topic_registry: Arc<InMemoryTopicRegistry>, subscription_manager: Arc<SubscriptionManager>, ) -> Self

pub fn evaluate(&self, event: &ResourceEvent) -> Vec<EvaluationMatch>

Evaluates a resource event and returns all matching subscriptions.

The flow is:

1. Find all topics whose triggers match the event’s resource type + interaction.
2. For each matching topic, find all active subscriptions.
3. For each subscription, evaluate filter criteria against the resource.
4. Return subscriptions that pass all filters.