Struct TriggerMatcher 

pub struct TriggerMatcher { /* private fields */ }

Matcher for efficiently finding triggers by (entity_type, event_kind).

Uses a nested HashMap for O(1) lookup:

• entity_type → event_kind → Vec<AfterMutationTrigger>
• When event_kind is None (matches all), stored separately for fallback

Integration with FunctionObserver

When the FunctionObserver receives an EntityEvent from the mutation pipeline, it calls find() to get all matching AfterMutationTriggers. For each matching trigger, the observer spawns an async task to invoke the function without blocking the mutation response. Task completion is tracked to prevent leaks on shutdown.

Example

let mut matcher = TriggerMatcher::new();
matcher.add(AfterMutationTrigger {
    function_name: "onUserCreated".to_string(),
    entity_type: "User".to_string(),
    event_filter: Some(EventKind::Insert),
});

// Later, when a User insert occurs:
let triggers = matcher.find("User", EventKind::Insert);
for trigger in triggers {
    // Spawn async task to invoke function
}

Implementations

impl TriggerMatcher

pub fn new() -> Self

Create a new empty trigger matcher.

pub fn add(&mut self, trigger: AfterMutationTrigger)

Add a trigger to the matcher.

pub fn find( &self, entity: &str, event_kind: EventKind, ) -> Vec<AfterMutationTrigger>

Find all triggers matching the given entity and event kind.

Trait Implementations

impl Clone for TriggerMatcher

fn clone(&self) -> TriggerMatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TriggerMatcher

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

Formats the value using the given formatter.

impl Default for TriggerMatcher

fn default() -> Self

Returns the “default value” for a type.