feat: add object_storage_port and scheduler_cluster_id to SchedulerAnnouncer (#71)

Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
Gaius 2023-08-25 17:26:24 +08:00 committed by GitHub
parent afbacb1102
commit 09fcb6eed6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 1 deletions

View File

@ -55,7 +55,7 @@ local-ip-address = "0.5.3"
rocksdb = "0.21.0" rocksdb = "0.21.0"
num_cpus = "1.0" num_cpus = "1.0"
chrono = { version = "0.4.26", features = ["serde"] } chrono = { version = "0.4.26", features = ["serde"] }
dragonfly-api = "2.0.16" dragonfly-api = "2.0.24"
sysinfo = "0.29.6" sysinfo = "0.29.6"
sha2 = "0.10" sha2 = "0.10"
hex = "0.4" hex = "0.4"

View File

@ -236,6 +236,7 @@ impl SchedulerAnnouncer {
ip: self.config.host.ip.unwrap().to_string(), ip: self.config.host.ip.unwrap().to_string(),
port: self.config.server.port as i32, port: self.config.server.port as i32,
download_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(), os: env::consts::OS.to_string(),
platform: env::consts::OS.to_string(), platform: env::consts::OS.to_string(),
platform_family: env::consts::FAMILY.to_string(), platform_family: env::consts::FAMILY.to_string(),
@ -248,6 +249,9 @@ impl SchedulerAnnouncer {
// TODO Get the disk information. // TODO Get the disk information.
disk: None, disk: None,
build: Some(build), build: Some(build),
// TODO Get scheduler cluster id from dynconfig.
scheduler_cluster_id: 0,
}; };
// Announce the host to the scheduler. // Announce the host to the scheduler.