evento-sql-migrator 2.0.0-alpha.22

SQL migrations for evento event sourcing library.
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

//! Optional schema for the **evento-accord** SQL-backed consensus journal
//! (`SqlJournal<DB>`), behind the `accord` feature.
//!
//! These four tables back a replica's durable consensus state — the per-transaction
//! command log, the truncation watermark, the metadata (epoch→layout) log, and the
//! config-Paxos acceptor records. The table and column **names are a contract** with
//! `evento_sql::SqlJournal`; keep them in sync. The migration is pure DDL, so this
//! crate needs no dependency on `evento-accord`.

mod tables;

use sea_query::Iden;
use sqlx_migrator::vec_box;

/// Column identifiers for `accord_commands` — one row per transaction's
/// [`CommandState`](https://docs.rs/evento-accord), keyed by an order-preserving
/// 20-byte `TxnId`.
#[derive(Iden)]
pub(crate) enum AccordCommands {
    Table,
    Txn,
    Data,
}

/// Column identifiers for `accord_meta` — a small key/value table (the truncation
/// watermark lives under `k = 'redundant_before'`).
#[derive(Iden)]
pub(crate) enum AccordMeta {
    Table,
    K,
    V,
}

/// Column identifiers for `accord_metadata_log` — the decided `(epoch, layout)` log.
#[derive(Iden)]
pub(crate) enum AccordMetadataLog {
    Table,
    Epoch,
    Layout,
}

/// Column identifiers for `accord_acceptors` — config-Paxos acceptor state per epoch.
#[derive(Iden)]
pub(crate) enum AccordAcceptors {
    Table,
    Epoch,
    State,
}

/// Creates the evento-accord consensus-journal tables. Independent of the event
/// schema (no migration dependencies), so it can run on a database that holds only
/// the consensus state.
pub struct AccordMigration;

#[cfg(feature = "sqlite")]
sqlx_migrator::sqlite_migration!(
    AccordMigration,
    "main",
    "accord_journal",
    vec_box![],
    vec_box![tables::Operation]
);

#[cfg(feature = "mysql")]
sqlx_migrator::mysql_migration!(
    AccordMigration,
    "main",
    "accord_journal",
    vec_box![],
    vec_box![tables::Operation]
);

#[cfg(feature = "postgres")]
sqlx_migrator::postgres_migration!(
    AccordMigration,
    "main",
    "accord_journal",
    vec_box![],
    vec_box![tables::Operation]
);