Enum SopTrigger 

pub enum SopTrigger {
    Mqtt {
        topic: String,
        condition: Option<String>,
    },
    Webhook {
        path: String,
    },
    Cron {
        expression: String,
    },
    Peripheral {
        board: String,
        signal: String,
        condition: Option<String>,
    },
    Filesystem {
        path: String,
        events: Vec<FilesystemEventKind>,
        condition: Option<String>,
    },
    Calendar {
        calendar_source: String,
        calendar_ids: Vec<String>,
        condition: Option<String>,
    },
    Channel {
        channel: String,
        alias: Option<String>,
        condition: Option<String>,
    },
    Manual,
    Amqp {
        routing_key: String,
        condition: Option<String>,
    },
}

What event can activate an SOP.

Variants

Mqtt

MQTT message arrival. Live: delivered by the MQTT listener.

Fields

topic: String

Topic filter. + matches one level, # matches the remaining levels.

condition: Option<String>

Optional expression evaluated against the message payload; the run starts only when it holds.

Webhook

Inbound HTTP request. Live: gateway /sop/* and SOP-first /webhook routes.

Fields

path: String

Request path matched exactly against the event path.

Cron

Time-based firing. Live: dispatched by the SOP maintenance tick (daemon / channel-start paths).

Fields

expression: String

Cron expression evaluated over the run window.

Peripheral

Hardware signal. Defined and matched, but no peripheral listener feeds it.

Fields

board: String

Board identifier the signal originates from.

signal: String

Signal name on the board; matched as board/signal.

condition: Option<String>

Optional expression evaluated against the signal payload.

Filesystem

Filesystem change. Live: delivered by the filesystem watcher.

Fields

path: String

Path glob (*, **, ?); a bare directory matches anything under it.

events: Vec<FilesystemEventKind>

Change kinds to match; empty matches every kind.

condition: Option<String>

Optional expression evaluated against the change payload.

Calendar

Calendar event state. Defined and matched, but no poller feeds it live.

Fields

calendar_source: String

Calendar source identifier the event originates from.

calendar_ids: Vec<String>

Calendar IDs to scope to; empty matches all of the source’s calendars.

condition: Option<String>

Optional expression evaluated against the calendar event payload.

Channel

Inbound message or forge/platform event on a configured channel (telegram, discord, slack, git, …). Live: delivered by the channel orchestrator when the channel’s SOP dispatch is enabled. The Git forge producer sets an event topic of the form <channel>.<alias>:<event_type> and puts event_type in the payload, so an authored condition filters forge events by type without a second trigger shape.

Fields

channel: String

ChannelKind snake_case value naming the channel type.

alias: Option<String>

Optional configured-instance alias; unset matches every instance.

condition: Option<String>

Optional expression evaluated against the message payload.

Manual

Agent-initiated run via the sop_execute tool. Not an external fan-in.

Amqp

AMQP delivery. Live: delivered by the AMQP consumer in a SOP dispatch mode.

Fields

routing_key: String

Routing-key filter (topic-exchange semantics): .-delimited words, * matches one word, # matches zero or more words.

condition: Option<String>

Optional expression evaluated against the delivery body.

Implementations

impl SopTrigger

pub fn source(&self) -> SopTriggerSource

pub fn is_headless(&self) -> bool

True when this trigger can only start a run with no ambient agent turn.

Every fan-in source except Manual fires from a listener, poller, or the maintenance tick, none of which carry an agent identity a step could borrow, so a procedure reachable by one must declare its own owning agent (see Sop::agent).

Manual is false because it is reachable from both sides: through the sop_execute tool the calling turn’s agent owns the run, while the dashboard run endpoint emits the same event from outside any agent turn. The trigger alone cannot tell those apart, so ownership for a Manual start is enforced by the surface that starts it (sop::headless_ownership_refusal) rather than by this flag.

Trait Implementations

impl Clone for SopTrigger

fn clone(&self) -> SopTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SopTrigger

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SopTrigger

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for SopTrigger

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

Formats the value using the given formatter.

impl Eq for SopTrigger

impl<'_enum> From<&'_enum SopTrigger> for SopTriggerSource

fn from(val: &'_enum SopTrigger) -> SopTriggerSource

Converts to this type from the input type.

impl From<SopTrigger> for SopTriggerSource

fn from(val: SopTrigger) -> SopTriggerSource

Converts to this type from the input type.

impl IntoDiscriminant for SopTrigger

type Discriminant = SopTriggerSource

Enum listing the same variants as this enum but without any data fields

fn discriminant(&self) -> Self::Discriminant

impl JsonSchema for SopTrigger

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for SopTrigger

fn eq(&self, other: &SopTrigger) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for SopTrigger

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for SopTrigger