infinite-db 0.4.0

A spatial-graph database using n-dimensional curves and hyperedges for engineering logic.
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

//! Intent checkpoint descriptors (peer track Phase 4).

use bincode::{Decode, Encode};

use super::address::RevisionId;
use super::error_record::OperationRevisionRange;

/// Operation kind tag carried on an intent checkpoint frame.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Encode, Decode)]
pub enum IntentOperationKind {
    General,
    Insert,
    HypergraphWrite,
    Custom(u32),
}

/// Marks that all WAL frames since the previous checkpoint form one logical operation.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Encode, Decode)]
pub struct IntentCheckpoint {
    pub first_revision: RevisionId,
    pub last_revision: RevisionId,
    pub kind: IntentOperationKind,
}

impl IntentCheckpoint {
    pub fn new(
        first_revision: RevisionId,
        last_revision: RevisionId,
        kind: IntentOperationKind,
    ) -> Self {
        Self {
            first_revision,
            last_revision,
            kind,
        }
    }

    pub fn revision_range(&self) -> OperationRevisionRange {
        OperationRevisionRange::new(self.first_revision, self.last_revision)
    }
}