mirror of
https://github.com/juspay/hyperswitch.git
synced 2025-11-03 21:37:41 +08:00
21 lines
1.0 KiB
Rust
21 lines
1.0 KiB
Rust
pub use router_env::opentelemetry::KeyValue;
|
|
use router_env::{counter_metric, global_meter, histogram_metric, metrics_context};
|
|
|
|
metrics_context!(CONTEXT);
|
|
global_meter!(DRAINER_METER, "DRAINER");
|
|
|
|
counter_metric!(JOBS_PICKED_PER_STREAM, DRAINER_METER);
|
|
counter_metric!(CYCLES_COMPLETED_SUCCESSFULLY, DRAINER_METER);
|
|
counter_metric!(CYCLES_COMPLETED_UNSUCCESSFULLY, DRAINER_METER);
|
|
counter_metric!(ERRORS_WHILE_QUERY_EXECUTION, DRAINER_METER);
|
|
counter_metric!(SUCCESSFUL_QUERY_EXECUTION, DRAINER_METER);
|
|
counter_metric!(SHUTDOWN_SIGNAL_RECEIVED, DRAINER_METER);
|
|
counter_metric!(SUCCESSFUL_SHUTDOWN, DRAINER_METER);
|
|
counter_metric!(STREAM_EMPTY, DRAINER_METER);
|
|
counter_metric!(DRAINER_HEALTH, DRAINER_METER);
|
|
|
|
histogram_metric!(QUERY_EXECUTION_TIME, DRAINER_METER); // Time in (ms) milliseconds
|
|
histogram_metric!(REDIS_STREAM_READ_TIME, DRAINER_METER); // Time in (ms) milliseconds
|
|
histogram_metric!(REDIS_STREAM_TRIM_TIME, DRAINER_METER); // Time in (ms) milliseconds
|
|
histogram_metric!(CLEANUP_TIME, DRAINER_METER); // Time in (ms) milliseconds
|