Enum TriggerHandlerSpec 

pub enum TriggerHandlerSpec {
    Local {
        raw: String,
        closure: Arc<VmClosure>,
    },
    A2a {
        target: String,
        allow_cleartext: bool,
    },
    Worker {
        queue: String,
    },
    Persona {
        binding: PersonaRuntimeBinding,
    },
    EvalPack {
        target: String,
        manifest: Box<EvalPackManifest>,
        ledger_options: Option<Value>,
    },
    AutoResume {
        worker_id: String,
    },
    SpawnToPool {
        pool: String,
        priority_from: Option<String>,
        key_from: Option<String>,
        task_factory: Arc<VmClosure>,
    },
    ReminderInject {
        target: TargetExpr,
        body: String,
        tags: Vec<String>,
        ttl_turns: Option<i64>,
        dedupe_key: Option<String>,
        propagate: ReminderPropagate,
        role_hint: ReminderRoleHint,
        preserve_on_compact: bool,
    },
    InterruptAndSuspend {
        target_agents: AgentScope,
        reason: String,
    },
}

Variants

Local

Fields

raw: String

closure: Arc<VmClosure>

A2a

Fields

target: String

allow_cleartext: bool

Worker

Fields

queue: String

Persona

Fields

binding: PersonaRuntimeBinding

EvalPack

Fields

target: String

manifest: Box<EvalPackManifest>

ledger_options: Option<Value>

AutoResume

Fields

worker_id: String

SpawnToPool

Composes triggers (#1870) with named agent pools (#1883). On match, the dispatcher resolves pool by name, invokes task_factory(event) to build the per-event closure, and submits it to the pool with the pool’s queue strategy + backpressure policy applied (PL-04 / #1889).

Fields

pool: String

priority_from: Option<String>

key_from: Option<String>

task_factory: Arc<VmClosure>

ReminderInject

Composes triggers (#1870) with the reminder pipeline (#1815) by injecting a SystemReminder into a target agent session’s transcript when the trigger matches (CH-05 / #1876). The reminder appears at the session’s next turn boundary — same as any other reminder. No spawn, no resume, no signal. body is a prompt-template string rendered against {event} / {batch.events} per match. target resolution happens at dispatch time via TargetExpr; missing-target dispatches are recorded as audit events rather than crashing the trigger.

Fields

target: TargetExpr

body: String

tags: Vec<String>

ttl_turns: Option<i64>

dedupe_key: Option<String>

propagate: ReminderPropagate

role_hint: ReminderRoleHint

preserve_on_compact: bool

InterruptAndSuspend

CH-10 (#1910): emergency “panic” broadcast. When the trigger fires, every running worker matched by target_agents is suspended synchronously via the cooperative suspend pipeline used by suspend_agent (#1837), bypassing the normal turn-boundary delivery contract. Already-suspended or terminal workers are skipped (no double-suspend, no error). reason is propagated to the suspension envelope, the WorkerSuspended event, and the triggers.interrupt_and_suspend.audit audit entry per suspension. A no-target dispatch records a single roll-up audit entry and returns a broadcast result with suspended_count: 0 — graceful no-op rather than dispatch failure, mirroring the ReminderInject missing-target contract.

Fields

target_agents: AgentScope

reason: String

Implementations

impl TriggerHandlerSpec

pub fn kind(&self) -> &'static str

Trait Implementations

impl Clone for TriggerHandlerSpec

fn clone(&self) -> TriggerHandlerSpec

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TriggerHandlerSpec

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

Formats the value using the given formatter.

impl From<&TriggerHandlerSpec> for DispatchUri

fn from(value: &TriggerHandlerSpec) -> Self

Converts to this type from the input type.