rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-10-30 01:27:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore(kv): add metrics while pushing to stream (#3364)

Browse Source
This commit is contained in:
Kartikeya Hegde
2024-01-30 11:35:05 +00:00
committed by GitHub
parent ac491038b1
commit 8c0c49c6bb
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
crates/storage_impl/src/lib.rs
View File

@ -225,6 +225,11 @@ impl<T: DatabaseStore> KVRouterStore<T> {
.change_context(RedisError::JsonSerializationFailed)?, .change_context(RedisError::JsonSerializationFailed)?,
) )
.await .await
.map(|_| metrics::KV_PUSHED_TO_DRAINER.add(&metrics::CONTEXT, 1, &[]))
.map_err(|err| {
metrics::KV_FAILED_TO_PUSH_TO_DRAINER.add(&metrics::CONTEXT, 1, &[]);
err
})
.change_context(RedisError::StreamAppendFailed) .change_context(RedisError::StreamAppendFailed)
} }
} }

2
crates/storage_impl/src/metrics.rs
View File

@ -8,3 +8,5 @@ counter_metric!(KV_MISS, GLOBAL_METER); // No. of KV misses
// Metrics for KV // Metrics for KV
counter_metric!(KV_OPERATION_SUCCESSFUL, GLOBAL_METER); counter_metric!(KV_OPERATION_SUCCESSFUL, GLOBAL_METER);
counter_metric!(KV_OPERATION_FAILED, GLOBAL_METER); counter_metric!(KV_OPERATION_FAILED, GLOBAL_METER);
counter_metric!(KV_PUSHED_TO_DRAINER, GLOBAL_METER);
counter_metric!(KV_FAILED_TO_PUSH_TO_DRAINER, GLOBAL_METER);