reddb-io-server 1.21.0

RedDB server-side engine: storage, runtime, replication, MCP, AI, and the gRPC/HTTP/RedWire/PG-wire dispatchers. Re-exported by the umbrella `reddb` crate.
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

//! Live transaction snapshot and visibility support.
//!
//! The live engine is optimistic MVCC: `SnapshotManager` allocates xids,
//! `visibility` decides snapshot reads, and commit-time first-committer-wins
//! checks live in the runtime.
//!
//! # Isolation Levels
//!
//! - **Read Committed**: See committed changes from other transactions
//! - **Snapshot Isolation**: See consistent snapshot from transaction start
//! - **Serializable**: Full serializability (not yet implemented)

// ADR 0065 retires these dormant transaction-coordinator scaffolding modules
// from the normal build. The live engine chose optimistic FCW; it does not
// promote the lock/deadlock/savepoint/log coordinator stack.
#[cfg(any())]
pub mod coordinator;
#[cfg(any())]
pub mod lock;
#[cfg(any())]
pub mod log;
#[cfg(any())]
pub mod savepoint;
pub mod snapshot;
pub mod visibility;

/// Isolation level requested by `BEGIN ISOLATION LEVEL ...`.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum IsolationLevel {
    /// `READ UNCOMMITTED`
    ReadUncommitted,
    /// `READ COMMITTED`
    ReadCommitted,
    /// `REPEATABLE READ` / `SNAPSHOT`
    #[default]
    SnapshotIsolation,
    /// `SERIALIZABLE`
    Serializable,
}

impl From<crate::storage::query::ast::IsolationLevel> for IsolationLevel {
    fn from(level: crate::storage::query::ast::IsolationLevel) -> Self {
        match level {
            crate::storage::query::ast::IsolationLevel::ReadUncommitted => Self::ReadUncommitted,
            crate::storage::query::ast::IsolationLevel::ReadCommitted => Self::ReadCommitted,
            crate::storage::query::ast::IsolationLevel::SnapshotIsolation => {
                Self::SnapshotIsolation
            }
            crate::storage::query::ast::IsolationLevel::Serializable => Self::Serializable,
        }
    }
}

#[cfg(any())]
pub use coordinator::{Transaction, TransactionManager, TxnConfig, TxnError, TxnHandle, TxnState};
#[cfg(any())]
pub use lock::{LockManager, LockMode, LockResult, LockWaiter};
#[cfg(any())]
pub use log::{LogEntry, LogEntryType, TransactionLog, WalConfig};
#[cfg(any())]
pub use savepoint::{Savepoint, SavepointManager};
pub use snapshot::{Snapshot, SnapshotManager, TxnContext, Xid, XID_NONE};
pub use visibility::is_visible;