nodedb 0.4.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
46
47
48
49
50
51
52
53
54
55
56

// SPDX-License-Identifier: BUSL-1.1

//! Startup-gate registration for the boot sequence.

use nodedb::control::startup::{ReadyGate, StartupPhase, StartupSequencer};

/// Every gate handle `main()` needs after registering all startup phases
/// up front, bundled so the registration call site doesn't juggle ten
/// separate `let`s. Phases that have no concurrent sub-tasks get a
/// single gate that is fired inline.
pub(crate) struct StartupGates {
    pub(crate) wal_gate: ReadyGate,
    pub(crate) catalog_gate: ReadyGate,
    pub(crate) raft_gate: ReadyGate,
    pub(crate) schema_gate: ReadyGate,
    pub(crate) sanity_gate: ReadyGate,
    pub(crate) data_groups_gate: ReadyGate,
    pub(crate) transport_gate: ReadyGate,
    pub(crate) warm_peers_gate: ReadyGate,
    pub(crate) health_loop_gate: ReadyGate,
    pub(crate) gateway_enable_gate: ReadyGate,
}

/// Register all gates up-front so the sequencer knows every phase has
/// an owner. Pure relocation of what used to be inline in `main()`.
pub(crate) fn register_startup_gates(startup_seq: &StartupSequencer) -> StartupGates {
    let wal_gate = startup_seq.register_gate(StartupPhase::WalRecovery, "wal");
    let catalog_gate =
        startup_seq.register_gate(StartupPhase::ClusterCatalogOpen, "cluster-catalog");
    let raft_gate =
        startup_seq.register_gate(StartupPhase::RaftMetadataReplay, "raft-metadata-replay");
    let schema_gate =
        startup_seq.register_gate(StartupPhase::SchemaCacheWarmup, "schema-cache-warmup");
    let sanity_gate =
        startup_seq.register_gate(StartupPhase::CatalogSanityCheck, "catalog-sanity-check");
    let data_groups_gate =
        startup_seq.register_gate(StartupPhase::DataGroupsReplay, "data-groups-replay");
    let transport_gate = startup_seq.register_gate(StartupPhase::TransportBind, "transport-bind");
    let warm_peers_gate = startup_seq.register_gate(StartupPhase::WarmPeers, "warm-peers");
    let health_loop_gate = startup_seq.register_gate(StartupPhase::HealthLoopStart, "health-loop");
    let gateway_enable_gate =
        startup_seq.register_gate(StartupPhase::GatewayEnable, "gateway-enable");

    StartupGates {
        wal_gate,
        catalog_gate,
        raft_gate,
        schema_gate,
        sanity_gate,
        data_groups_gate,
        transport_gate,
        warm_peers_gate,
        health_loop_gate,
        gateway_enable_gate,
    }
}