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

// SPDX-License-Identifier: BUSL-1.1

//! MaterializedView post-apply — no in-memory registry to sync.
//! The refresh loop reads the view definition straight from
//! `SystemCatalog` on its next tick.

use std::sync::Arc;

use tracing::debug;

use crate::control::security::catalog::StoredMaterializedView;
use crate::control::state::SharedState;

pub fn put(stored: StoredMaterializedView, shared: Arc<SharedState>) {
    debug!(
        view = %stored.name,
        tenant = stored.tenant_id,
        "catalog_entry: materialized view upserted (refresh loop will pick it up)"
    );
    super::owner::install_from_parent(
        "materialized_view",
        stored.tenant_id,
        &stored.name,
        &stored.owner,
        &shared,
    );
}

pub fn delete(tenant_id: u64, name: String, shared: Arc<SharedState>) {
    debug!(
        view = %name,
        tenant = tenant_id,
        "catalog_entry: materialized view removed"
    );
    shared
        .permissions
        .install_replicated_remove_owner("materialized_view", tenant_id, &name);
}