Struct SignalGateway 

pub struct SignalGateway { /* private fields */ }

Entry point for all external signals into the agent.

• Cron scheduling: fires ScheduledPrompts at the right wall-clock time
• Webhook ingestion: push any RuntimeSignal directly via ingest
• Subscribe pattern: callers receive signals via subscribe

Implementations

impl SignalGateway

pub fn new() -> Self

pub fn subscribe(&self) -> GatewayReceiver

Subscribe to all signals emitted by this gateway. Returns a GatewayReceiver that implements SignalSource.

pub fn schedule(&self, prompt: ScheduledPrompt)

Schedule a ScheduledPrompt to fire at its run_at_ms. Idempotent by goal+time.

pub fn cancel(&self, goal: &str, run_at_ms: u64)

Cancel a previously scheduled prompt.

pub fn ingest(&self, signal: RuntimeSignal)

Ingest a raw external signal (e.g. from a webhook handler).

pub fn destroy(&self)

Abort all pending scheduled tasks.

Trait Implementations

impl Default for SignalGateway

fn default() -> Self

Returns the “default value” for a type.