Skip to content

Commit 547887c

Browse files
committed
ref: renamed runtime status update env
1 parent f72a532 commit 547887c

2 files changed

Lines changed: 7 additions & 6 deletions

File tree

crates/taurus/src/app/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -135,12 +135,12 @@ async fn setup_dynamic_services_if_needed(
135135
.await;
136136
}
137137

138-
let runtime_status_heartbeat_task = if config.adapter_status_update_interval_seconds > 0 {
138+
let runtime_status_heartbeat_task = if config.runtime_status_update_interval_seconds > 0 {
139139
let status_service = runtime_status_service
140140
.as_ref()
141141
.expect("runtime status service should exist in dynamic mode")
142142
.clone();
143-
let update_interval_seconds = config.adapter_status_update_interval_seconds;
143+
let update_interval_seconds = config.runtime_status_update_interval_seconds;
144144

145145
let handle = tokio::spawn(async move {
146146
let mut interval = tokio::time::interval(Duration::from_secs(update_interval_seconds));

crates/taurus/src/config/mod.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,14 @@ use code0_flow::flow_config::mode::Mode;
33

44
/// Struct for all relevant `Taurus` startup configurations
55
pub struct Config {
6-
/// Aquila mode
6+
/// Taurus mode
77
///
88
/// Options:
99
/// `static` (default)
1010
/// `hybrid`
1111
pub mode: Mode,
1212

13+
/// URL to the NATS service
1314
pub nats_url: String,
1415

1516
pub aquila_url: String,
@@ -26,7 +27,7 @@ pub struct Config {
2627

2728
/// Runtime status heartbeat interval in seconds while Taurus is running.
2829
/// Set to 0 to disable periodic heartbeat updates.
29-
pub adapter_status_update_interval_seconds: u64,
30+
pub runtime_status_update_interval_seconds: u64,
3031
}
3132

3233
/// Implementation for all relevant `Aquila` startup configurations
@@ -44,8 +45,8 @@ impl Config {
4445
grpc_host: env_with_default("GRPC_HOST", "127.0.0.1".to_string()),
4546
grpc_port: env_with_default("GRPC_PORT", 50051),
4647
definitions: env_with_default("DEFINITIONS", String::from("./definitions")),
47-
adapter_status_update_interval_seconds: env_with_default(
48-
"ADAPTER_STATUS_UPDATE_INTERVAL_SECONDS",
48+
runtime_status_update_interval_seconds: env_with_default(
49+
"RUNTIME_STATUS_UPDATE_INTERVAL_SECONDS",
4950
30_u64,
5051
),
5152
}

0 commit comments

Comments
 (0)