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

// SPDX-License-Identifier: BUSL-1.1

//! Schedule post-apply side effects — sync the in-memory cron
//! registry so the scheduler executor picks up the change on its
//! next tick.

use std::sync::Arc;

use crate::control::state::SharedState;
use crate::event::scheduler::types::ScheduleDef;

pub fn put(stored: ScheduleDef, shared: Arc<SharedState>) {
    super::owner::install_from_parent(
        "schedule",
        stored.tenant_id,
        &stored.name,
        &stored.owner,
        &shared,
    );
    shared.schedule_registry.register(stored);
}

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