stormchaser-model 1.3.0

A robust, distributed workflow engine for event-driven and human-triggered workflows.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Outbox pattern models for reliable event publishing.

use crate::id::*;
use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use serde_json::Value;

/// Represents a message scheduled for reliable delivery via the outbox pattern.
#[derive(Debug, Serialize, Deserialize, Clone, sqlx::FromRow)]
pub struct OutboxMessage {
    /// Unique identifier for the outbox message.
    pub id: i64,
    /// Associated workflow run ID.
    pub run_id: RunId,
    /// Event subject or topic.
    pub subject: String,
    /// JSON-encoded message payload.
    pub payload: Value,
    /// Timestamp when the message was created.
    pub created_at: DateTime<Utc>,
    /// Timestamp when the message was successfully processed, if applicable.
    pub processed_at: Option<DateTime<Utc>>,
}