Merge branch 'main' into dom/wal-refs
commit
9330527f61
|
@ -305,7 +305,7 @@ where
|
|||
mod tests {
|
||||
use std::sync::Arc;
|
||||
|
||||
use metric::{assert_histogram, Attributes, Metric};
|
||||
use metric::{assert_histogram, Attributes};
|
||||
|
||||
use crate::components::commit::mock::{CommitHistoryEntry, MockCommit};
|
||||
use iox_tests::ParquetFileBuilder;
|
||||
|
|
|
@ -83,7 +83,7 @@ where
|
|||
mod tests {
|
||||
use std::{collections::HashMap, sync::Arc};
|
||||
|
||||
use metric::{assert_counter, Attributes, Metric};
|
||||
use metric::{assert_counter, Attributes};
|
||||
use object_store::Error as ObjectStoreError;
|
||||
|
||||
use crate::components::partition_done_sink::mock::MockPartitionDoneSink;
|
||||
|
|
|
@ -85,7 +85,7 @@ where
|
|||
mod tests {
|
||||
use std::sync::Arc;
|
||||
|
||||
use metric::{assert_counter, Attributes, Metric};
|
||||
use metric::{assert_counter, Attributes};
|
||||
|
||||
use crate::{
|
||||
components::partition_filter::has_files::HasFilesPartitionFilter,
|
||||
|
|
|
@ -64,7 +64,7 @@ where
|
|||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use metric::{assert_counter, Attributes, Metric};
|
||||
use metric::{assert_counter, Attributes};
|
||||
|
||||
use crate::components::partition_source::mock::MockPartitionSource;
|
||||
use iox_tests::PartitionBuilder;
|
||||
|
|
|
@ -69,7 +69,7 @@ where
|
|||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use metric::{assert_counter, Attributes, Metric};
|
||||
use metric::assert_counter;
|
||||
|
||||
use crate::components::partitions_source::mock::MockPartitionsSource;
|
||||
|
||||
|
|
|
@ -106,7 +106,7 @@ mod tests {
|
|||
|
||||
use compactor2_test_utils::{create_overlapped_l0_l1_files_2, create_overlapped_l1_l2_files_2};
|
||||
use data_types::CompactionLevel;
|
||||
use metric::{assert_counter, assert_histogram, Attributes, Metric};
|
||||
use metric::{assert_counter, assert_histogram};
|
||||
|
||||
use crate::{
|
||||
components::split_or_compact::{split_compact::SplitCompact, SplitOrCompact},
|
||||
|
|
|
@ -48,10 +48,10 @@ macro_rules! assert_counter {
|
|||
#[allow(unused)]
|
||||
let mut attr = None;
|
||||
$(attr = Some($attr);)*
|
||||
let attr = attr.unwrap_or_else(|| Attributes::from(&[]));
|
||||
let attr = attr.unwrap_or_else(|| metric::Attributes::from(&[]));
|
||||
|
||||
let counter = $metrics
|
||||
.get_instrument::<Metric<$counter>>($name)
|
||||
.get_instrument::<metric::Metric<$counter>>($name)
|
||||
.expect("failed to find metric with provided name")
|
||||
.get_observer(&attr)
|
||||
.expect("failed to find metric with provided attributes")
|
||||
|
|
|
@ -106,10 +106,10 @@ macro_rules! assert_histogram {
|
|||
#[allow(unused)]
|
||||
let mut attr = None;
|
||||
$(attr = Some($attr);)*
|
||||
let attr = attr.unwrap_or_else(|| Attributes::from(&[]));
|
||||
let attr = attr.unwrap_or_else(|| metric::Attributes::from(&[]));
|
||||
|
||||
let hist = $metrics
|
||||
.get_instrument::<Metric<$hist>>($name)
|
||||
.get_instrument::<metric::Metric<$hist>>($name)
|
||||
.expect("failed to find metric with provided name")
|
||||
.get_observer(&attr)
|
||||
.expect("failed to find metric with provided attributes")
|
||||
|
|
Loading…
Reference in New Issue