Struct RecurringScheduleWire 

pub struct RecurringScheduleWire {
    pub name: String,
    pub cron: String,
    pub payload: Vec<u8>,
    pub priority: u8,
    pub max_attempts: u32,
    pub enabled: bool,
    pub next_run_ms: u64,
}

Cron-driven recurring job registered on a queue stream.

Fields

name: String

Unique schedule name within the stream.

cron: String

Cron expression (5-field min hour dom month dow or 6-field with seconds).

payload: Vec<u8>

Payload enqueued on each tick.

priority: u8

Passed to QueueEnqueueRequest::priority.

max_attempts: u32

Passed to QueueEnqueueRequest::max_attempts.

enabled: bool

When false the schedule is stored but does not fire.

next_run_ms: u64

Next fire time (unix ms); leader-maintained.

Trait Implementations

impl Clone for RecurringScheduleWire

fn clone(&self) -> RecurringScheduleWire

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecurringScheduleWire

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RecurringScheduleWire

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for RecurringScheduleWire

impl PartialEq for RecurringScheduleWire

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for RecurringScheduleWire

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 RecurringScheduleWire