From 09fcb6eed6b0a90382ba0c27ba0c46698f57fb6c Mon Sep 17 00:00:00 2001 From: Gaius Date: Fri, 25 Aug 2023 17:26:24 +0800 Subject: [PATCH] feat: add object_storage_port and scheduler_cluster_id to SchedulerAnnouncer (#71) Signed-off-by: Gaius --- Cargo.toml | 2 +- src/announcer/mod.rs | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/Cargo.toml b/Cargo.toml index 34380eb7..a749ea99 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -55,7 +55,7 @@ local-ip-address = "0.5.3" rocksdb = "0.21.0" num_cpus = "1.0" chrono = { version = "0.4.26", features = ["serde"] } -dragonfly-api = "2.0.16" +dragonfly-api = "2.0.24" sysinfo = "0.29.6" sha2 = "0.10" hex = "0.4" diff --git a/src/announcer/mod.rs b/src/announcer/mod.rs index e201e74b..67e3145d 100644 --- a/src/announcer/mod.rs +++ b/src/announcer/mod.rs @@ -236,6 +236,7 @@ impl SchedulerAnnouncer { ip: self.config.host.ip.unwrap().to_string(), port: self.config.server.port as i32, download_port: self.config.server.port as i32, + object_storage_port: self.config.object_storage.port as i32, os: env::consts::OS.to_string(), platform: env::consts::OS.to_string(), platform_family: env::consts::FAMILY.to_string(), @@ -248,6 +249,9 @@ impl SchedulerAnnouncer { // TODO Get the disk information. disk: None, build: Some(build), + + // TODO Get scheduler cluster id from dynconfig. + scheduler_cluster_id: 0, }; // Announce the host to the scheduler.