Add CloudWatchMetricPublisher, a MetricPublisher implementation that uploads metric data to CloudWatch.

Author: millems

core/metrics-spi/src/main/java/software/amazon/awssdk/metrics/MetricCollection.java

@@ -15,6 +15,7 @@
 
 package software.amazon.awssdk.metrics;
 
+import java.time.Instant;
 import java.util.List;
 import software.amazon.awssdk.annotations.SdkPublicApi;
 
@@ -41,4 +42,9 @@ public interface MetricCollection extends Iterable<MetricRecord<?>> {
      * @return The child metric collections.
      */
     List<MetricCollection> children();
+
+    /**
+     * @return The time at which this collection was created.
+     */
+    Instant creationTime();
 }

core/metrics-spi/src/main/java/software/amazon/awssdk/metrics/SdkMetric.java

@@ -52,6 +52,20 @@ public interface SdkMetric<T> {
      */
     T convertValue(Object o);
 
+    /**
+     * Create a new metric under the {@link MetricCategory#DEFAULT} category.
+     *
+     * @param name The name of this metric.
+     * @param clzz The class of the object containing the associated value for this metric.
+     * @param <T> The type of the object containing the associated value for this metric.
+     * @return The created metric.
+     *
+     * @throws IllegalArgumentException If a metric of the same name has already been created.
+     */
+    static <T> SdkMetric<T> create(String name, Class<T> clzz) {
+        return DefaultSdkMetric.create(name, clzz, MetricCategory.DEFAULT);
+    }
+
     /**
      * Create a new metric.
      *

core/metrics-spi/src/main/java/software/amazon/awssdk/metrics/internal/DefaultMetricCollection.java

@@ -17,6 +17,7 @@
 
 import static java.util.stream.Collectors.toList;
 
+import java.time.Instant;
 import java.util.Collections;
 import java.util.Iterator;
 import java.util.List;
@@ -32,14 +33,15 @@ public final class DefaultMetricCollection implements MetricCollection {
     private final String name;
     private final Map<SdkMetric<?>, List<MetricRecord<?>>> metrics;
     private final List<MetricCollection> children;
-
+    private final Instant creationTime;
 
     public DefaultMetricCollection(String name, Map<SdkMetric<?>,
         List<MetricRecord<?>>> metrics,
                                    List<MetricCollection> children) {
         this.name = name;
         this.metrics = metrics;
         this.children = children != null ? Collections.unmodifiableList(children) : Collections.emptyList();
+        this.creationTime = Instant.now();
     }
 
     @Override
@@ -65,6 +67,11 @@ public List<MetricCollection> children() {
         return children;
     }
 
+    @Override
+    public Instant creationTime() {
+        return creationTime;
+    }
+
     @Override
     public Iterator<MetricRecord<?>> iterator() {
         return metrics.values().stream()

metric-publishers/cloudwatch-metric-publisher/pom.xml

@@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>
+<!--
+  ~ Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+  ~
+  ~ Licensed under the Apache License, Version 2.0 (the "License").
+  ~ You may not use this file except in compliance with the License.
+  ~ A copy of the License is located at
+  ~
+  ~  http://aws.amazon.com/apache2.0
+  ~
+  ~ or in the "license" file accompanying this file. This file is distributed
+  ~ on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
+  ~ express or implied. See the License for the specific language governing
+  ~ permissions and limitations under the License.
+  --><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>software.amazon.awssdk</groupId>
+        <artifactId>metric-publishers</artifactId>
+        <version>2.13.23-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>cloudwatch-metric-publisher</artifactId>
+    <name>AWS Java SDK :: Metric Publishers :: CloudWatch</name>
+    <packaging>jar</packaging>
+
+    <dependencies>
+        <dependency>
+            <groupId>software.amazon.awssdk</groupId>
+            <artifactId>cloudwatch</artifactId>
+            <version>${awsjavasdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>software.amazon.awssdk</groupId>
+            <artifactId>annotations</artifactId>
+            <version>${awsjavasdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>software.amazon.awssdk</groupId>
+            <artifactId>sdk-core</artifactId>
+            <version>${awsjavasdk.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>software.amazon.awssdk</groupId>
+            <artifactId>http-client-spi</artifactId>
+            <version>${awsjavasdk.version}</version>
+        </dependency>
+    </dependencies>
+</project>