[ONOS-7683] Add unit tests for a set of telemetry config classes
Change-Id: I73ad36e02044371a2fb87540e28ef2257a6dba92
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultGrpcTelemetryConfig.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultGrpcTelemetryConfig.java
index 7b0433e..6cee737 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultGrpcTelemetryConfig.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultGrpcTelemetryConfig.java
@@ -18,6 +18,7 @@
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
import org.onosproject.openstacktelemetry.api.config.GrpcTelemetryConfig;
+import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
import java.util.Map;
import java.util.Objects;
@@ -96,10 +97,15 @@
return Objects.hash(address, port, usePlaintext, maxInboundMsgSize, configMap);
}
+ @Override
+ public TelemetryConfig.Builder createBuilder() {
+ return new DefaultBuilder();
+ }
+
/**
* Builder class of DefaultKafkaTelemetryConfig.
*/
- public final class DefaultBuilder implements Builder {
+ public static final class DefaultBuilder implements Builder {
private String address;
private int port;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultInfluxDbTelemetryConfig.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultInfluxDbTelemetryConfig.java
index a95517b..68b28c1 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultInfluxDbTelemetryConfig.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultInfluxDbTelemetryConfig.java
@@ -18,6 +18,7 @@
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
import org.onosproject.openstacktelemetry.api.config.InfluxDbTelemetryConfig;
+import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
import java.util.Map;
import java.util.Objects;
@@ -113,10 +114,15 @@
return Objects.hash(address, port, username, password, database, enableBatch, configMap);
}
+ @Override
+ public TelemetryConfig.Builder createBuilder() {
+ return new DefaultBuilder();
+ }
+
/**
* Builder class of DefaultInfluxDbTelemetryConfig.
*/
- public final class DefaultBuilder implements Builder {
+ public static final class DefaultBuilder implements Builder {
private String address;
private int port;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultKafkaTelemetryConfig.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultKafkaTelemetryConfig.java
index 9dc460a..efde9f5 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultKafkaTelemetryConfig.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultKafkaTelemetryConfig.java
@@ -18,6 +18,7 @@
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
import org.onosproject.openstacktelemetry.api.config.KafkaTelemetryConfig;
+import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
import java.util.Map;
import java.util.Objects;
@@ -140,10 +141,15 @@
lingerMs, memoryBuffer, keySerializer, valueSerializer, configMap);
}
+ @Override
+ public TelemetryConfig.Builder createBuilder() {
+ return new DefaultBuilder();
+ }
+
/**
* Builder class of DefaultKafkaTelemetryConfig.
*/
- public final class DefaultBuilder implements Builder {
+ public static final class DefaultBuilder implements Builder {
private String address;
private int port;
private int retries;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultRestTelemetryConfig.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultRestTelemetryConfig.java
index b11b14e..29e9a2a 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultRestTelemetryConfig.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/config/DefaultRestTelemetryConfig.java
@@ -18,6 +18,7 @@
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Maps;
import org.onosproject.openstacktelemetry.api.config.RestTelemetryConfig;
+import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
import java.util.Map;
import java.util.Objects;
@@ -114,10 +115,15 @@
responseMediaType, configMap);
}
+ @Override
+ public TelemetryConfig.Builder createBuilder() {
+ return new DefaultBuilder();
+ }
+
/**
* Builder class of DefaultRestTelemetryConfig.
*/
- public final class DefaultBuilder implements Builder {
+ public static final class DefaultBuilder implements Builder {
private String address;
private int port;