Struct AfterMutationTrigger 

pub struct AfterMutationTrigger {
    pub function_name: String,
    pub entity_type: String,
    pub event_filter: Option<EventKind>,
}

Trigger that fires after a mutation completes.

When a mutation completes, the observer pipeline emits an EntityEvent. If an AfterMutationTrigger matches the entity type and event kind, the corresponding function is invoked asynchronously without blocking the mutation response.

Matching

• Must match entity_type exactly
• If event_filter is None, matches all event kinds (Insert/Update/Delete)
• If event_filter is Some, matches only that specific event kind

Dispatch

• Invoked in declaration order from schema.compiled.json
• Spawned as an async task (mutation response returns immediately)
• Function execution timeout: 5s default (can be overridden per function)
• Failure doesn’t affect mutation (error logged to tracing subscriber)

Fields

function_name: String

Name of the function to invoke.

entity_type: String

Entity type to trigger on (e.g., “User”).

event_filter: Option<EventKind>

Optional filter on event kind (None = all).

Implementations

impl AfterMutationTrigger

pub fn matches(&self, entity: &str, event_kind: EventKind) -> bool

Check if this trigger matches the given entity and event.

pub fn build_payload(&self, event: &EntityEvent) -> EventPayload

Build an EventPayload from an entity event.

Trait Implementations

impl Clone for AfterMutationTrigger

fn clone(&self) -> AfterMutationTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AfterMutationTrigger

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

Formats the value using the given formatter.