tdb_server_core 0.5.1

tectonicdb server
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::prelude::*;

#[cfg(feature = "gcs")]
pub mod gstorage;
#[cfg(feature = "influx")]
pub mod influx;
pub mod history;

/// Run each plugin in a separate thread
pub async fn run_plugins(broker: Sender<Event>, settings: Arc<Settings>) {
    info!("initializing plugins");
    if settings.granularity > 0 {
        history::run(broker.clone(), settings.clone()).await;
    }
    #[cfg(feature = "gcs")] gstorage::run(broker, settings).await;
    #[cfg(feature = "influx")] influx::run(broker, settings).await;
}

#[allow(unused)]
pub fn run_plugin_exit_hooks(_broker: Sender<Event>, settings: Arc<Settings>) {
    #[cfg(feature = "gcs")] gstorage::run_exit_hook(settings);
}