nodedb 0.3.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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

// SPDX-License-Identifier: BUSL-1.1

//! Post-apply side effects for a [`CatalogEntry`] — dispatched by
//! DDL family.
//!
//! Split into two phases so readers of `applied_index` observe a
//! consistent view:
//!
//! - [`apply_post_apply_side_effects_sync`] (in `sync`) runs the
//!   synchronous in-memory cache updates **inline** on the raft
//!   applier thread, BEFORE the metadata applier bumps the
//!   `AppliedIndexWatcher`.
//! - [`spawn_post_apply_async_side_effects`] (in `async_dispatch`)
//!   spawns tokio tasks for the genuinely async work — runs on
//!   **every node** (leader and followers) so each node's local
//!   Data Plane observes catalog mutations symmetrically.

// Per-family modules (existing).
pub mod api_key;
pub mod change_stream;
pub mod collection;
pub mod continuous_aggregate;
pub mod custom_type;
pub mod database;
pub mod function;
pub mod materialized_view;
pub mod owner;
pub mod permission;
pub mod procedure;
pub mod rls;
pub mod role;
pub mod schedule;
pub mod sequence;
pub mod synonym_group;
pub mod tenant;
pub mod trigger;
pub mod user;

// Orchestration modules.
mod async_dispatch;
pub(crate) mod gateway_invalidation;
mod sync;

pub use async_dispatch::spawn_post_apply_async_side_effects;
pub use sync::apply_post_apply_side_effects_sync;