We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 3f391a6 + b8452a7 commit f0bcaddCopy full SHA for f0bcadd
1 file changed
src/monitor/shares.rs
@@ -7,6 +7,8 @@ use crate::{
7
proxy_state::{DownstreamType, ProxyState},
8
};
9
10
+const SHARE_BATCH_INTERVAL_SECS: u64 = 180;
11
+
12
#[derive(serde::Serialize, Clone, Debug)]
13
pub struct ShareInfo {
14
worker_name: String,
@@ -91,7 +93,8 @@ impl SharesMonitor {
91
93
92
94
pub async fn monitor(&self) {
95
let api = MonitorAPI::new(shares_server_endpoint());
- let mut interval = tokio::time::interval(std::time::Duration::from_secs(300)); // 5 minutes
96
+ let mut interval =
97
+ tokio::time::interval(std::time::Duration::from_secs(SHARE_BATCH_INTERVAL_SECS));
98
99
// First tick completes immediately
100
interval.tick().await;
0 commit comments