aboutsummaryrefslogtreecommitdiff
path: root/src/model/block_metrics.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2022-03-15 12:04:12 +0100
committerAlex Auvolat <alex@adnab.me>2022-03-23 10:25:15 +0100
commitc1d9854d2c5998adcad60784ec54659113c28a9f (patch)
treecb6bd08213ac4b97f91f9bb9ffb83244d5180e97 /src/model/block_metrics.rs
parent8565f7dc314f194ba85e9a0c8a021b9565c22e36 (diff)
downloadgarage-c1d9854d2c5998adcad60784ec54659113c28a9f.tar.gz
garage-c1d9854d2c5998adcad60784ec54659113c28a9f.zip
Move block manager to separate module
Diffstat (limited to 'src/model/block_metrics.rs')
-rw-r--r--src/model/block_metrics.rs102
1 files changed, 0 insertions, 102 deletions
diff --git a/src/model/block_metrics.rs b/src/model/block_metrics.rs
deleted file mode 100644
index f0f541a3..00000000
--- a/src/model/block_metrics.rs
+++ /dev/null
@@ -1,102 +0,0 @@
-use opentelemetry::{global, metrics::*};
-
-use garage_util::sled_counter::SledCountedTree;
-
-/// TableMetrics reference all counter used for metrics
-pub struct BlockManagerMetrics {
- pub(crate) _resync_queue_len: ValueObserver<u64>,
- pub(crate) _resync_errored_blocks: ValueObserver<u64>,
-
- pub(crate) resync_counter: BoundCounter<u64>,
- pub(crate) resync_error_counter: BoundCounter<u64>,
- pub(crate) resync_duration: BoundValueRecorder<f64>,
- pub(crate) resync_send_counter: Counter<u64>,
- pub(crate) resync_recv_counter: BoundCounter<u64>,
-
- pub(crate) bytes_read: BoundCounter<u64>,
- pub(crate) block_read_duration: BoundValueRecorder<f64>,
- pub(crate) bytes_written: BoundCounter<u64>,
- pub(crate) block_write_duration: BoundValueRecorder<f64>,
- pub(crate) delete_counter: BoundCounter<u64>,
-
- pub(crate) corruption_counter: BoundCounter<u64>,
-}
-
-impl BlockManagerMetrics {
- pub fn new(resync_queue: SledCountedTree, resync_errors: SledCountedTree) -> Self {
- let meter = global::meter("garage_model/block");
- Self {
- _resync_queue_len: meter
- .u64_value_observer("block.resync_queue_length", move |observer| {
- observer.observe(resync_queue.len() as u64, &[])
- })
- .with_description(
- "Number of block hashes queued for local check and possible resync",
- )
- .init(),
- _resync_errored_blocks: meter
- .u64_value_observer("block.resync_errored_blocks", move |observer| {
- observer.observe(resync_errors.len() as u64, &[])
- })
- .with_description("Number of block hashes whose last resync resulted in an error")
- .init(),
-
- resync_counter: meter
- .u64_counter("block.resync_counter")
- .with_description("Number of calls to resync_block")
- .init()
- .bind(&[]),
- resync_error_counter: meter
- .u64_counter("block.resync_error_counter")
- .with_description("Number of calls to resync_block that returned an error")
- .init()
- .bind(&[]),
- resync_duration: meter
- .f64_value_recorder("block.resync_duration")
- .with_description("Duration of resync_block operations")
- .init()
- .bind(&[]),
- resync_send_counter: meter
- .u64_counter("block.resync_send_counter")
- .with_description("Number of blocks sent to another node in resync operations")
- .init(),
- resync_recv_counter: meter
- .u64_counter("block.resync_recv_counter")
- .with_description("Number of blocks received from other nodes in resync operations")
- .init()
- .bind(&[]),
-
- bytes_read: meter
- .u64_counter("block.bytes_read")
- .with_description("Number of bytes read from disk")
- .init()
- .bind(&[]),
- block_read_duration: meter
- .f64_value_recorder("block.read_duration")
- .with_description("Duration of block read operations")
- .init()
- .bind(&[]),
- bytes_written: meter
- .u64_counter("block.bytes_written")
- .with_description("Number of bytes written to disk")
- .init()
- .bind(&[]),
- block_write_duration: meter
- .f64_value_recorder("block.write_duration")
- .with_description("Duration of block write operations")
- .init()
- .bind(&[]),
- delete_counter: meter
- .u64_counter("block.delete_counter")
- .with_description("Number of blocks deleted")
- .init()
- .bind(&[]),
-
- corruption_counter: meter
- .u64_counter("block.corruption_counter")
- .with_description("Data corruptions detected on block reads")
- .init()
- .bind(&[]),
- }
- }
-}