jamjet-state 0.3.1

JamJet durable state — event log, snapshots, SQLite and Postgres backends
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
35
36
37
38

use crate::event::EventSequence;
use chrono::{DateTime, Utc};
use jamjet_core::workflow::ExecutionId;
use serde::{Deserialize, Serialize};
use uuid::Uuid;

/// A point-in-time snapshot of workflow state.
///
/// Current state = latest snapshot + events with sequence > snapshot.at_sequence
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Snapshot {
    pub id: Uuid,
    pub execution_id: ExecutionId,
    /// The event sequence number at which this snapshot was taken.
    pub at_sequence: EventSequence,
    /// Materialized workflow state at this point.
    pub state: serde_json::Value,
    pub created_at: DateTime<Utc>,
}

impl Snapshot {
    pub fn new(
        execution_id: ExecutionId,
        at_sequence: EventSequence,
        state: serde_json::Value,
    ) -> Self {
        Self {
            id: Uuid::new_v4(),
            execution_id,
            at_sequence,
            state,
            created_at: Utc::now(),
        }
    }
}

/// Default number of events between automatic snapshots.
pub const DEFAULT_SNAPSHOT_INTERVAL: i64 = 50;