Skip to content

Commit 159f82e

Browse files
author
Meshwa Savalia
committed
Add examples for High Resolution Metrics and minor test file changes
1 parent f0c5b6d commit 159f82e

File tree

3 files changed

+7
-1
lines changed

3 files changed

+7
-1
lines changed

examples/ecs-firelens/src/main/java/App.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import software.amazon.cloudwatchlogs.emf.environment.EnvironmentProvider;
2424
import software.amazon.cloudwatchlogs.emf.exception.InvalidMetricException;
2525
import software.amazon.cloudwatchlogs.emf.logger.MetricsLogger;
26+
import software.amazon.cloudwatchlogs.emf.model.StorageResolution;
2627
import software.amazon.cloudwatchlogs.emf.model.Unit;
2728
import sun.misc.Signal;
2829
import java.io.IOException;
@@ -39,6 +40,7 @@ public static void main(String[] args) throws Exception {
3940
MetricsLogger logger = new MetricsLogger();
4041
logger.setNamespace("FargateEMF");
4142
logger.putMetric("Latency", 63, Unit.MILLISECONDS);
43+
logger.putMetric("LatencyInHighResolution", 65, Unit.MILLISECONDS, StorageResolution.HIGH);
4244
logger.flush();
4345
HttpServer server = HttpServer.create(new InetSocketAddress(8000), 0);
4446
int portNumber = 8000;
@@ -75,6 +77,7 @@ public void handle(HttpExchange he) throws IOException {
7577
logger.putProperty("Url", he.getRequestURI());
7678
try {
7779
logger.putMetric("ProcessingTime", System.currentTimeMillis() - time, Unit.MILLISECONDS);
80+
logger.putMetric("ProcessingTimeInHighResolution", System.currentTimeMillis() - time, Unit.MILLISECONDS, StorageResolution.HIGH);
7881
} catch (InvalidMetricException e) {
7982
System.out.println(e);
8083
}

examples/lambda/src/main/java/Handler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import software.amazon.cloudwatchlogs.emf.exception.InvalidMetricException;
66
import software.amazon.cloudwatchlogs.emf.logger.MetricsLogger;
77
import software.amazon.cloudwatchlogs.emf.model.DimensionSet;
8+
import software.amazon.cloudwatchlogs.emf.model.StorageResolution;
89
import software.amazon.cloudwatchlogs.emf.model.Unit;
910

1011
import java.util.HashMap;
@@ -20,6 +21,7 @@ public String handleRequest(Map<String, String> event, Context context) {
2021
try {
2122
logger.putDimensions(DimensionSet.of("Service", "Aggregator"));
2223
logger.putMetric("ProcessingLatency", 100, Unit.MILLISECONDS);
24+
logger.putMetric("ProcessingLatencyInHighResolution", 101, Unit.MILLISECONDS, StorageResolution.HIGH);
2325
} catch (InvalidDimensionException | InvalidMetricException | DimensionSetExceededException e) {
2426
System.out.println(e);
2527
}

src/integration-test/java/software/amazon/cloudwatchlogs/emf/MetricsLoggerIntegrationTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import software.amazon.cloudwatchlogs.emf.exception.InvalidMetricException;
3939
import software.amazon.cloudwatchlogs.emf.logger.MetricsLogger;
4040
import software.amazon.cloudwatchlogs.emf.model.DimensionSet;
41+
import software.amazon.cloudwatchlogs.emf.model.StorageResolution;
4142
import software.amazon.cloudwatchlogs.emf.model.Unit;
4243

4344
public class MetricsLoggerIntegrationTest {
@@ -122,7 +123,7 @@ public void testMultipleFlushOverUDP() throws InterruptedException, InvalidMetri
122123
private void logMetric(Environment env, String metricName) throws InvalidMetricException {
123124
MetricsLogger logger = new MetricsLogger(env);
124125
logger.putDimensions(dimensions);
125-
logger.putMetric(metricName, 100, Unit.MILLISECONDS);
126+
logger.putMetric(metricName, 100, Unit.MILLISECONDS, StorageResolution.HIGH);
126127
logger.flush();
127128
}
128129

0 commit comments

Comments
 (0)