Method serialize

graphlite/src/txn/wal.rs:134–204

Serialize WAL entry to binary format Binary Format: - Magic (4 bytes): WAL_MAGIC - Entry Type (1 byte): WALEntryType - Transaction ID (8 bytes): u64 - Global Sequence (8 bytes): u64 - Txn Sequence (8 bytes): u64 - Timestamp (8 bytes): u64 (nanos since UNIX_EPOCH) - Operation Type (1 byte): Option (255 = None) - Description Length (4 bytes): u32 - Description (variable): UTF-8 bytes

(&self)

    /// - Description (variable): UTF-8 bytes
    /// - Checksum (4 bytes): CRC32
    pub fn serialize(&self) -> Vec<u8> {
        let mut buffer = Vec::with_capacity(256);

        // Magic number
        buffer.extend_from_slice(&WAL_MAGIC.to_le_bytes());

        // Entry type
        buffer.push(self.entry_type as u8);

        // Transaction ID
        buffer.extend_from_slice(&self.transaction_id.id().to_le_bytes());

        // Global sequence
        buffer.extend_from_slice(&self.global_sequence.to_le_bytes());

        // Transaction sequence
        buffer.extend_from_slice(&self.txn_sequence.to_le_bytes());

        // Timestamp
        let timestamp_nanos = self
            .timestamp
            .duration_since(UNIX_EPOCH)
            .unwrap_or_default()
            .as_nanos() as u64;
        buffer.extend_from_slice(&timestamp_nanos.to_le_bytes());

        // Operation type (255 = None)
        let op_type_byte = match &self.operation_type {
            // Read operations
            Some(OperationType::Select) => 0,
            Some(OperationType::Match) => 1,
            // Write operations
            Some(OperationType::Insert) => 10,
            Some(OperationType::Update) => 11,
            Some(OperationType::Set) => 12,
            Some(OperationType::Delete) => 13,
            Some(OperationType::Remove) => 14,
            // Schema operations
            Some(OperationType::CreateTable) => 20,
            Some(OperationType::CreateGraph) => 21,
            Some(OperationType::AlterTable) => 22,
            Some(OperationType::DropTable) => 23,
            Some(OperationType::DropGraph) => 24,
            // Security operations
            Some(OperationType::CreateUser) => 25,
            Some(OperationType::DropUser) => 26,
            Some(OperationType::CreateRole) => 27,
            Some(OperationType::DropRole) => 28,
            Some(OperationType::GrantRole) => 29,
            Some(OperationType::RevokeRole) => 30,
            // Transaction control
            Some(OperationType::Begin) => 31,
            Some(OperationType::Commit) => 32,
            Some(OperationType::Rollback) => 33,
            // Other
            Some(OperationType::Other) => 99,
            None => 255,
        };