Enum WorkerTrigger 

pub enum WorkerTrigger {
    Queue {
        queue: ResourceRef,
    },
    Storage {
        storage: ResourceRef,
        events: Vec<String>,
    },
    Schedule {
        cron: String,
    },
}

Defines what triggers a worker execution.

Variants

Queue

Worker triggered by queue messages (always 1 message per invocation)

Fields

queue: ResourceRef

Reference to the queue resource

Storage

Worker triggered by storage events (object created, deleted, etc.)

Fields

storage: ResourceRef

Reference to the storage resource

events: Vec<String>

Events to trigger on (e.g., [“created”, “deleted”])

Schedule

Worker triggered on a schedule (cron expression)

Fields

cron: String

Cron expression for scheduling (standard 5-field unix cron)

Implementations

impl WorkerTrigger

pub fn queue<R: ?Sized>(queue: &R) -> Self

where for<'a> &'a R: Into<ResourceRef>,

Creates a queue trigger for the specified queue resource. The worker will be automatically invoked when messages arrive in the queue. Each message is processed individually (batch size of 1).

pub fn storage<R: ?Sized>(storage: &R, events: Vec<String>) -> Self

where for<'a> &'a R: Into<ResourceRef>,

Creates a storage trigger for the specified storage resource. The worker will be invoked when matching events occur on the storage resource.

pub fn schedule<S: Into<String>>(cron: S) -> Self

Creates a schedule trigger with the specified cron expression. Uses standard 5-field unix cron format (minute hour day-of-month month day-of-week).

Trait Implementations

impl Clone for WorkerTrigger

fn clone(&self) -> WorkerTrigger

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerTrigger

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkerTrigger

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorkerTrigger

fn eq(&self, other: &WorkerTrigger) -> 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 WorkerTrigger

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 WorkerTrigger

impl StructuralPartialEq for WorkerTrigger