commit - 3d47cae64d9a975de5cc2dabb8c2f93b453d13a1
commit + 56353a840d3c0193dfb3b0f4b433668156a44b45
blob - da25e6bbcbb16dbed6de3816f4e9803a375b845a
blob + 9ca43d9b329c06d88504c32f44d8ceab81065458
--- kopsd/src/server.rs
+++ kopsd/src/server.rs
// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
//
-use std::{os::unix::fs::PermissionsExt, sync::Arc};
+use std::{
+ collections::HashMap,
+ os::unix::fs::PermissionsExt,
+ sync::{Arc, Mutex},
+};
use anyhow::{Context, Result};
use daemonize::Daemonize;
.context("failed to build tokio runtime")?;
rt.block_on(async move {
- let clusters_map = std::collections::HashMap::new();
// for c in &config.cluster {
// let cs = init_cluster_state(c.clone()).await.unwrap();
// // clusters_map.insert(c.name.clone(), cs);
// let state =
// Arc::new(DaemonState { clusters: clusters_map, default_cluster });
let state = Arc::new(DaemonState {
- clusters: clusters_map,
+ clusters: HashMap::new(),
default_cluster,
- aws_sessions: std::sync::Mutex::new(
- std::collections::HashMap::new(),
- ),
+ aws_sessions: Mutex::new(HashMap::new()),
});
// for c in config.cluster.clone() {