rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-03 05:17:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: add health metric to drainer (#2217)

Browse Source
This commit is contained in:
Kartikeya Hegde
2023-09-22 21:00:24 +05:30
committed by GitHub
parent 53c5c39ce5
commit 4e8471be50
2 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
crates/drainer/src/lib.rs
View File

@ -42,6 +42,7 @@ pub async fn start_drainer(
let active_tasks = Arc::new(atomic::AtomicU64::new(0));
'event: loop {
metrics::DRAINER_HEALTH.add(&metrics::CONTEXT, 1, &[]);
match rx.try_recv() {
Err(mpsc::error::TryRecvError::Empty) => {
if utils::is_stream_available(stream_index, store.clone()).await {