1 /***********************************************************************
2  * Copyright (c) 2013-2024 Commonwealth Computer Research, Inc.
3  * All rights reserved. This program and the accompanying materials
4  * are made available under the terms of the Apache License, Version 2.0
5  * which accompanies this distribution and is available at
6  * http://www.opensource.org/licenses/apache2.0.php.
7  ***********************************************************************/
8 
9 package org.locationtech.geomesa.metrics.micrometer
10 package cloudwatch
11 import com.typesafe.config.Config
12 import io.micrometer.cloudwatch2.CloudWatchMeterRegistry
13 import io.micrometer.core.instrument.{Clock, MeterRegistry}
14 import pureconfig.generic.semiauto.deriveReader
15 import pureconfig.{ConfigReader, ConfigSource}
16 import software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient
17 
18 object CloudwatchFactory extends RegistryFactory {
19 
20   override def apply(conf: Config): MeterRegistry = {
21     implicit val reader: ConfigReader[CloudwatchConfig] = deriveReader[CloudwatchConfig]
22     val config = ConfigSource.fromConfig(conf).loadOrThrow[CloudwatchConfig]
23     new CloudWatchMeterRegistry(k => config.properties.getOrElse(k, null), Clock.SYSTEM, CloudWatchAsyncClient.create())
24   }
25 
26   private case class CloudwatchConfig(
27       namespace: String = "geomesa",
28       properties: Map[String, String] = Map.empty
29     )
30 }