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. Defined and matched, but no live route feeds it.

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

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<'_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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

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 Eq for SopTrigger

impl StructuralPartialEq for SopTrigger