feature/nanocld: event manager (#801)

* feature/nanocld: event manager
next-hat · Jan 5, 2024 · d59a45b · d59a45b
1 parent 7be1d44
commit d59a45b
Show file tree

Hide file tree

Showing 46 changed files with 832 additions and 749 deletions.
diff --git a/...23-12-30-161201_metrics-add-note/down.sql → ...23-12-30-161201_metrics_add_note/down.sql b/...23-12-30-161201_metrics-add-note/down.sql → ...23-12-30-161201_metrics_add_note/down.sql
diff --git a/...2023-12-30-161201_metrics-add-note/up.sql → ...2023-12-30-161201_metrics_add_note/up.sql b/...2023-12-30-161201_metrics-add-note/up.sql → ...2023-12-30-161201_metrics_add_note/up.sql
diff --git a/...-02-135246_metrics-rename-expire/down.sql → ...-02-135246_metrics_rename_expire/down.sql b/...-02-135246_metrics-rename-expire/down.sql → ...-02-135246_metrics_rename_expire/down.sql
diff --git a/...01-02-135246_metrics-rename-expire/up.sql → ...01-02-135246_metrics_rename_expire/up.sql b/...01-02-135246_metrics-rename-expire/up.sql → ...01-02-135246_metrics_rename_expire/up.sql
diff --git a/bin/nanocld/src/event_emitter.rs b/bin/nanocld/src/event_emitter.rs
diff --git a/bin/nanocld/src/main.rs b/bin/nanocld/src/main.rs
@@ -6,13 +6,11 @@ use nanocl_utils::logger;
 mod cli;
 mod config;
 mod schema;
-mod version;
-mod boot;
 mod models;
-mod event_emitter;
-mod server;
-mod repositories;
+mod version;
 mod utils;
+mod subsystem;
+mod repositories;
 mod services;
 
 /// Provides an api to manage containers and virtual machines accross physical hosts
@@ -45,16 +43,16 @@ async fn main() -> std::io::Result<()> {
     Ok(config) => config,
   };
   // Boot internal dependencies (database, event bus, etc...)
-  let daemon_state = match boot::init(&config).await {
+  let daemon_state = match subsystem::init(&config).await {
     Err(err) => {
       err.print_and_exit();
     }
     Ok(daemon_state) => daemon_state,
   };
   // Start http server
-  match server::gen(daemon_state).await {
+  match utils::server::gen(daemon_state).await {
     Err(err) => {
-      err.map_err_context(|| "Daemon state").print_and_exit();
+      err.map_err_context(|| "Http server").print_and_exit();
     }
     Ok(server) => {
       // Start http server and wait for shutdown

diff --git a/bin/nanocld/src/models/mod.rs b/bin/nanocld/src/models/mod.rs
@@ -9,8 +9,8 @@ pub use ws::*;
 mod node;
 pub use node::*;
 
-mod state;
-pub use state::*;
+mod system;
+pub use system::*;
 
 mod metric;
 pub use metric::*;
@@ -48,6 +48,9 @@ pub use process::*;
 mod event;
 pub use event::*;
 
+mod raw_emitter;
+pub use raw_emitter::*;
+
 pub type Pool = Arc<R2D2Pool<ConnectionManager<PgConnection>>>;
 pub type DBConn = PooledConnection<ConnectionManager<PgConnection>>;