feat: 🎸 Swap to embedded metric format

(Will provide another commit to fix broken/commented out tests)

Cargo.toml

@@ -23,10 +23,13 @@ serde = "1.0"
 cached = { version = "0.46", features = ["async"] }
 env_logger = "0.10"
 aws-sdk-cloudwatchlogs = "0.37"
-aws-sdk-cloudwatch = "0.37"
 aws-config = "0.100"
 aws-smithy-types = "0.100"
 async-trait = "0.1"
+metrics_cloudwatch_embedded = "0.4"
+tracing = "0.1"
+metrics = "0.21"
+chrono = "0.4.31"
 
 [dev-dependencies]
 insta = { version = "1.34", features = ["filters"] }

src/error.rs

@@ -2,7 +2,6 @@ use std::fmt::Display;
 
 use serde::Serialize;
 
-use aws_sdk_cloudwatch::Error as CloudWatchError;
 use aws_sdk_cloudwatchlogs::Error as CloudWatchLogsError;
 
 #[derive(Debug, Serialize)]
@@ -25,16 +24,6 @@ impl Display for Error {
     }
 }
 
-// TODO: Can we find a common trait to implement From<> for instead of implementing for each client?
-impl From<CloudWatchError> for Error {
-    fn from(e: CloudWatchError) -> Self {
-        Self {
-            message: e.to_string(),
-            severity: Severity::Error,
-        }
-    }
-}
-
 impl From<CloudWatchLogsError> for Error {
     fn from(e: CloudWatchLogsError) -> Self {
         Self {

src/global.rs

@@ -1,25 +1,18 @@
 use std::{collections::HashMap, time::Duration};
 
 use aws_config::{BehaviorVersion, SdkConfig};
-use aws_sdk_cloudwatch::Client as CloudWatchMetricsClient;
 use aws_sdk_cloudwatchlogs::Client as CloudWatchLogsClient;
 use aws_smithy_types::retry::{RetryConfig, RetryMode};
 use cached::proc_macro::cached;
 
-use crate::{cloudwatch_logs_traits::CloudWatchLogs, cloudwatch_metrics_traits::CloudWatchMetrics};
+use crate::cloudwatch_logs_traits::CloudWatchLogs;
 
 #[cached]
 pub async fn cloudwatch_logs() -> CloudWatchLogs {
     let sdk_config = sdk_config().await;
     CloudWatchLogs::new(CloudWatchLogsClient::new(&sdk_config))
 }
 
-#[cached]
-pub async fn cloudwatch_metrics() -> CloudWatchMetrics {
-    let sdk_config = sdk_config().await;
-    CloudWatchMetrics::new(CloudWatchMetricsClient::new(&sdk_config))
-}
-
 #[cached]
 async fn sdk_config() -> SdkConfig {
     let retry_config = RetryConfig::standard()
@@ -64,7 +57,7 @@ mod tests {
 
     use crate::global::retention;
 
-    use super::{cloudwatch_logs, cloudwatch_metrics, initialize_logger, log_group_tags};
+    use super::{cloudwatch_logs, initialize_logger, log_group_tags};
 
     #[tokio::test]
     async fn test_cw_logs_client() {
@@ -74,14 +67,6 @@ mod tests {
         cloudwatch_logs().await;
     }
 
-    #[tokio::test]
-    async fn test_cw_metrics_client() {
-        std::env::set_var("AWS_ACCESS_KEY_ID", "AKIAASDASDQWEF");
-        std::env::set_var("AWS_SECRET_ACCESS_KEY", "ASIAAFQWEFWEIFJ");
-
-        cloudwatch_metrics().await;
-    }
-
     #[test]
     fn test_retention() {
         std::env::set_var("log_retention_in_days", "1");

src/lib.rs

@@ -1,5 +1,4 @@
 pub mod cloudwatch_logs_traits;
-pub mod cloudwatch_metrics_traits;
 pub mod error;
 pub mod event;
 pub mod global;