nodedb 0.3.0-beta.1

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

// SPDX-License-Identifier: BUSL-1.1

//! Continuous-aggregate post-apply — install the owner cache entry
//! and let the Data Plane register-dispatch happen on the handler
//! side (the manager's runtime state is per-core; the proposing
//! node calls `MetaOp::RegisterContinuousAggregate` after the
//! propose returns and startup replay does the same on every node).

use std::sync::Arc;

use tracing::debug;

use crate::control::security::catalog::StoredContinuousAggregate;
use crate::control::security::catalog::auth_types::object_type;
use crate::control::state::SharedState;

pub fn put(stored: StoredContinuousAggregate, shared: Arc<SharedState>) {
    debug!(
        cagg = %stored.name,
        tenant = stored.tenant_id,
        "catalog_entry: continuous aggregate upserted"
    );
    super::owner::install_from_parent(
        object_type::CONTINUOUS_AGGREGATE,
        stored.tenant_id,
        &stored.name,
        &stored.owner,
        &shared,
    );
}

pub fn delete(tenant_id: u64, name: String, shared: Arc<SharedState>) {
    debug!(
        cagg = %name,
        tenant = tenant_id,
        "catalog_entry: continuous aggregate removed"
    );
    shared.permissions.install_replicated_remove_owner(
        object_type::CONTINUOUS_AGGREGATE,
        tenant_id,
        &name,
    );
}