test: metrics

.github/workflows/ci.yml

@@ -91,6 +91,6 @@ jobs:
             "repo": "${{ github.repository }}",
             "ref": "${{ github.ref }}",
             "lang": "rust",
-            "test_cmd": "cargo test --all-features -- --skip access_token"
+            "test_cmd": "cargo test --all-features -- --skip access_token --skip metrics"
           }
         ]

src/types.rs

@@ -1996,7 +1996,7 @@ impl From<IssueAccessTokenInput> for api::access::AccessTokenInfo {
     }
 }
 
-#[derive(Debug, Clone, Copy)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
 /// Interval to accumulate over for timeseries metric sets.
 pub enum TimeseriesInterval {
     /// Minute.
@@ -2301,7 +2301,7 @@ impl From<GetStreamMetricsInput> for (BasinName, StreamName, api::metrics::Strea
     }
 }
 
-#[derive(Debug, Clone, Copy)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
 /// Unit in which metric values are measured.
 pub enum MetricUnit {
     /// Size in bytes.

tests/common/mod.rs

@@ -76,6 +76,12 @@ impl Deref for S2Basin {
     }
 }
 
+impl S2Basin {
+    pub fn basin_name(&self) -> &BasinName {
+        &self.basin_name
+    }
+}
+
 impl AsyncTestContext for S2Basin {
     async fn setup() -> Self {
         let config = default_s2_config().expect("valid S2 config");
@@ -114,6 +120,16 @@ impl Deref for S2Stream {
     }
 }
 
+impl S2Stream {
+    pub fn basin_name(&self) -> &BasinName {
+        self.basin.basin_name()
+    }
+
+    pub fn stream_name(&self) -> &StreamName {
+        &self.stream_name
+    }
+}
+
 impl AsyncTestContext for S2Stream {
     async fn setup() -> Self {
         let basin = SharedS2Basin::setup().await;