nodedb 0.2.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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

// SPDX-License-Identifier: BUSL-1.1

//! WAL append logic: delegates to shared dispatch utilities.

use crate::types::{TenantId, VShardId};

use super::core::NodeDbPgHandler;

impl NodeDbPgHandler {
    /// Append a write operation to the WAL for single-node durability.
    ///
    /// Delegates to the shared `dispatch_utils::wal_append_if_write` to
    /// avoid duplication between pgwire and HTTP endpoints.
    pub(super) fn wal_append_if_write(
        &self,
        tenant_id: TenantId,
        vshard_id: VShardId,
        database_id: crate::types::DatabaseId,
        plan: &crate::bridge::envelope::PhysicalPlan,
    ) -> crate::Result<()> {
        crate::control::server::wal_dispatch::wal_append_if_write(
            &self.state.wal,
            tenant_id,
            vshard_id,
            database_id,
            plan,
        )
    }
}