[ONOS-7683] Add default implementation of telemetry config managers
Change-Id: Iac3681ceff2b343746d2d0b1043300044043b63a
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryConfigManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryConfigManager.java
index 3aba590..77c3d63 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryConfigManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryConfigManager.java
@@ -15,16 +15,150 @@
*/
package org.onosproject.openstacktelemetry.impl;
+import org.apache.felix.scr.annotations.Activate;
+import org.apache.felix.scr.annotations.Deactivate;
+import org.apache.felix.scr.annotations.Modified;
+import org.apache.felix.scr.annotations.Property;
+import org.apache.felix.scr.annotations.Reference;
+import org.apache.felix.scr.annotations.ReferenceCardinality;
+import org.onlab.util.Tools;
+import org.onosproject.cfg.ComponentConfigService;
+import org.onosproject.openstacktelemetry.api.InfluxDbTelemetryAdminService;
import org.onosproject.openstacktelemetry.api.InfluxDbTelemetryConfigService;
import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
+import org.onosproject.openstacktelemetry.config.DefaultInfluxDbTelemetryConfig;
+import org.osgi.service.component.ComponentContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Dictionary;
+
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_DATABASE;
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_ENABLE_BATCH;
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_PASSWORD;
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_SERVER_IP;
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_SERVER_PORT;
+import static org.onosproject.openstacktelemetry.api.Constants.DEFAULT_INFLUXDB_USERNAME;
+import static org.onosproject.openstacktelemetry.util.OpenstackTelemetryUtil.getBooleanProperty;
/**
* InfluxDB server configuration manager for publishing openstack telemetry.
*/
public class InfluxDbTelemetryConfigManager implements InfluxDbTelemetryConfigService {
+ private final Logger log = LoggerFactory.getLogger(getClass());
+
+ private static final String ADDRESS = "address";
+ private static final String PORT = "port";
+ private static final String USERNAME = "username";
+ private static final String PASSWORD = "password";
+ private static final String DATABASE = "database";
+ private static final String ENABLE_BATCH = "enableBatch";
+
+ @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+ protected ComponentConfigService componentConfigService;
+
+ @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+ protected InfluxDbTelemetryAdminService influxDbTelemetryAdminService;
+
+ @Property(name = ADDRESS, value = DEFAULT_INFLUXDB_SERVER_IP,
+ label = "Default IP address to establish initial connection to InfluxDB server")
+ protected String address = DEFAULT_INFLUXDB_SERVER_IP;
+
+ @Property(name = PORT, intValue = DEFAULT_INFLUXDB_SERVER_PORT,
+ label = "Default port number to establish initial connection to InfluxDB server")
+ protected Integer port = DEFAULT_INFLUXDB_SERVER_PORT;
+
+ @Property(name = USERNAME, value = DEFAULT_INFLUXDB_USERNAME,
+ label = "Username used for authenticating against InfluxDB server")
+ protected String username = DEFAULT_INFLUXDB_USERNAME;
+
+ @Property(name = PASSWORD, value = DEFAULT_INFLUXDB_PASSWORD,
+ label = "Password used for authenticating against InfluxDB server")
+ protected String password = DEFAULT_INFLUXDB_PASSWORD;
+
+ @Property(name = DATABASE, value = DEFAULT_INFLUXDB_DATABASE,
+ label = "Database of InfluxDB server")
+ protected String database = DEFAULT_INFLUXDB_DATABASE;
+
+ @Property(name = ENABLE_BATCH, boolValue = DEFAULT_INFLUXDB_ENABLE_BATCH,
+ label = "Flag value of enabling batch mode of InfluxDB server")
+ protected Boolean enableBatch = DEFAULT_INFLUXDB_ENABLE_BATCH;
+
+ @Activate
+ protected void activate(ComponentContext context) {
+ componentConfigService.registerProperties(getClass());
+ influxDbTelemetryAdminService.start(getConfig());
+ log.info("Started");
+ }
+
+ @Deactivate
+ protected void deactivate() {
+ componentConfigService.unregisterProperties(getClass(), false);
+ influxDbTelemetryAdminService.stop();
+ log.info("Stopped");
+ }
+
+ @Modified
+ private void modified(ComponentContext context) {
+ readComponentConfiguration(context);
+ influxDbTelemetryAdminService.restart(getConfig());
+ log.info("Modified");
+ }
+
@Override
public TelemetryConfig getConfig() {
- return null;
+ return new DefaultInfluxDbTelemetryConfig.DefaultBuilder()
+ .withAddress(address)
+ .withPort(port)
+ .withUsername(username)
+ .withPassword(password)
+ .withDatabase(database)
+ .withEnableBatch(enableBatch)
+ .build();
+ }
+
+ /**
+ * Extracts properties from the component configuration context.
+ *
+ * @param context the component context
+ */
+ private void readComponentConfiguration(ComponentContext context) {
+ Dictionary<?, ?> properties = context.getProperties();
+
+ String addressStr = Tools.get(properties, ADDRESS);
+ address = addressStr != null ? addressStr : DEFAULT_INFLUXDB_SERVER_IP;
+ log.info("Configured. InfluxDB server address is {}", address);
+
+ Integer portConfigured = Tools.getIntegerProperty(properties, PORT);
+ if (portConfigured == null) {
+ port = DEFAULT_INFLUXDB_SERVER_PORT;
+ log.info("InfluxDB server port is NOT configured, default value is {}", port);
+ } else {
+ port = portConfigured;
+ log.info("Configured. InfluxDB server port is {}", port);
+ }
+
+ String usernameStr = Tools.get(properties, USERNAME);
+ username = usernameStr != null ? usernameStr : DEFAULT_INFLUXDB_USERNAME;
+ log.info("Configured. InfluxDB server username is {}", username);
+
+ String passwordStr = Tools.get(properties, PASSWORD);
+ password = passwordStr != null ? passwordStr : DEFAULT_INFLUXDB_PASSWORD;
+ log.info("Configured. InfluxDB server password is {}", password);
+
+ String databaseStr = Tools.get(properties, DATABASE);
+ database = databaseStr != null ? databaseStr : DEFAULT_INFLUXDB_DATABASE;
+ log.info("Configured. InfluxDB server database is {}", database);
+
+ Boolean enableBatchConfigured = getBooleanProperty(properties, ENABLE_BATCH);
+ if (enableBatchConfigured == null) {
+ enableBatch = DEFAULT_INFLUXDB_ENABLE_BATCH;
+ log.info("InfluxDB server enable batch flag is " +
+ "NOT configured, default value is {}", enableBatch);
+ } else {
+ enableBatch = enableBatchConfigured;
+ log.info("Configured. InfluxDB server enable batch is {}", enableBatch);
+ }
}
}