Add REST API for query/update/delete/enable/disable telemetry config
1. Add unit test for newly added REST APIs
2. Add codec and unit tests for TelemetryConfig
3. Split web package out from app package due to dep conflict
Change-Id: I85f52b2a7d059622e98832843bc9613cb8befa98
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/FlowInfoJsonCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/FlowInfoJsonCodec.java
deleted file mode 100644
index be51b15..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/FlowInfoJsonCodec.java
+++ /dev/null
@@ -1,148 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.codec;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import org.onlab.packet.IpAddress;
-import org.onlab.packet.IpPrefix;
-import org.onlab.packet.MacAddress;
-import org.onlab.packet.TpPort;
-import org.onlab.packet.VlanId;
-import org.onosproject.codec.CodecContext;
-import org.onosproject.codec.JsonCodec;
-import org.onosproject.net.DeviceId;
-import org.onosproject.openstacktelemetry.api.FlowInfo;
-import org.onosproject.openstacktelemetry.api.StatsInfo;
-import org.onosproject.openstacktelemetry.impl.DefaultFlowInfo;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static org.onlab.packet.VlanId.NO_VID;
-
-/**
- * Openstack telemetry codec used for serializing and de-serializing JSON string.
- */
-public final class FlowInfoJsonCodec extends JsonCodec<FlowInfo> {
-
- private static final String FLOW_TYPE = "flowType";
- private static final String DEVICE_ID = "deviceId";
- private static final String INPUT_INTERFACE_ID = "inputInterfaceId";
- private static final String OUTPUT_INTERFACE_ID = "outputInterfaceId";
-
- private static final String VLAN_ID = "vlanId";
- private static final String VXLAN_ID = "vxlanId";
- private static final String SRC_IP = "srcIp";
- private static final String SRC_IP_PREFIX_LEN = "srcIpPrefixLength";
- private static final String DST_IP = "dstIp";
- private static final String DST_IP_PREFIX_LEN = "dstIpPrefixLength";
- private static final String SRC_PORT = "srcPort";
- private static final String DST_PORT = "dstPort";
- private static final String PROTOCOL = "protocol";
- private static final String SRC_MAC = "srcMac";
- private static final String DST_MAC = "dstMac";
- private static final String STATS_INFO = "statsInfo";
-
- @Override
- public ObjectNode encode(FlowInfo info, CodecContext context) {
- checkNotNull(info, "FlowInfo cannot be null");
-
- ObjectNode result = context.mapper().createObjectNode()
- .put(FLOW_TYPE, info.flowType())
- .put(DEVICE_ID, info.deviceId().toString())
- .put(INPUT_INTERFACE_ID, info.inputInterfaceId())
- .put(OUTPUT_INTERFACE_ID, info.outputInterfaceId())
- .put(SRC_IP, info.srcIp().address().toString())
- .put(SRC_IP_PREFIX_LEN, info.srcIp().prefixLength())
- .put(DST_IP, info.dstIp().address().toString())
- .put(DST_IP_PREFIX_LEN, info.dstIp().prefixLength())
- .put(SRC_PORT, info.srcPort().toString())
- .put(DST_PORT, info.dstPort().toString())
- .put(PROTOCOL, info.protocol())
- .put(SRC_MAC, info.srcMac().toString())
- .put(DST_MAC, info.dstMac().toString());
-
- if (info.vlanId() != null) {
- result.put(VLAN_ID, info.vlanId().toString());
- } else {
- result.put(VXLAN_ID, info.vxlanId());
- }
-
- ObjectNode statsInfoJson =
- context.codec(StatsInfo.class).encode(info.statsInfo(), context);
-
- result.put(STATS_INFO, statsInfoJson);
-
- return result;
- }
-
- @Override
- public FlowInfo decode(ObjectNode json, CodecContext context) {
- if (json == null || !json.isObject()) {
- return null;
- }
-
- String flowType = json.get(FLOW_TYPE).asText();
- String deviceId = json.get(DEVICE_ID).asText();
- int inputInterfaceId = json.get(INPUT_INTERFACE_ID).asInt();
- int outputInterfaceId = json.get(OUTPUT_INTERFACE_ID).asInt();
- String srcIp = json.get(SRC_IP).asText();
- int srcIpPrefixLength = json.get(SRC_IP_PREFIX_LEN).asInt();
- String dstIp = json.get(DST_IP).asText();
- int dstIpPrefixLength = json.get(DST_IP_PREFIX_LEN).asInt();
- int srcPort = json.get(SRC_PORT).asInt();
- int dstPort = json.get(DST_PORT).asInt();
- String protocol = json.get(PROTOCOL).asText();
- String srcMac = json.get(SRC_MAC).asText();
- String dstMac = json.get(DST_MAC).asText();
-
- VlanId vlanId;
- short vxlanId = 0;
- try {
- if (json.get(VLAN_ID).isNull()) {
- vlanId = VlanId.vlanId(NO_VID);
- if (!(json.get(VXLAN_ID).isNull())) {
- vxlanId = (short) json.get(VXLAN_ID).asInt();
- }
- } else {
- vlanId = VlanId.vlanId((short) json.get(VLAN_ID).asInt());
- }
- } catch (NullPointerException ex) {
- vlanId = VlanId.vlanId();
- }
-
- JsonNode statsInfoJson = json.get(STATS_INFO);
-
- JsonCodec<StatsInfo> statsInfoCodec = context.codec(StatsInfo.class);
- StatsInfo statsInfo = statsInfoCodec.decode((ObjectNode) statsInfoJson.deepCopy(), context);
-
- return new DefaultFlowInfo.DefaultBuilder()
- .withFlowType(Byte.valueOf(flowType))
- .withDeviceId(DeviceId.deviceId(deviceId))
- .withInputInterfaceId(inputInterfaceId)
- .withOutputInterfaceId(outputInterfaceId)
- .withSrcIp(IpPrefix.valueOf(IpAddress.valueOf(srcIp), srcIpPrefixLength))
- .withDstIp(IpPrefix.valueOf(IpAddress.valueOf(dstIp), dstIpPrefixLength))
- .withSrcPort(TpPort.tpPort(srcPort))
- .withDstPort(TpPort.tpPort(dstPort))
- .withProtocol(Byte.valueOf(protocol))
- .withSrcMac(MacAddress.valueOf(srcMac))
- .withDstMac(MacAddress.valueOf(dstMac))
- .withVlanId(vlanId)
- .withVxlanId(vxlanId)
- .withStatsInfo(statsInfo)
- .build();
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsFlowRuleJsonCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsFlowRuleJsonCodec.java
deleted file mode 100644
index 384987b..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsFlowRuleJsonCodec.java
+++ /dev/null
@@ -1,91 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.codec;
-
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import org.apache.commons.lang3.exception.ExceptionUtils;
-import org.onlab.packet.TpPort;
-import org.onosproject.codec.CodecContext;
-import org.onosproject.codec.JsonCodec;
-import org.onosproject.openstacktelemetry.api.StatsFlowRule;
-import org.onosproject.openstacktelemetry.impl.DefaultStatsFlowRule;
-import org.slf4j.Logger;
-
-import org.onlab.packet.IpPrefix;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static org.onosproject.openstacktelemetry.util.OpenstackTelemetryUtil.getProtocolTypeFromString;
-import static org.slf4j.LoggerFactory.getLogger;
-
-/**
- * JSON codec for StatsFlowRule.
- */
-public class StatsFlowRuleJsonCodec extends JsonCodec<StatsFlowRule> {
-
- private final Logger log = getLogger(getClass());
-
- public static final String SRC_IP_PREFIX = "srcIpPrefix";
- public static final String DST_IP_PREFIX = "dstIpPrefix";
- public static final String IP_PROTOCOL = "ipProtocol";
- public static final String SRC_TP_PORT = "srcTpPort";
- public static final String DST_TP_PORT = "dstTpPort";
-
- public ObjectNode encode(StatsFlowRule flowRule, CodecContext context) {
- checkNotNull(flowRule, "FlowInfo cannot be null");
- ObjectNode result = context.mapper().createObjectNode()
- .put(SRC_IP_PREFIX, flowRule.srcIpPrefix().toString())
- .put(DST_IP_PREFIX, flowRule.dstIpPrefix().toString())
- .put(IP_PROTOCOL, flowRule.ipProtocol())
- .put(SRC_TP_PORT, flowRule.srcTpPort().toString())
- .put(DST_TP_PORT, flowRule.dstTpPort().toString());
- return result;
- }
-
- @Override
- public StatsFlowRule decode(ObjectNode json, CodecContext context) {
- if (json == null || !json.isObject()) {
- return null;
- }
- try {
- String srcIpPrefix = json.get(SRC_IP_PREFIX).asText();
- String dstIpPrefix = json.get(DST_IP_PREFIX).asText();
-
- DefaultStatsFlowRule.Builder flowRuleBuilder;
-
- if (json.get(IP_PROTOCOL) == null) {
- log.info("ipProtocol: null");
- flowRuleBuilder = DefaultStatsFlowRule.builder()
- .srcIpPrefix(IpPrefix.valueOf(srcIpPrefix))
- .dstIpPrefix(IpPrefix.valueOf(dstIpPrefix));
- } else {
- byte ipProtocol = getProtocolTypeFromString(json.get(IP_PROTOCOL).asText());
- int srcTpPort = json.get(SRC_TP_PORT).asInt();
- int dstTpPort = json.get(DST_TP_PORT).asInt();
-
- flowRuleBuilder = DefaultStatsFlowRule.builder()
- .srcIpPrefix(IpPrefix.valueOf(srcIpPrefix))
- .dstIpPrefix(IpPrefix.valueOf(dstIpPrefix))
- .ipProtocol(ipProtocol)
- .srcTpPort(TpPort.tpPort(srcTpPort))
- .dstTpPort(TpPort.tpPort(dstTpPort));
- }
- return flowRuleBuilder.build();
- } catch (Exception ex) {
- log.error("Exception Stack:\n{}", ExceptionUtils.getStackTrace(ex));
- }
- return null;
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsInfoJsonCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsInfoJsonCodec.java
deleted file mode 100644
index 905b2ff..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/StatsInfoJsonCodec.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.codec;
-
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import org.onosproject.codec.CodecContext;
-import org.onosproject.codec.JsonCodec;
-import org.onosproject.openstacktelemetry.api.StatsInfo;
-import org.onosproject.openstacktelemetry.impl.DefaultStatsInfo;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-
-/**
- * Openstack telemetry codec used for serializing and de-serializing JSON string.
- */
-public final class StatsInfoJsonCodec extends JsonCodec<StatsInfo> {
-
- private static final String STARTUP_TIME = "startupTime";
- private static final String FST_PKT_ARR_TIME = "fstPktArrTime";
- private static final String LST_PKT_OFFSET = "lstPktOffset";
- private static final String PREV_ACC_BYTES = "prevAccBytes";
- private static final String PREV_ACC_PKTS = "prevAccPkts";
- private static final String CURR_ACC_BYTES = "currAccBytes";
- private static final String CURR_ACC_PKTS = "currAccPkts";
- private static final String ERROR_PKTS = "errorPkts";
- private static final String DROP_PKTS = "dropPkts";
-
- @Override
- public ObjectNode encode(StatsInfo info, CodecContext context) {
- checkNotNull(info, "StatsInfo cannot be null");
-
- return context.mapper().createObjectNode()
- .put(STARTUP_TIME, info.startupTime())
- .put(FST_PKT_ARR_TIME, info.fstPktArrTime())
- .put(LST_PKT_OFFSET, info.lstPktOffset())
- .put(PREV_ACC_BYTES, info.prevAccBytes())
- .put(PREV_ACC_PKTS, info.prevAccPkts())
- .put(CURR_ACC_BYTES, info.prevAccBytes())
- .put(CURR_ACC_PKTS, info.prevAccPkts())
- .put(ERROR_PKTS, info.errorPkts())
- .put(DROP_PKTS, info.dropPkts());
- }
-
- @Override
- public StatsInfo decode(ObjectNode json, CodecContext context) {
- if (json == null || !json.isObject()) {
- return null;
- }
-
- return new DefaultStatsInfo.DefaultBuilder()
- .withStartupTime(json.get(STARTUP_TIME).asLong())
- .withFstPktArrTime(json.get(FST_PKT_ARR_TIME).asLong())
- .withLstPktOffset(json.get(LST_PKT_OFFSET).asInt())
- .withPrevAccBytes(json.get(PREV_ACC_BYTES).asLong())
- .withPrevAccPkts(json.get(PREV_ACC_PKTS).asInt())
- .withCurrAccBytes(json.get(CURR_ACC_BYTES).asLong())
- .withCurrAccPkts(json.get(CURR_ACC_PKTS).asInt())
- .withErrorPkts((short) json.get(ERROR_PKTS).asInt())
- .withDropPkts((short) json.get(DROP_PKTS).asInt())
- .build();
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaFlowInfoByteBufferCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaFlowInfoByteBufferCodec.java
similarity index 97%
rename from apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaFlowInfoByteBufferCodec.java
rename to apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaFlowInfoByteBufferCodec.java
index 2ee625f..759dd5a 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaFlowInfoByteBufferCodec.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaFlowInfoByteBufferCodec.java
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.onosproject.openstacktelemetry.codec;
+package org.onosproject.openstacktelemetry.codec.bytebuffer;
import org.onlab.packet.IpAddress;
import org.onlab.packet.IpAddress.Version;
@@ -25,7 +25,7 @@
import org.onosproject.openstacktelemetry.api.ByteBufferCodec;
import org.onosproject.openstacktelemetry.api.FlowInfo;
import org.onosproject.openstacktelemetry.api.StatsInfo;
-import org.onosproject.openstacktelemetry.impl.DefaultFlowInfo;
+import org.onosproject.openstacktelemetry.api.DefaultFlowInfo;
import java.nio.ByteBuffer;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaMessageByteBufferCodec.java
similarity index 97%
rename from apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java
rename to apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaMessageByteBufferCodec.java
index 2be5f3e..514bc23 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaMessageByteBufferCodec.java
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.onosproject.openstacktelemetry.codec;
+package org.onosproject.openstacktelemetry.codec.bytebuffer;
import org.onosproject.openstacktelemetry.api.FlowInfo;
import org.onosproject.openstacktelemetry.api.TelemetryCodec;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaStatsInfoByteBufferCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaStatsInfoByteBufferCodec.java
similarity index 95%
rename from apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaStatsInfoByteBufferCodec.java
rename to apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaStatsInfoByteBufferCodec.java
index ce3faa8..456dc72 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaStatsInfoByteBufferCodec.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/TinaStatsInfoByteBufferCodec.java
@@ -13,11 +13,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package org.onosproject.openstacktelemetry.codec;
+package org.onosproject.openstacktelemetry.codec.bytebuffer;
import org.onosproject.openstacktelemetry.api.ByteBufferCodec;
import org.onosproject.openstacktelemetry.api.StatsInfo;
-import org.onosproject.openstacktelemetry.impl.DefaultStatsInfo;
+import org.onosproject.openstacktelemetry.api.DefaultStatsInfo;
import java.nio.ByteBuffer;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/package-info.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/package-info.java
similarity index 91%
rename from apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/package-info.java
rename to apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/package-info.java
index f7f6401..b8ef80a 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/package-info.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/bytebuffer/package-info.java
@@ -17,4 +17,4 @@
/**
* Implementations of the codec broker and openstack telemetry entity codecs.
*/
-package org.onosproject.openstacktelemetry.codec;
\ No newline at end of file
+package org.onosproject.openstacktelemetry.codec.bytebuffer;
\ No newline at end of file
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/gui/OpensteckTelemetryViewMessageHandler.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/gui/OpensteckTelemetryViewMessageHandler.java
index dcb7082..f6d9bdd 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/gui/OpensteckTelemetryViewMessageHandler.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/gui/OpensteckTelemetryViewMessageHandler.java
@@ -30,7 +30,7 @@
import org.onosproject.openstacktelemetry.api.FlowInfo;
import org.onosproject.openstacktelemetry.api.StatsFlowRule;
import org.onosproject.openstacktelemetry.api.StatsFlowRuleAdminService;
-import org.onosproject.openstacktelemetry.impl.DefaultStatsFlowRule;
+import org.onosproject.openstacktelemetry.api.DefaultStatsFlowRule;
import org.onosproject.ui.RequestHandler;
import org.onosproject.ui.UiConnection;
import org.onosproject.ui.UiMessageHandler;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java
deleted file mode 100644
index b0d3aad..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultFlowInfo.java
+++ /dev/null
@@ -1,354 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.impl;
-
-import org.onlab.packet.IpPrefix;
-import org.onlab.packet.MacAddress;
-import org.onlab.packet.TpPort;
-import org.onlab.packet.VlanId;
-import org.onosproject.net.DeviceId;
-import org.onosproject.openstacktelemetry.api.FlowInfo;
-import org.onosproject.openstacktelemetry.api.StatsInfo;
-
-import java.util.Objects;
-
-import static com.google.common.base.MoreObjects.toStringHelper;
-import static com.google.common.base.Preconditions.checkNotNull;
-import static org.onosproject.openstacktelemetry.util.OpenstackTelemetryUtil.getProtocolNameFromType;
-
-/**
- * Implementation class of FlowInfo.
- */
-public final class DefaultFlowInfo implements FlowInfo {
- private static final String INGRESS_STATS = "Ingress Port :";
- private static final String EGRESS_STATS = "Egress Port :";
-
- private final byte flowType;
- private final DeviceId deviceId;
- private final int inputInterfaceId;
- private final int outputInterfaceId;
- private final VlanId vlanId;
- private final short vxlanId;
- private final IpPrefix srcIp;
- private final IpPrefix dstIp;
- private final TpPort srcPort;
- private final TpPort dstPort;
- private final byte protocol;
- private final MacAddress srcMac;
- private final MacAddress dstMac;
- private final StatsInfo statsInfo;
-
- private DefaultFlowInfo(byte flowType, DeviceId deviceId,
- int inputInterfaceId, int outputInterfaceId,
- VlanId vlanId, short vxlanId, IpPrefix srcIp,
- IpPrefix dstIp, TpPort srcPort, TpPort dstPort,
- byte protocol, MacAddress srcMac, MacAddress dstMac,
- StatsInfo statsInfo) {
- this.flowType = flowType;
- this.deviceId = deviceId;
- this.inputInterfaceId = inputInterfaceId;
- this.outputInterfaceId = outputInterfaceId;
- this.vlanId = vlanId;
- this.vxlanId = vxlanId;
- this.srcIp = srcIp;
- this.dstIp = dstIp;
- this.srcPort = srcPort;
- this.dstPort = dstPort;
- this.protocol = protocol;
- this.srcMac = srcMac;
- this.dstMac = dstMac;
- this.statsInfo = statsInfo;
- }
-
- @Override
- public byte flowType() {
- return flowType;
- }
-
- @Override
- public DeviceId deviceId() {
- return deviceId;
- }
-
- @Override
- public int inputInterfaceId() {
- return inputInterfaceId;
- }
-
- @Override
- public int outputInterfaceId() {
- return outputInterfaceId;
- }
-
- @Override
- public VlanId vlanId() {
- return vlanId;
- }
-
- @Override
- public short vxlanId() {
- return vxlanId;
- }
-
- @Override
- public IpPrefix srcIp() {
- return srcIp;
- }
-
- @Override
- public IpPrefix dstIp() {
- return dstIp;
- }
-
- @Override
- public TpPort srcPort() {
- return srcPort;
- }
-
- @Override
- public TpPort dstPort() {
- return dstPort;
- }
-
- @Override
- public byte protocol() {
- return protocol;
- }
-
- @Override
- public MacAddress srcMac() {
- return srcMac;
- }
-
- @Override
- public MacAddress dstMac() {
- return dstMac;
- }
-
- @Override
- public StatsInfo statsInfo() {
- return statsInfo;
- }
-
- @Override
- public boolean roughEquals(FlowInfo flowInfo) {
- final DefaultFlowInfo other = (DefaultFlowInfo) flowInfo;
- return Objects.equals(this.deviceId, other.deviceId) &&
- Objects.equals(this.srcIp, other.srcIp) &&
- Objects.equals(this.dstIp, other.dstIp) &&
- Objects.equals(this.srcPort, other.srcPort) &&
- Objects.equals(this.dstPort, other.dstPort) &&
- Objects.equals(this.protocol, other.protocol);
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
-
- if (obj instanceof DefaultFlowInfo) {
- final DefaultFlowInfo other = (DefaultFlowInfo) obj;
- return Objects.equals(this.flowType, other.flowType) &&
- Objects.equals(this.deviceId, other.deviceId) &&
- Objects.equals(this.inputInterfaceId, other.inputInterfaceId) &&
- Objects.equals(this.outputInterfaceId, other.outputInterfaceId) &&
- Objects.equals(this.vlanId, other.vlanId) &&
- Objects.equals(this.vxlanId, other.vxlanId) &&
- Objects.equals(this.srcIp, other.srcIp) &&
- Objects.equals(this.dstIp, other.dstIp) &&
- Objects.equals(this.srcPort, other.srcPort) &&
- Objects.equals(this.dstPort, other.dstPort) &&
- Objects.equals(this.protocol, other.protocol) &&
- Objects.equals(this.srcMac, other.srcMac) &&
- Objects.equals(this.dstMac, other.dstMac) &&
- Objects.equals(this.statsInfo, other.statsInfo);
- }
- return false;
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(flowType, deviceId, inputInterfaceId,
- outputInterfaceId, vlanId, vxlanId, srcIp, dstIp, srcPort, dstPort,
- protocol, srcMac, dstMac, statsInfo);
- }
-
- @Override
- public String uniqueFlowInfoKey() {
- if (srcIp.address().isZero() || dstIp.address().isZero()) {
- if (!srcIp.address().isZero()) {
- return INGRESS_STATS + srcIp.toString();
- }
- if (!dstIp.address().isZero()) {
- return EGRESS_STATS + dstIp.toString();
- }
- }
- return srcIp.toString() + ":" +
- ((srcPort == null) ? "any" : srcPort.toString()) +
- " -> " +
- dstIp.toString() + ":" +
- ((dstPort == null) ? "any" : dstPort.toString()) +
- " (" + getProtocolNameFromType(protocol) + ")";
- }
-
- @Override
- public String toString() {
- return toStringHelper(this)
- .add("flowType", flowType)
- .add("deviceId", deviceId)
- .add("inputInterfaceId", inputInterfaceId)
- .add("outputInterfaceId", outputInterfaceId)
- .add("vlanId", vlanId)
- .add("vxlanId", vxlanId)
- .add("srcIp", srcIp)
- .add("dstIp", dstIp)
- .add("srcPort", srcPort)
- .add("dstPort", dstPort)
- .add("protocol", protocol)
- .add("srcMac", srcMac)
- .add("dstMac", dstMac)
- .add("statsInfo", statsInfo)
- .toString();
- }
-
- /**
- * Obtains a default flow info builder object.
- *
- * @return flow info builder object
- */
- public static Builder builder() {
- return new DefaultBuilder();
- }
-
- /**
- * Builder class of DefaultFlowInfo.
- */
- public static final class DefaultBuilder implements FlowInfo.Builder {
-
- private byte flowType;
- private DeviceId deviceId;
- private int inputInterfaceId;
- private int outputInterfaceId;
- private VlanId vlanId;
- private short vxlanId;
- private IpPrefix srcIp;
- private IpPrefix dstIp;
- private TpPort srcPort;
- private TpPort dstPort;
- private byte protocol;
- private MacAddress srcMac;
- private MacAddress dstMac;
- private StatsInfo statsInfo;
-
- @Override
- public Builder withFlowType(byte flowType) {
- this.flowType = flowType;
- return this;
- }
-
- @Override
- public Builder withDeviceId(DeviceId deviceId) {
- this.deviceId = deviceId;
- return this;
- }
-
- @Override
- public Builder withInputInterfaceId(int inputInterfaceId) {
- this.inputInterfaceId = inputInterfaceId;
- return this;
- }
-
- @Override
- public Builder withOutputInterfaceId(int outputInterfaceId) {
- this.outputInterfaceId = outputInterfaceId;
- return this;
- }
-
- @Override
- public Builder withVlanId(VlanId vlanId) {
- this.vlanId = vlanId;
- return this;
- }
-
- @Override
- public Builder withVxlanId(short vxlanId) {
- this.vxlanId = vxlanId;
- return this;
- }
-
- @Override
- public Builder withSrcIp(IpPrefix srcIp) {
- this.srcIp = srcIp;
- return this;
- }
-
- @Override
- public Builder withDstIp(IpPrefix dstIp) {
- this.dstIp = dstIp;
- return this;
- }
-
- @Override
- public Builder withSrcPort(TpPort srcPort) {
- this.srcPort = srcPort;
- return this;
- }
-
- @Override
- public Builder withDstPort(TpPort dstPort) {
- this.dstPort = dstPort;
- return this;
- }
-
- @Override
- public Builder withProtocol(byte protocol) {
- this.protocol = protocol;
- return this;
- }
-
- @Override
- public Builder withSrcMac(MacAddress srcMac) {
- this.srcMac = srcMac;
- return this;
- }
-
- @Override
- public Builder withDstMac(MacAddress dstMac) {
- this.dstMac = dstMac;
- return this;
- }
-
- @Override
- public Builder withStatsInfo(StatsInfo statsInfo) {
- this.statsInfo = statsInfo;
- return this;
- }
-
- @Override
- public FlowInfo build() {
-
- // TODO: need to check the null value for more properties
- checkNotNull(srcIp, "Source IP address cannot be null");
- checkNotNull(dstIp, "Destination IP address cannot be null");
- checkNotNull(statsInfo, "StatsInfo cannot be null");
-
- return new DefaultFlowInfo(flowType, deviceId, inputInterfaceId,
- outputInterfaceId, vlanId, vxlanId, srcIp, dstIp, srcPort, dstPort,
- protocol, srcMac, dstMac, statsInfo);
- }
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsFlowRule.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsFlowRule.java
deleted file mode 100644
index 9ee84f8..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsFlowRule.java
+++ /dev/null
@@ -1,189 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.impl;
-
-import com.google.common.base.MoreObjects;
-import org.onlab.packet.IpPrefix;
-import org.onlab.packet.TpPort;
-import org.onosproject.openstacktelemetry.api.StatsFlowRule;
-
-import java.util.Objects;
-
-import static com.google.common.base.Preconditions.checkArgument;
-
-/**
- * Implementation of StatsFlowRule.
- */
-public final class DefaultStatsFlowRule implements StatsFlowRule {
- private final IpPrefix srcIpPrefix;
- private final IpPrefix dstIpPrefix;
- private final byte ipProtocol;
- private final TpPort srcTpPort;
- private final TpPort dstTpPort;
-
- private static final String NOT_NULL_MSG = "Element % cannot be null";
-
- protected DefaultStatsFlowRule(IpPrefix srcIpPrefix,
- IpPrefix dstIpPrefix,
- byte ipProtoco,
- TpPort srcTpPort,
- TpPort dstTpPort) {
- this.srcIpPrefix = srcIpPrefix;
- this.dstIpPrefix = dstIpPrefix;
- this.ipProtocol = ipProtoco;
- this.srcTpPort = srcTpPort;
- this.dstTpPort = dstTpPort;
- }
-
- @Override
- public IpPrefix srcIpPrefix() {
- return srcIpPrefix;
- }
-
- @Override
- public IpPrefix dstIpPrefix() {
- return dstIpPrefix;
- }
-
- @Override
- public byte ipProtocol() {
- return ipProtocol;
- }
-
- @Override
- public TpPort srcTpPort() {
- return srcTpPort;
- }
-
- @Override
- public TpPort dstTpPort() {
- return dstTpPort;
- }
-
- @Override
- public String toString() {
- return MoreObjects.toStringHelper(getClass())
- .add("srcIpPrefix", srcIpPrefix)
- .add("dstIpPrefix", dstIpPrefix)
- .add("ipProtocol", ipProtocol)
- .add("srcTpPort", srcTpPort)
- .add("dstTpPort", dstTpPort)
- .toString();
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
-
- if (obj instanceof DefaultStatsFlowRule) {
- final DefaultStatsFlowRule other = (DefaultStatsFlowRule) obj;
- return Objects.equals(this.srcIpPrefix, other.srcIpPrefix) &&
- Objects.equals(this.dstIpPrefix, other.dstIpPrefix) &&
- Objects.equals(this.srcTpPort, other.srcTpPort) &&
- Objects.equals(this.dstTpPort, other.dstTpPort) &&
- Objects.equals(this.ipProtocol, other.ipProtocol);
- }
- return false;
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(srcIpPrefix, dstIpPrefix, srcTpPort, dstTpPort, ipProtocol);
- }
-
- /**
- * Obtains a default stats flow rule builder object.
- *
- * @return flow rule builder object
- */
- public static Builder builder() {
- return new Builder();
- }
-
- /**
- * Obtains the builder object existing flow rule.
- *
- * @param flowRule flow rule
- * @return builder object
- */
- public static Builder from(StatsFlowRule flowRule) {
- return new Builder()
- .srcIpPrefix(flowRule.srcIpPrefix())
- .dstIpPrefix(flowRule.dstIpPrefix())
- .ipProtocol(flowRule.ipProtocol())
- .srcTpPort(flowRule.srcTpPort())
- .dstTpPort(flowRule.dstTpPort());
- }
-
- /**
- * A builder class for openstack flow rule.
- */
- public static final class Builder implements StatsFlowRule.Builder {
- private IpPrefix srcIpPrefix;
- private IpPrefix dstIpPrefix;
- private byte ipProtocol;
- private TpPort srcTpPort;
- private TpPort dstTpPort;
-
- // private constructor not intended to use from external
- private Builder() {
- }
-
- @Override
- public DefaultStatsFlowRule build() {
- checkArgument(srcIpPrefix != null, NOT_NULL_MSG, "Source IP Prefix");
- checkArgument(dstIpPrefix != null, NOT_NULL_MSG, "Destination IP Prefix");
-
- return new DefaultStatsFlowRule(srcIpPrefix,
- dstIpPrefix,
- ipProtocol,
- srcTpPort,
- dstTpPort);
- }
-
- @Override
- public Builder srcIpPrefix(IpPrefix srcIpPrefix) {
- this.srcIpPrefix = srcIpPrefix;
- return this;
- }
-
- @Override
- public Builder dstIpPrefix(IpPrefix dstIpPrefix) {
- this.dstIpPrefix = dstIpPrefix;
- return this;
- }
-
- @Override
- public Builder ipProtocol(byte ipProtocol) {
- this.ipProtocol = ipProtocol;
- return this;
- }
-
- @Override
- public Builder srcTpPort(TpPort srcTpPort) {
- this.srcTpPort = srcTpPort;
- return this;
- }
-
- @Override
- public Builder dstTpPort(TpPort dstTpPort) {
- this.dstTpPort = dstTpPort;
- return this;
- }
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsInfo.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsInfo.java
deleted file mode 100644
index 6e085a2..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultStatsInfo.java
+++ /dev/null
@@ -1,217 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.impl;
-
-import org.onosproject.openstacktelemetry.api.StatsInfo;
-
-import java.util.Objects;
-
-import static com.google.common.base.MoreObjects.toStringHelper;
-
-/**
- * Implementation class of StatsInfo.
- */
-public final class DefaultStatsInfo implements StatsInfo {
-
- private final long startupTime;
- private final long fstPktArrTime;
- private final int lstPktOffset;
- private final long prevAccBytes;
- private final int prevAccPkts;
- private final long currAccBytes;
- private final int currAccPkts;
- private final short errorPkts;
- private final short dropPkts;
-
- private DefaultStatsInfo(long startupTime, long fstPktArrTime, int lstPktOffset,
- long prevAccBytes, int prevAccPkts, long currAccBytes,
- int currAccPkts, short errorPkts, short dropPkts) {
- this.startupTime = startupTime;
- this.fstPktArrTime = fstPktArrTime;
- this.lstPktOffset = lstPktOffset;
- this.prevAccBytes = prevAccBytes;
- this.prevAccPkts = prevAccPkts;
- this.currAccBytes = currAccBytes;
- this.currAccPkts = currAccPkts;
- this.errorPkts = errorPkts;
- this.dropPkts = dropPkts;
- }
-
- @Override
- public long startupTime() {
- return startupTime;
- }
-
- @Override
- public long fstPktArrTime() {
- return fstPktArrTime;
- }
-
- @Override
- public int lstPktOffset() {
- return lstPktOffset;
- }
-
- @Override
- public long prevAccBytes() {
- return prevAccBytes;
- }
-
- @Override
- public int prevAccPkts() {
- return prevAccPkts;
- }
-
- @Override
- public long currAccBytes() {
- return currAccBytes;
- }
-
- @Override
- public int currAccPkts() {
- return currAccPkts;
- }
-
- @Override
- public short errorPkts() {
- return errorPkts;
- }
-
- @Override
- public short dropPkts() {
- return dropPkts;
- }
-
- @Override
- public boolean equals(Object obj) {
- if (this == obj) {
- return true;
- }
-
- if (obj instanceof DefaultStatsInfo) {
- final DefaultStatsInfo other = (DefaultStatsInfo) obj;
- return Objects.equals(this.startupTime, other.startupTime) &&
- Objects.equals(this.fstPktArrTime, other.fstPktArrTime) &&
- Objects.equals(this.lstPktOffset, other.lstPktOffset) &&
- Objects.equals(this.prevAccBytes, other.prevAccBytes) &&
- Objects.equals(this.prevAccPkts, other.prevAccPkts) &&
- Objects.equals(this.currAccBytes, other.currAccBytes) &&
- Objects.equals(this.currAccPkts, other.currAccPkts) &&
- Objects.equals(this.errorPkts, other.errorPkts) &&
- Objects.equals(this.dropPkts, other.dropPkts);
- }
- return false;
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(startupTime, fstPktArrTime, lstPktOffset,
- prevAccBytes, prevAccPkts, currAccBytes, currAccPkts,
- errorPkts, dropPkts);
- }
-
- @Override
- public String toString() {
- return toStringHelper(this)
- .add("startupTime", startupTime)
- .add("fstPktArrTime", fstPktArrTime)
- .add("lstPktOffset", lstPktOffset)
- .add("prevAccBytes", prevAccBytes)
- .add("prevAccPkts", prevAccPkts)
- .add("currAccBytes", currAccBytes)
- .add("currAccPkts", currAccPkts)
- .add("errorPkts", errorPkts)
- .add("dropPkts", dropPkts)
- .toString();
- }
-
- /**
- * Builder class of DefaultStatsInfo.
- */
- public static final class DefaultBuilder implements StatsInfo.Builder {
- private long startupTime;
- private long fstPktArrTime;
- private int lstPktOffset;
- private long prevAccBytes;
- private int prevAccPkts;
- private long currAccBytes;
- private int currAccPkts;
- private short errorPkts;
- private short dropPkts;
-
- @Override
- public Builder withStartupTime(long startupTime) {
- this.startupTime = startupTime;
- return this;
- }
-
- @Override
- public Builder withFstPktArrTime(long fstPktArrTime) {
- this.fstPktArrTime = fstPktArrTime;
- return this;
- }
-
- @Override
- public Builder withLstPktOffset(int lstPktOffset) {
- this.lstPktOffset = lstPktOffset;
- return this;
- }
-
- @Override
- public Builder withPrevAccBytes(long prevAccBytes) {
- this.prevAccBytes = prevAccBytes;
- return this;
- }
-
- @Override
- public Builder withPrevAccPkts(int prevAccPkts) {
- this.prevAccPkts = prevAccPkts;
- return this;
- }
-
- @Override
- public Builder withCurrAccBytes(long currAccBytes) {
- this.currAccBytes = currAccBytes;
- return this;
- }
-
- @Override
- public Builder withCurrAccPkts(int currAccPkts) {
- this.currAccPkts = currAccPkts;
- return this;
- }
-
- @Override
- public Builder withErrorPkts(short errorPkts) {
- this.errorPkts = errorPkts;
- return this;
- }
-
- @Override
- public Builder withDropPkts(short dropPkts) {
- this.dropPkts = dropPkts;
- return this;
- }
-
- @Override
- public StatsInfo build() {
-
- return new DefaultStatsInfo(startupTime, fstPktArrTime, lstPktOffset,
- prevAccBytes, prevAccPkts, currAccBytes, currAccPkts,
- errorPkts, dropPkts);
- }
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultTelemetryConfig.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultTelemetryConfig.java
deleted file mode 100644
index d130446..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DefaultTelemetryConfig.java
+++ /dev/null
@@ -1,216 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.impl;
-
-import com.google.common.collect.ImmutableList;
-import com.google.common.collect.ImmutableMap;
-import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
-
-import java.util.ArrayList;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.Queue;
-import java.util.Set;
-
-import static com.google.common.base.MoreObjects.toStringHelper;
-import static com.google.common.base.Preconditions.checkNotNull;
-import static com.google.common.collect.ImmutableMap.copyOf;
-
-/**
- * Implementation of TelemetryConfig.
- */
-public final class DefaultTelemetryConfig implements TelemetryConfig {
- private final String name;
- private final ConfigType type;
- private final List<TelemetryConfig> parents;
-
- private final String manufacturer;
- private final String swVersion;
- private final boolean enabled;
-
- private final Map<String, String> properties;
-
- /**
- * Creates a configuration with the specified name.
- *
- * @param name configuration name
- * @param type configuration type
- * @param parents optional parent configurations
- * @param manufacturer off-platform application manufacturer
- * @param swVersion off-platform application software version
- * @param enabled service enable flag
- * @param properties properties for telemetry configuration
- */
- public DefaultTelemetryConfig(String name, ConfigType type,
- List<TelemetryConfig> parents,
- String manufacturer, String swVersion,
- boolean enabled, Map<String, String> properties) {
- this.name = checkNotNull(name, "Name cannot be null");
- this.type = checkNotNull(type, "type cannot be null");
- this.parents = parents == null ? ImmutableList.of() : ImmutableList.copyOf(parents);
- this.manufacturer = checkNotNull(manufacturer, "Manufacturer cannot be null");
- this.swVersion = checkNotNull(swVersion, "SW version cannot be null");
- this.properties = copyOf(checkNotNull(properties, "Properties cannot be null"));
- this.enabled = enabled;
- }
-
- @Override
- public String name() {
- return name;
- }
-
- @Override
- public ConfigType type() {
- return type;
- }
-
- @Override
- public List<TelemetryConfig> parents() {
- if (parents == null) {
- return ImmutableList.of();
- } else {
- return ImmutableList.copyOf(parents);
- }
- }
-
- @Override
- public String manufacturer() {
- return manufacturer;
- }
-
- @Override
- public String swVersion() {
- return swVersion;
- }
-
- @Override
- public boolean enabled() {
- return enabled;
- }
-
- @Override
- public Map<String, String> properties() {
- if (properties == null) {
- return ImmutableMap.of();
- } else {
- return ImmutableMap.copyOf(properties);
- }
- }
-
- @Override
- public String getProperty(String name) {
- Queue<TelemetryConfig> queue = new LinkedList<>();
- queue.add(this);
- while (!queue.isEmpty()) {
- TelemetryConfig config = queue.remove();
- String property = config.properties().get(name);
- if (property != null) {
- return property;
- } else if (config.parents() != null) {
- queue.addAll(config.parents());
- }
- }
- return null;
- }
-
- @Override
- public TelemetryConfig merge(TelemetryConfig other) {
- // merge the properties
- ImmutableMap.Builder<String, String> properties = ImmutableMap.builder();
- properties.putAll(other.properties());
-
- // remove duplicated properties from this configuration and merge
- this.properties().entrySet().stream()
- .filter(e -> !other.properties().containsKey(e.getKey()))
- .forEach(properties::put);
-
- List<TelemetryConfig> completeParents = new ArrayList<>();
-
- if (parents != null) {
- parents.forEach(parent -> other.parents().forEach(otherParent -> {
- if (otherParent.name().equals(parent.name())) {
- completeParents.add(parent.merge(otherParent));
- } else if (!completeParents.contains(otherParent)) {
- completeParents.add(otherParent);
- } else if (!completeParents.contains(parent)) {
- completeParents.add(parent);
- }
- }));
- }
-
- return new DefaultTelemetryConfig(name, type,
- !completeParents.isEmpty() ? completeParents : other.parents(),
- manufacturer, swVersion, enabled, properties.build());
- }
-
- @Override
- public TelemetryConfig updateProperties(Map<String, String> properties) {
-
- return new DefaultTelemetryConfig(name, type, parents, manufacturer,
- swVersion, enabled, properties);
- }
-
- @Override
- public TelemetryConfig updateEnabled(boolean enabled) {
- return new DefaultTelemetryConfig(name, type, parents, manufacturer,
- swVersion, enabled, properties);
- }
-
- @Override
- public Set<String> keys() {
- return properties.keySet();
- }
-
- @Override
- public String value(String key) {
- return properties.get(key);
- }
-
- @Override
- public String toString() {
- return toStringHelper(this)
- .add("name", name)
- .add("type", type)
- .add("parents", parents)
- .add("manufacturer", manufacturer)
- .add("swVersion", swVersion)
- .add("enabled", enabled)
- .add("properties", properties)
- .toString();
- }
-
- @Override
- public boolean equals(Object configToBeCompared) {
- if (this == configToBeCompared) {
- return true;
- }
-
- if (configToBeCompared == null || getClass() != configToBeCompared.getClass()) {
- return false;
- }
-
- DefaultTelemetryConfig telemetryConfig =
- (DefaultTelemetryConfig) configToBeCompared;
- return name.equals(telemetryConfig.name());
- }
-
- @Override
- public int hashCode() {
- return Objects.hashCode(name);
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DistributedTelemetryConfigStore.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DistributedTelemetryConfigStore.java
index 8fc31a6..d066d85 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DistributedTelemetryConfigStore.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/DistributedTelemetryConfigStore.java
@@ -19,6 +19,7 @@
import org.onlab.util.KryoNamespace;
import org.onosproject.core.ApplicationId;
import org.onosproject.core.CoreService;
+import org.onosproject.openstacktelemetry.api.DefaultTelemetryConfig;
import org.onosproject.openstacktelemetry.api.TelemetryConfigEvent;
import org.onosproject.openstacktelemetry.api.TelemetryConfigProvider;
import org.onosproject.openstacktelemetry.api.TelemetryConfigStore;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
index 962779a..38dd2b8 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/InfluxDbTelemetryManager.java
@@ -201,7 +201,7 @@
InfluxDB producer = InfluxDBFactory.connect(influxDbServerBuilder.toString(),
influxDbConfig.username(), influxDbConfig.password());
- producers.put(config.name(), producer);
+ producers.put(name, producer);
createDB(producer, influxDbConfig.database());
}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/KafkaTelemetryManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/KafkaTelemetryManager.java
index 152bfde..06936ca 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/KafkaTelemetryManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/KafkaTelemetryManager.java
@@ -54,8 +54,6 @@
private final Logger log = LoggerFactory.getLogger(getClass());
- private static final String CODEC_PREFIX = "org.onosproject.openstacktelemetry.codec.";
-
private static final String BOOTSTRAP_SERVERS = "bootstrap.servers";
private static final String RETRIES = "retries";
private static final String ACKS = "acks";
@@ -102,11 +100,10 @@
Set<Future<RecordMetadata>> futureSet = Sets.newHashSet();
producers.forEach((k, v) -> {
TelemetryConfig config = telemetryConfigService.getConfig(k);
- KafkaTelemetryConfig kafkaConfig =
- fromTelemetryConfig(config);
+ KafkaTelemetryConfig kafkaConfig = fromTelemetryConfig(config);
try {
- Class codecClazz = Class.forName(CODEC_PREFIX + kafkaConfig.codec());
+ Class codecClazz = Class.forName(kafkaConfig.codec());
TelemetryCodec codec = (TelemetryCodec) codecClazz.newInstance();
ByteBuffer buffer = codec.encode(flowInfos);
@@ -148,7 +145,7 @@
prop.put(KEY_SERIALIZER, kafkaConfig.keySerializer());
prop.put(VALUE_SERIALIZER, kafkaConfig.valueSerializer());
- producers.put(config.name(), new KafkaProducer<>(prop));
+ producers.put(name, new KafkaProducer<>(prop));
}
}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/StatsFlowRuleManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/StatsFlowRuleManager.java
index 3d9f577..30faac7 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/StatsFlowRuleManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/StatsFlowRuleManager.java
@@ -57,6 +57,9 @@
import org.onosproject.openstacknetworking.api.OpenstackNetworkService;
import org.onosproject.openstacknode.api.OpenstackNode;
import org.onosproject.openstacknode.api.OpenstackNodeService;
+import org.onosproject.openstacktelemetry.api.DefaultFlowInfo;
+import org.onosproject.openstacktelemetry.api.DefaultStatsFlowRule;
+import org.onosproject.openstacktelemetry.api.DefaultStatsInfo;
import org.onosproject.openstacktelemetry.api.FlowInfo;
import org.onosproject.openstacktelemetry.api.OpenstackTelemetryService;
import org.onosproject.openstacktelemetry.api.StatsFlowRule;
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/TelemetryConfigManager.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/TelemetryConfigManager.java
index 3ae2504..9832ad3 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/TelemetryConfigManager.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/TelemetryConfigManager.java
@@ -23,6 +23,7 @@
import org.onosproject.core.ApplicationId;
import org.onosproject.core.CoreService;
import org.onosproject.event.ListenerRegistry;
+import org.onosproject.openstacktelemetry.api.DefaultTelemetryConfig;
import org.onosproject.openstacktelemetry.api.TelemetryConfigAdminService;
import org.onosproject.openstacktelemetry.api.TelemetryConfigEvent;
import org.onosproject.openstacktelemetry.api.TelemetryConfigListener;
@@ -74,6 +75,7 @@
private static final String ERR_NULL_CONFIG = "Telemetry config cannot be null";
private static final String NO_CONFIG = "Telemetry config not found";
+ private static final String ERR_NULL_CONFIG_NAME = "Telemetry config name cannot be null";
private static final KryoNamespace SERIALIZER_TELEMETRY_CONFIG =
KryoNamespace.newBuilder()
@@ -175,6 +177,14 @@
}
@Override
+ public void removeTelemetryConfig(String name) {
+ checkNotNull(name, ERR_NULL_CONFIG_NAME);
+
+ telemetryConfigStore.removeTelemetryConfig(name);
+ log.info(String.format(MSG_TELEMETRY_CONFIG, name, MSG_REMOVED));
+ }
+
+ @Override
public TelemetryConfig getConfig(String name) {
return nullIsNotFound(telemetryConfigStore.telemetryConfig(name), NO_CONFIG);
}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/XmlTelemetryConfigLoader.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/XmlTelemetryConfigLoader.java
index 39a5df0..c9c6e9f 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/XmlTelemetryConfigLoader.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/impl/XmlTelemetryConfigLoader.java
@@ -21,6 +21,7 @@
import org.apache.commons.configuration.ConfigurationException;
import org.apache.commons.configuration.HierarchicalConfiguration;
import org.apache.commons.configuration.XMLConfiguration;
+import org.onosproject.openstacktelemetry.api.DefaultTelemetryConfig;
import org.onosproject.openstacktelemetry.api.config.TelemetryConfig;
import java.io.IOException;
@@ -45,8 +46,8 @@
* </p>
* <pre>
* <configs>
- * <config name=“...” [manufacturer="..." swVersion="..."]>
- * [<property name=“key”>value</key>]
+ * <config name="..." [manufacturer="..." swVersion="..."]>
+ * [<property name="key">value</key>]
* ...
* </config>
* ...
@@ -203,10 +204,16 @@
ImmutableMap.Builder<String, String> properties = ImmutableMap.builder();
// note that, we only allow the inheritance from single source
- Map<String, String> parentConfigs = Maps.newHashMap();
+ final Map<String, String> parentConfigs = Maps.newHashMap();
if (!parents.isEmpty()) {
TelemetryConfig parent = parents.get(0);
- parentConfigs = parent.properties();
+ parent.properties().forEach(parentConfigs::put);
+ }
+
+ for (HierarchicalConfiguration b : config.configurationsAt(PROPERTY)) {
+ if (parentConfigs.keySet().contains(b.getString(NAME))) {
+ parentConfigs.remove(b.getString(NAME));
+ }
}
properties.putAll(parentConfigs);
@@ -214,6 +221,7 @@
for (HierarchicalConfiguration b : config.configurationsAt(PROPERTY)) {
properties.put(b.getString(NAME), (String) b.getRootNode().getValue());
}
+
return properties.build();
}
}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryCodecRegister.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryCodecRegister.java
deleted file mode 100644
index c8bfeb5..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryCodecRegister.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.web;
-
-import org.osgi.service.component.annotations.Activate;
-import org.osgi.service.component.annotations.Component;
-import org.osgi.service.component.annotations.Deactivate;
-import org.osgi.service.component.annotations.Reference;
-import org.osgi.service.component.annotations.ReferenceCardinality;
-import org.onosproject.codec.CodecService;
-import org.onosproject.openstacktelemetry.api.FlowInfo;
-import org.onosproject.openstacktelemetry.api.StatsFlowRule;
-import org.onosproject.openstacktelemetry.api.StatsInfo;
-import org.onosproject.openstacktelemetry.codec.FlowInfoJsonCodec;
-import org.onosproject.openstacktelemetry.codec.StatsFlowRuleJsonCodec;
-import org.onosproject.openstacktelemetry.codec.StatsInfoJsonCodec;
-
-import static org.slf4j.LoggerFactory.getLogger;
-
-/**
- * Implementation of the JSON codec brokering service for OpenstackTelemetry.
- */
-@Component(immediate = true)
-public class OpenstackTelemetryCodecRegister {
-
- private final org.slf4j.Logger log = getLogger(getClass());
-
- @Reference(cardinality = ReferenceCardinality.MANDATORY)
- protected CodecService codecService;
-
- @Activate
- protected void activate() {
- codecService.registerCodec(StatsInfo.class, new StatsInfoJsonCodec());
- codecService.registerCodec(FlowInfo.class, new FlowInfoJsonCodec());
- codecService.registerCodec(StatsFlowRule.class, new StatsFlowRuleJsonCodec());
-
- log.info("Started");
- }
-
- @Deactivate
- protected void deactivate() {
- codecService.unregisterCodec(StatsInfo.class);
- codecService.unregisterCodec(FlowInfo.class);
- codecService.unregisterCodec(StatsFlowRule.class);
-
- log.info("Stopped");
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebApplication.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebApplication.java
deleted file mode 100644
index 9dc4e18..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebApplication.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.web;
-
-import org.onlab.rest.AbstractWebApplication;
-
-import java.util.Set;
-
-/**
- * Openstack telemetry REST APIs web application.
- */
-public class OpenstackTelemetryWebApplication extends AbstractWebApplication {
- @Override
- public Set<Class<?>> getClasses() {
- return getClasses(OpenstackTelemetryWebResource.class);
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebResource.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebResource.java
deleted file mode 100644
index 34f8366..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/OpenstackTelemetryWebResource.java
+++ /dev/null
@@ -1,191 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-package org.onosproject.openstacktelemetry.web;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.node.ArrayNode;
-import com.fasterxml.jackson.databind.node.ObjectNode;
-import com.google.common.collect.Sets;
-import org.apache.commons.lang3.exception.ExceptionUtils;
-import org.onosproject.codec.JsonCodec;
-import org.onosproject.openstacktelemetry.api.FlowInfo;
-import org.onosproject.openstacktelemetry.api.StatsFlowRule;
-import org.onosproject.openstacktelemetry.api.StatsFlowRuleAdminService;
-import org.onosproject.openstacktelemetry.codec.FlowInfoJsonCodec;
-import org.onosproject.rest.AbstractWebResource;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import javax.ws.rs.Consumes;
-import javax.ws.rs.DELETE;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-import javax.ws.rs.core.Context;
-import javax.ws.rs.core.MediaType;
-import javax.ws.rs.core.Response;
-import javax.ws.rs.core.UriBuilder;
-import javax.ws.rs.core.UriInfo;
-import java.io.InputStream;
-import java.util.Set;
-
-import static com.fasterxml.jackson.databind.SerializationFeature.INDENT_OUTPUT;
-import static javax.ws.rs.core.Response.created;
-import static org.onlab.util.Tools.readTreeFromStream;
-
-/**
- * Handles REST API call of openstack telemetry.
- */
-
-@Path("telemetry")
-public class OpenstackTelemetryWebResource extends AbstractWebResource {
-
- private final Logger log = LoggerFactory.getLogger(getClass());
-
- private final ObjectNode root = mapper().createObjectNode();
-
- private static final String JSON_NODE_FLOW_RULE = "rules";
- private static final String FLOW_RULE_ID = "STATS_FLOW_RULE_ID";
-
- private final StatsFlowRuleAdminService
- statsFlowRuleService = get(StatsFlowRuleAdminService.class);
-
- @Context
- private UriInfo uriInfo;
-
- /**
- * Creates a flow rule for metric.
- *
- * @param input openstack flow rule JSON input stream
- * @return 201 CREATED if the JSON is correct,
- * 400 BAD_REQUEST if the JSON is malformed.
- */
- @POST
- @Consumes(MediaType.APPLICATION_JSON)
- @Produces(MediaType.APPLICATION_JSON)
- public Response createBulkFlowRule(InputStream input) {
- log.info("CREATE BULK FLOW RULE: {}", input.toString());
-
- readNodeConfiguration(input).forEach(flowRule -> {
- log.debug("FlowRule: {}", flowRule.toString());
- statsFlowRuleService.createStatFlowRule(flowRule);
- });
-
- UriBuilder locationBuilder = uriInfo.getBaseUriBuilder()
- .path(JSON_NODE_FLOW_RULE)
- .path(FLOW_RULE_ID);
-
- return created(locationBuilder.build()).build();
- }
-
- /**
- * Delete flow rules.
- *
- * @param input openstack flow rule JSON input stream
- * @return 200 OK if processing is correct.
- */
- @DELETE
- @Consumes(MediaType.APPLICATION_JSON)
- @Produces(MediaType.APPLICATION_JSON)
- public Response deleteBulkFlowRule(InputStream input) {
- log.info("DELETE BULK FLOW RULE: {}", input.toString());
-
- readNodeConfiguration(input).forEach(flowRule -> {
- log.debug("FlowRule: {}", flowRule.toString());
- statsFlowRuleService.deleteStatFlowRule(flowRule);
- });
-
- return ok(root).build();
- }
-
- /**
- * Get flow rules which is installed on ONOS.
- *
- * @return 200 OK
- */
- public Response readBulkFlowRule() {
- log.info("READ BULK FLOW RULE");
-
- return ok(root).build();
- }
-
- /**
- * Get flow information list.
- *
- * @return Flow information list
- */
- @GET
- @Path("list")
- @Produces(MediaType.APPLICATION_JSON)
- public Response getFlowInfoBulk() {
- log.info("GET BULK FLOW RULE");
-
- Set<FlowInfo> flowInfoSet;
- flowInfoSet = statsFlowRuleService.getOverlayFlowInfos();
-
- log.info("\n\n======================================================\n" +
- "FlowInfo Set: \n{}" +
- "\n\n======================================================\n",
- flowInfoSet);
-
- JsonCodec<FlowInfo> flowInfoCodec = new FlowInfoJsonCodec();
-
- ObjectNode nodeJson;
- int idx = 0;
- for (FlowInfo flowInfo: flowInfoSet) {
- nodeJson = flowInfoCodec.encode(flowInfo, this);
- root.put("FlowInfo" + String.valueOf(idx++), nodeJson.toString());
- }
- return ok(root).build();
- }
-
- @GET
- @Path("list/{srcIpPrefix}/{dstIpPrefix}")
- @Produces(MediaType.APPLICATION_JSON)
- public Response getFlowRule(@PathParam("srcIpPrefix") String srcIpPrefix,
- @PathParam("dstIpPrefix") String dstIpPrefix) {
- return ok(root).build();
- }
-
- private Set<StatsFlowRule> readNodeConfiguration(InputStream input) {
- log.info("Input JSON Data: \n\t\t{}", input.toString());
- Set<StatsFlowRule> flowRuleSet = Sets.newHashSet();
- try {
- JsonNode jsonTree = readTreeFromStream(mapper().enable(INDENT_OUTPUT), input);
- ArrayNode nodes = (ArrayNode) jsonTree.path(JSON_NODE_FLOW_RULE);
- nodes.forEach(node -> {
- try {
- ObjectNode objectNode = node.deepCopy();
- log.debug("ObjectNode: {}", objectNode.toString());
- StatsFlowRule statsFlowRule = codec(StatsFlowRule.class)
- .decode(objectNode, this);
- log.debug("StatsFlowRule: {}", statsFlowRule.toString());
- flowRuleSet.add(statsFlowRule);
- } catch (Exception ex) {
- log.error("Exception Stack:\n{}", ExceptionUtils.getStackTrace(ex));
- throw new IllegalArgumentException();
- }
- });
- } catch (Exception ex) {
- log.error("Exception Stack:\n{}", ExceptionUtils.getStackTrace(ex));
- throw new IllegalArgumentException(ex);
- }
-
- return flowRuleSet;
- }
-}
diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/package-info.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/package-info.java
deleted file mode 100644
index 24c5ed66..0000000
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/web/package-info.java
+++ /dev/null
@@ -1,20 +0,0 @@
-/*
- * Copyright 2018-present Open Networking Foundation
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License 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.
- */
-
-/**
- * Web GUI and REST API of openstack telemetry.
- */
-package org.onosproject.openstacktelemetry.web;
\ No newline at end of file
diff --git a/apps/openstacktelemetry/app/src/main/resources/definitions/dummy.json b/apps/openstacktelemetry/app/src/main/resources/definitions/dummy.json
deleted file mode 100644
index 7a73a41..0000000
--- a/apps/openstacktelemetry/app/src/main/resources/definitions/dummy.json
+++ /dev/null
@@ -1,2 +0,0 @@
-{
-}
\ No newline at end of file
diff --git a/apps/openstacktelemetry/app/src/main/resources/org/onosproject/openstacktelemetry/impl/kafka-configs.xml b/apps/openstacktelemetry/app/src/main/resources/org/onosproject/openstacktelemetry/impl/kafka-configs.xml
index 7429ac2..48623b6 100644
--- a/apps/openstacktelemetry/app/src/main/resources/org/onosproject/openstacktelemetry/impl/kafka-configs.xml
+++ b/apps/openstacktelemetry/app/src/main/resources/org/onosproject/openstacktelemetry/impl/kafka-configs.xml
@@ -34,6 +34,8 @@
</property>
<property name="topic">sona.flow</property>
<property name="key">flowdata</property>
- <property name="codec">TinaMessageByteBufferCodec</property>
+ <property name="codec">
+ org.onosproject.openstacktelemetry.codec.bytebuffer.TinaMessageByteBufferCodec
+ </property>
</config>
</configs>
\ No newline at end of file
diff --git a/apps/openstacktelemetry/app/src/main/webapp/WEB-INF/web.xml b/apps/openstacktelemetry/app/src/main/webapp/WEB-INF/web.xml
deleted file mode 100644
index 1181c43..0000000
--- a/apps/openstacktelemetry/app/src/main/webapp/WEB-INF/web.xml
+++ /dev/null
@@ -1,58 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ~ Copyright 2018-present Open Networking Foundation
- ~
- ~ Licensed under the Apache License, Version 2.0 (the "License");
- ~ you may not use this file except in compliance with the License.
- ~ You may obtain a copy of the License at
- ~
- ~ http://www.apache.org/licenses/LICENSE-2.0
- ~
- ~ Unless required by applicable law or agreed to in writing, software
- ~ distributed under the License 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.
- -->
-<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"
- xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
- xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
- id="ONOS" version="2.5">
- <display-name>Openstack Telemetry REST API v1.0</display-name>
-
- <security-constraint>
- <web-resource-collection>
- <web-resource-name>Secured</web-resource-name>
- <url-pattern>/*</url-pattern>
- </web-resource-collection>
- <auth-constraint>
- <role-name>admin</role-name>
- <role-name>viewer</role-name>
- </auth-constraint>
- </security-constraint>
-
- <security-role>
- <role-name>admin</role-name>
- <role-name>viewer</role-name>
- </security-role>
-
- <login-config>
- <auth-method>BASIC</auth-method>
- <realm-name>karaf</realm-name>
- </login-config>
-
- <servlet>
- <servlet-name>JAX-RS Service</servlet-name>
- <servlet-class>org.glassfish.jersey.servlet.ServletContainer</servlet-class>
- <init-param>
- <param-name>javax.ws.rs.Application</param-name>
- <param-value>org.onosproject.openstacktelemetry.web.OpenstackTelemetryWebApplication</param-value>
- </init-param>
- <load-on-startup>1</load-on-startup>
- </servlet>
-
- <servlet-mapping>
- <servlet-name>JAX-RS Service</servlet-name>
- <url-pattern>/*</url-pattern>
- </servlet-mapping>
-</web-app>