Struct ClaimedOutboxEvent 

pub struct ClaimedOutboxEvent {
    pub id: i64,
    pub stream: String,
    pub event_key: String,
    pub event_kind: String,
    pub payload_json: String,
    pub attempts: i32,
    pub claim_key: String,
    pub claim_expires_at_epoch: i64,
}

Event exclusively claimed by one worker until its lease expires.

Fields

id: i64

Stable database identifier.

stream: String

Explicit application or tenant stream.

event_key: String

Idempotency key unique within the stream.

event_kind: String

Bounded event kind used for dispatch routing.

payload_json: String

Serialized JSON payload.

attempts: i32

Number of successful claims, including this one.

claim_key: String

Unpredictable token required to acknowledge or fail this claim.

claim_expires_at_epoch: i64

Unix timestamp when another worker may reclaim this event.

Implementations

impl ClaimedOutboxEvent

pub fn payload(&self) -> Result<Value, Error>

Parses the bounded payload as JSON.

Trait Implementations

impl Clone for ClaimedOutboxEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClaimedOutboxEvent

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

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for ClaimedOutboxEvent

where &'a str: ColumnIndex<R>, i64: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, i32: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>