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

// SPDX-License-Identifier: BUSL-1.1

//! Trigger post-apply side effects — sync the in-memory
//! `trigger_registry`.

use std::sync::Arc;

use crate::control::security::catalog::trigger_types::StoredTrigger;
use crate::control::state::SharedState;

pub fn put(stored: StoredTrigger, shared: Arc<SharedState>) {
    // `register` is an upsert: inserts new triggers and replaces
    // on OR REPLACE / ALTER ENABLE/DISABLE.
    super::owner::install_from_parent(
        "trigger",
        stored.tenant_id,
        &stored.name,
        &stored.owner,
        &shared,
    );
    shared.trigger_registry.register(stored);
}

pub fn delete(tenant_id: u64, name: String, shared: Arc<SharedState>) {
    shared.trigger_registry.unregister(tenant_id, &name);
    shared
        .permissions
        .install_replicated_remove_owner("trigger", tenant_id, &name);
}