photon-backend 0.1.0

Photon publish/subscribe backend implementations and storage adapters
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Subscription model.

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

/// Subscription mode.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize, Default)]
#[serde(rename_all = "lowercase")]
pub enum SubscriptionMode {
    /// Durable: checkpoints maintained, survives restart.
    #[default]
    Durable,
    /// Ephemeral: no checkpoints, lost on restart.
    Ephemeral,
}

/// Subscription handler registration.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Subscription {
    /// Unique subscription ID (UUID).
    pub subscription_id: String,
    /// Subscription name (unique per topic, required for durable).
    pub subscription_name: String,
    /// Topic name.
    pub topic_name: String,
    /// Optional key filter.
    pub topic_key_filter: Option<String>,
    /// Whether the subscription is enabled.
    pub enabled: bool,
    /// Durable or ephemeral.
    pub mode: SubscriptionMode,
    /// When the subscription was created.
    pub created_at: DateTime<Utc>,
}