diff --git a/ctl/src/discovery/mod.rs b/ctl/src/discovery/mod.rs index ba4bdd3..a878e2b 100644 --- a/ctl/src/discovery/mod.rs +++ b/ctl/src/discovery/mod.rs @@ -1,3 +1,5 @@ +#![allow(dead_code)] + use std::{collections::HashMap, net::SocketAddr}; use chrono::{DateTime, Utc}; @@ -12,11 +14,8 @@ pub struct Discovery { rx: mpsc::Receiver, // TODO: Add more information on workers workers: HashMap, - #[allow(dead_code)] services: HashMap, - #[allow(dead_code)] instances: HashMap, - #[allow(dead_code)] deployments: HashMap, } diff --git a/ctl/src/http/deployer/mod.rs b/ctl/src/http/deployer/mod.rs index 24fe0c8..1104cf0 100644 --- a/ctl/src/http/deployer/mod.rs +++ b/ctl/src/http/deployer/mod.rs @@ -4,8 +4,9 @@ use proto::ctl::deployer::{DeployReq, DeployRes}; use crate::http::HttpState; pub async fn deploy( - State(_state): State, + State(state): State, Json(_payload): Json, ) -> Json { + _ = state.discovery; todo!(); } diff --git a/worker/src/args.rs b/worker/src/args.rs index 038e3b6..c40daa8 100644 --- a/worker/src/args.rs +++ b/worker/src/args.rs @@ -5,6 +5,7 @@ use clap::{value_parser, Parser}; #[derive(Debug)] pub struct WorkerArgs { /// Controller's address. + #[allow(dead_code)] pub controller_addr: SocketAddr, /// Interval at which metrics are pushed to the controller. diff --git a/worker/src/http/runner/mod.rs b/worker/src/http/runner/mod.rs index 2744061..3ed3a1c 100644 --- a/worker/src/http/runner/mod.rs +++ b/worker/src/http/runner/mod.rs @@ -4,8 +4,9 @@ use proto::worker::runner::{DeployInstanceReq, DeployInstanceRes}; use crate::http::HttpState; pub async fn new_instance( - State(_state): State, + State(state): State, Json(_payload): Json, ) -> Json { + _ = state.runner; todo!(); }