Deprecate and clean up some classes on control metric aggregation

Since the metric aggregation logic has been moved to message
provider, now there is no caller which refers to those classes.
Due to this reason, following classes need to be purged to
maintain clean code repository.

Change-Id: Id5bcb7eda6ce3538c18007301da35df9255159ae

-/*
- * Copyright 2016-present Open Networking Laboratory
- *
- * 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.cpman.impl;
-
-import com.google.common.collect.ImmutableMap;
-import com.google.common.collect.ImmutableSet;
-import com.google.common.collect.Sets;
-import org.onlab.metrics.MetricsService;
-import org.onosproject.cpman.ControlMetricType;
-import org.onosproject.net.DeviceId;
-import org.onosproject.net.device.DeviceService;
-
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-import java.util.concurrent.ConcurrentHashMap;
-
-/**
- * Singleton class to provide various control plane metrics to other components.
- */
-public final class ControlMetricsFactory {
-    private MetricsService metricsService;
-    private boolean enableMonitor = false;
-    private Boolean isInitialized = false;
-
-    // define a set of MetricsAggregators
-    private MetricsAggregator cpuLoad;
-    private MetricsAggregator totalCpuTime;
-    private MetricsAggregator sysCpuTime;
-    private MetricsAggregator userCpuTime;
-    private MetricsAggregator cpuIdleTime;
-    private MetricsAggregator memoryUsed;
-    private MetricsAggregator memoryFree;
-    private MetricsAggregator memoryUsedRatio;
-    private MetricsAggregator memoryFreeRatio;
-    private Map<String, MetricsAggregator> diskReadBytes;
-    private Map<String, MetricsAggregator> diskWriteBytes;
-    private Map<String, MetricsAggregator> nwIncomingBytes;
-    private Map<String, MetricsAggregator> nwOutgoingBytes;
-    private Map<String, MetricsAggregator> nwIncomingPackets;
-    private Map<String, MetricsAggregator> nwOutgoingPackets;
-
-    private Map<DeviceId, MetricsAggregator> inboundPacket;
-    private Map<DeviceId, MetricsAggregator> outboundPacket;
-    private Map<DeviceId, MetricsAggregator> flowmodPacket;
-    private Map<DeviceId, MetricsAggregator> flowrmvPacket;
-    private Map<DeviceId, MetricsAggregator> requestPacket;
-    private Map<DeviceId, MetricsAggregator> replyPacket;
-    private Set<DeviceId> deviceIds = Sets.newConcurrentHashSet();
-    private Set<String> diskPartitions = Sets.newConcurrentHashSet();
-    private Set<String> nwInterfaces = Sets.newConcurrentHashSet();
-
-    /**
-     * Initializes the control metrics factory instance using the given
-     * metric service and device service. Makes sure that we only initialize
-     * control metrics factory instance once.
-     *
-     * @param metricsService metric service
-     * @param deviceService  device service
-     */
-    public void initialization(MetricsService metricsService, DeviceService deviceService) {
-        synchronized (isInitialized) {
-            if (!isInitialized) {
-                this.metricsService = metricsService;
-                registerMetrics();
-                deviceService.getDevices().forEach(d->deviceIds.add(d.id()));
-                addAllControlMessageMetrics(deviceIds);
-                isInitialized = true;
-            }
-        }
-    }
-
-    /**
-     * Adds control metrics of a new device.
-     *
-     * @param deviceId device identifier
-     */
-    public void addControlMessageMetricsByDeviceId(DeviceId deviceId) {
-        MetricsAggregator inbound = new MetricsAggregator(metricsService,
-                ControlMetricType.INBOUND_PACKET, Optional.of(deviceId));
-        MetricsAggregator outbound = new MetricsAggregator(metricsService,
-                ControlMetricType.OUTBOUND_PACKET, Optional.of(deviceId));
-        MetricsAggregator flowmod = new MetricsAggregator(metricsService,
-                ControlMetricType.FLOW_MOD_PACKET, Optional.of(deviceId));
-        MetricsAggregator flowrmv = new MetricsAggregator(metricsService,
-                ControlMetricType.FLOW_REMOVED_PACKET, Optional.of(deviceId));
-        MetricsAggregator request = new MetricsAggregator(metricsService,
-                ControlMetricType.REQUEST_PACKET, Optional.of(deviceId));
-        MetricsAggregator reply = new MetricsAggregator(metricsService,
-                ControlMetricType.REPLY_PACKET, Optional.of(deviceId));
-
-        inboundPacket.putIfAbsent(deviceId, inbound);
-        outboundPacket.putIfAbsent(deviceId, outbound);
-        flowmodPacket.putIfAbsent(deviceId, flowmod);
-        flowrmvPacket.putIfAbsent(deviceId, flowrmv);
-        requestPacket.putIfAbsent(deviceId, request);
-        replyPacket.putIfAbsent(deviceId, reply);
-
-        deviceIds.add(deviceId);
-    }
-
-    /**
-     * Adds control metrics of a disk.
-     *
-     * @param partitionName disk partition name
-     */
-    public void addDiskMetricsByPartition(String partitionName) {
-        MetricsAggregator readBytes = new MetricsAggregator(metricsService,
-                ControlMetricType.DISK_READ_BYTES, partitionName);
-        MetricsAggregator writeBytes = new MetricsAggregator(metricsService,
-                ControlMetricType.DISK_WRITE_BYTES, partitionName);
-
-        diskReadBytes.putIfAbsent(partitionName, readBytes);
-        diskWriteBytes.putIfAbsent(partitionName, writeBytes);
-
-        diskPartitions.add(partitionName);
-    }
-
-    /**
-     * Adds control metrics of a ethernet interface.
-     *
-     * @param interfaceName network interface name
-     */
-    public void addNetworkMetricsByInterface(String interfaceName) {
-        MetricsAggregator incomingBytes = new MetricsAggregator(metricsService,
-                ControlMetricType.NW_INCOMING_BYTES, interfaceName);
-        MetricsAggregator outgoingBytes = new MetricsAggregator(metricsService,
-                ControlMetricType.NW_OUTGOING_BYTES, interfaceName);
-        MetricsAggregator incomingPackets = new MetricsAggregator(metricsService,
-                ControlMetricType.NW_INCOMING_PACKETS, interfaceName);
-        MetricsAggregator outgoingPackets = new MetricsAggregator(metricsService,
-                ControlMetricType.NW_OUTGOING_PACKETS, interfaceName);
-
-        nwIncomingBytes.putIfAbsent(interfaceName, incomingBytes);
-        nwOutgoingBytes.putIfAbsent(interfaceName, outgoingBytes);
-        nwIncomingPackets.putIfAbsent(interfaceName, incomingPackets);
-        nwOutgoingPackets.putIfAbsent(interfaceName, outgoingPackets);
-
-        nwInterfaces.add(interfaceName);
-    }
-
-    /**
-     * Removes control metrics of an existing device.
-     *
-     * @param deviceId device identifier
-     */
-    public void removeControlMessageMetricsByDeviceId(DeviceId deviceId) {
-        inboundPacket.remove(deviceId);
-        outboundPacket.remove(deviceId);
-        flowmodPacket.remove(deviceId);
-        flowrmvPacket.remove(deviceId);
-        requestPacket.remove(deviceId);
-        replyPacket.remove(deviceId);
-
-        deviceIds.remove(deviceId);
-    }
-
-    /**
-     * Removes control metrics of a disk.
-     *
-     * @param partitionName disk partition name
-     */
-    public void removeDiskMetricsByResourceName(String partitionName) {
-        diskReadBytes.remove(partitionName);
-        diskWriteBytes.remove(partitionName);
-
-        diskPartitions.remove(partitionName);
-    }
-
-    /**
-     * Removes control metrics of a network interface.
-     *
-     * @param interfaceName network interface name
-     */
-    public void removeNetworkInterfacesByResourceName(String interfaceName) {
-        nwIncomingBytes.remove(interfaceName);
-        nwOutgoingBytes.remove(interfaceName);
-        nwIncomingPackets.remove(interfaceName);
-        nwOutgoingPackets.remove(interfaceName);
-
-        nwInterfaces.remove(interfaceName);
-    }
-
-    /**
-     * Returns all device identifiers.
-     *
-     * @return a collection of device identifiers
-     */
-    public Set<DeviceId> getDeviceIds() {
-        return ImmutableSet.copyOf(this.deviceIds);
-    }
-
-    /**
-     * Returns all disk partition names.
-     *
-     * @return a collection of disk partitions.
-     */
-    public Set<String> getDiskPartitions() {
-        return ImmutableSet.copyOf(this.diskPartitions);
-    }
-
-    /**
-     * Returns all network interface names.
-     *
-     * @return a collection of network interfaces.
-     */
-    public Set<String> getNetworkInterfaces() {
-        return ImmutableSet.copyOf(this.nwInterfaces);
-    }
-
-    /**
-     * Adds control metrics for all devices.
-     *
-     * @param deviceIds a set of device identifiers
-     */
-    public void addAllControlMessageMetrics(Set<DeviceId> deviceIds) {
-        deviceIds.forEach(v -> addControlMessageMetricsByDeviceId(v));
-    }
-
-    /**
-     * Returns monitoring status.
-     *
-     * @return monitoring status
-     */
-    public boolean isMonitor() {
-        return this.enableMonitor;
-    }
-
-    /**
-     * Enable control plane monitoring.
-     */
-    protected void startMonitor() {
-        this.enableMonitor = true;
-    }
-
-    /**
-     * Disable control plane monitoring.
-     */
-    protected void stopMonitor() {
-        this.enableMonitor = false;
-    }
-
-    /**
-     * Registers new control metrics.
-     */
-    protected void registerMetrics() {
-        /* CPU */
-        cpuLoad = new MetricsAggregator(metricsService, ControlMetricType.CPU_LOAD);
-        totalCpuTime = new MetricsAggregator(metricsService, ControlMetricType.TOTAL_CPU_TIME);
-        sysCpuTime = new MetricsAggregator(metricsService, ControlMetricType.SYS_CPU_TIME);
-        userCpuTime = new MetricsAggregator(metricsService, ControlMetricType.USER_CPU_TIME);
-        cpuIdleTime = new MetricsAggregator(metricsService, ControlMetricType.CPU_IDLE_TIME);
-
-        /* Memory */
-        memoryFree = new MetricsAggregator(metricsService, ControlMetricType.MEMORY_FREE);
-        memoryUsed = new MetricsAggregator(metricsService, ControlMetricType.MEMORY_USED);
-        memoryFreeRatio = new MetricsAggregator(metricsService,
-                                        ControlMetricType.MEMORY_FREE_RATIO);
-        memoryUsedRatio = new MetricsAggregator(metricsService,
-                                        ControlMetricType.MEMORY_USED_RATIO);
-
-        /* Disk I/O */
-        diskReadBytes = new ConcurrentHashMap<>();
-        diskWriteBytes = new ConcurrentHashMap<>();
-
-        /* Network I/O */
-        nwIncomingBytes = new ConcurrentHashMap<>();
-        nwOutgoingBytes = new ConcurrentHashMap<>();
-        nwIncomingPackets = new ConcurrentHashMap<>();
-        nwOutgoingPackets = new ConcurrentHashMap<>();
-
-        /* OpenFlow Messages */
-        inboundPacket = new ConcurrentHashMap<>();
-        outboundPacket = new ConcurrentHashMap<>();
-        flowmodPacket = new ConcurrentHashMap<>();
-        flowrmvPacket = new ConcurrentHashMap<>();
-        requestPacket = new ConcurrentHashMap<>();
-        replyPacket = new ConcurrentHashMap<>();
-    }
-
-    /**
-     * Unregisters all control metrics.
-     */
-    protected void unregisterMetrics() {
-        /* Disk I/O */
-        diskReadBytes.clear();
-        diskWriteBytes.clear();
-
-        /* Network I/O */
-        nwIncomingBytes.clear();
-        nwOutgoingBytes.clear();
-        nwIncomingPackets.clear();
-        nwOutgoingPackets.clear();
-
-        /* OpenFlow Message */
-        inboundPacket.clear();
-        outboundPacket.clear();
-        flowmodPacket.clear();
-        flowrmvPacket.clear();
-        requestPacket.clear();
-        replyPacket.clear();
-    }
-
-    /**
-     * Returns CPU load metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator cpuLoadMetric() {
-        return cpuLoad;
-    }
-
-    /**
-     * Returns total CPU time metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator totalCpuTimeMetric() {
-        return totalCpuTime;
-    }
-
-    /**
-     * Returns system CPU time metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator sysCpuTimeMetric() {
-        return sysCpuTime;
-    }
-
-    /**
-     * Returns user CPU time metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator userCpuTime() {
-        return userCpuTime;
-    }
-
-    /**
-     * Returns CPU idle time metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator cpuIdleTime() {
-        return cpuIdleTime;
-    }
-
-    /**
-     * Returns free memory ratio metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator memoryFreeRatio() {
-        return memoryFreeRatio;
-    }
-
-    /**
-     * Returns used memory ratio metric aggregator.
-     *
-     * @return metric aggregator
-     */
-    public MetricsAggregator memoryUsedRatio() {
-        return memoryUsedRatio;
-    }
-
-    /**
-     * Returns disk read bytes metric aggregator.
-     *
-     * @param resourceName name of disk resource
-     * @return metric aggregator
-     */
-    public MetricsAggregator diskReadBytes(String resourceName) {
-        return diskReadBytes.get(resourceName);
-    }
-
-    /**
-     * Returns disk write bytes metric aggregator.
-     *
-     * @param resourceName name of disk resource
-     * @return metric aggregator
-     */
-    public MetricsAggregator diskWriteBytes(String resourceName) {
-        return diskWriteBytes.get(resourceName);
-    }
-
-    /**
-     * Returns incoming bytes metric aggregator.
-     *
-     * @param interfaceName name of network interface
-     * @return metric aggregator
-     */
-    public MetricsAggregator nwIncomingBytes(String interfaceName) {
-        return nwIncomingBytes.get(interfaceName);
-    }
-
-    /**
-     * Returns outgoing bytes metric aggregator.
-     *
-     * @param interfaceName name of network interface
-     * @return metric aggregator
-     */
-    public MetricsAggregator nwOutgoingBytes(String interfaceName) {
-        return nwOutgoingBytes.get(interfaceName);
-    }
-
-    /**
-     * Returns incoming packets metric aggregator.
-     *
-     * @param interfaceName name of network interface
-     * @return metric aggregator
-     */
-    public MetricsAggregator nwIncomingPackets(String interfaceName) {
-        return nwIncomingPackets.get(interfaceName);
-    }
-
-    /**
-     * Returns outgoing packets metric aggregator.
-     *
-     * @param interfaceName name of network interface
-     * @return metric aggregator
-     */
-    public MetricsAggregator nwOutgoingPackets(String interfaceName) {
-        return nwOutgoingPackets.get(interfaceName);
-    }
-
-    /**
-     * Returns inbound packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> inboundPacket() {
-        return ImmutableMap.copyOf(inboundPacket);
-    }
-
-    /**
-     * Returns outgoing packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> outboundPacket() {
-        return ImmutableMap.copyOf(outboundPacket);
-    }
-
-    /**
-     * Returns flow-mod packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> flowmodPacket() {
-        return ImmutableMap.copyOf(flowmodPacket);
-    }
-
-    /**
-     * Returns flow-removed packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> flowrmvPacket() {
-        return ImmutableMap.copyOf(flowrmvPacket);
-    }
-
-    /**
-     * Returns request packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> requestPacket() {
-        return ImmutableMap.copyOf(requestPacket);
-    }
-
-    /**
-     * Returns reply packet metric aggregator of all devices.
-     *
-     * @return metric aggregator
-     */
-    public Map<DeviceId, MetricsAggregator> replyPacket() {
-        return ImmutableMap.copyOf(replyPacket);
-    }
-
-    /**
-     * Returns inbound packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator inboundPacket(DeviceId deviceId) {
-        return inboundPacket.get(deviceId);
-    }
-
-    /**
-     * Returns outbound packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator outboundPacket(DeviceId deviceId) {
-        return outboundPacket.get(deviceId);
-    }
-
-    /**
-     * Returns flow-mod packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator flowmodPacket(DeviceId deviceId) {
-        return flowmodPacket.get(deviceId);
-    }
-
-    /**
-     * Returns flow-removed packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator flowrmvPacket(DeviceId deviceId) {
-        return flowrmvPacket.get(deviceId);
-    }
-
-    /**
-     * Returns request packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator requestPacket(DeviceId deviceId) {
-        return requestPacket.get(deviceId);
-    }
-
-    /**
-     * Returns reply packet metric aggregator of a specified device.
-     *
-     * @param deviceId device identifier
-     * @return metric aggregator
-     */
-    public MetricsAggregator replyPacket(DeviceId deviceId) {
-        return replyPacket.get(deviceId);
-    }
-
-    /**
-     * Returns an instance of control metrics factory.
-     *
-     * @return instance of control metrics factory
-     */
-    public static ControlMetricsFactory getInstance() {
-        return SingletonHelper.INSTANCE;
-    }
-
-    private static class SingletonHelper {
-        private static final ControlMetricsFactory INSTANCE = new ControlMetricsFactory();
-    }
-}
\ No newline at end of file

-/*
- * Copyright 2016-present Open Networking Laboratory
- *
- * 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.cpman.impl;
-
-import org.onosproject.net.DeviceId;
-
-import java.util.Optional;
-
-/**
- * Control metrics observer interface.
- */
-public interface ControlMetricsObserver {
-
-    /**
-     * Feeds the extracted value from MetricAggregator to back-end storage.
-     *
-     * @param metricsAggregator metric aggregator
-     * @param deviceId          device identification
-     */
-    void feedMetrics(MetricsAggregator metricsAggregator, Optional<DeviceId> deviceId);
-
-    /**
-     * Feeds the extracted value from MetricAggregator to back-end storage.
-     *
-     * @param metricsAggregator metric aggregator
-     * @param resourceName      resource name
-     */
-    void feedMetrics(MetricsAggregator metricsAggregator, String resourceName);
-}

-/*
- * Copyright 2016-present Open Networking Laboratory
- *
- * 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.cpman.impl;
-
-import org.apache.felix.scr.annotations.Reference;
-import org.apache.felix.scr.annotations.ReferenceCardinality;
-import org.onosproject.cpman.ControlMetric;
-import org.onosproject.cpman.ControlPlaneMonitorService;
-import org.onosproject.cpman.MetricValue;
-import org.onosproject.net.DeviceId;
-
-import java.util.Optional;
-
-/**
- * Default ControlMetricsObserver.
- */
-public class DefaultControlMetricsObserver implements ControlMetricsObserver {
-
-    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
-    protected ControlPlaneMonitorService controlPlaneMonitorService;
-
-    @Override
-    public void feedMetrics(MetricsAggregator ma, Optional<DeviceId> deviceId) {
-        MetricValue mv = new MetricValue.Builder()
-                        .rate(ma.getRate())
-                        .count(ma.getCount())
-                        .load(ma.getLoad())
-                        .add();
-        ControlMetric cm = new ControlMetric(ma.getMetricsType(), mv);
-        controlPlaneMonitorService.updateMetric(cm, 1, deviceId);
-    }
-
-    @Override
-    public void feedMetrics(MetricsAggregator ma, String resourceName) {
-        MetricValue mv = new MetricValue.Builder()
-                        .rate(ma.getRate())
-                        .count(ma.getCount())
-                        .load(ma.getLoad())
-                        .add();
-        ControlMetric cm = new ControlMetric(ma.getMetricsType(), mv);
-        controlPlaneMonitorService.updateMetric(cm, 1, resourceName);
-    }
-}
\ No newline at end of file

-/*
- * Copyright 2016-present Open Networking Laboratory
- *
- * 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.cpman.impl;
-
-import com.codahale.metrics.Meter;
-import org.apache.commons.lang3.StringUtils;
-import org.onlab.metrics.MetricsComponent;
-import org.onlab.metrics.MetricsFeature;
-import org.onlab.metrics.MetricsService;
-import org.onosproject.cpman.ControlMetricType;
-import org.onosproject.net.DeviceId;
-
-import java.util.Optional;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-
-/**
- * An aggregator that aggregates a specific network or performance metrics via the metrics service.
- */
-public class MetricsAggregator {
-
-    private Meter rateMeter;
-    private Meter countMeter;
-    private MetricsService metricsService;
-    private MetricsComponent metricsComponent;
-    private MetricsFeature metricsFeature;
-    private ControlMetricType metricsType;
-    private static final int EXECUTE_PERIOD_IN_SECOND = 60;
-    private static final String RATE_NAME = "rate";
-    private static final String COUNT_NAME = "count";
-
-    /**
-     * Constructs a new metrics aggregator for aggregating a metric.
-     * Instantiates the metrics service
-     * Initializes all the general metrics for that object
-     *
-     * @param metricsService metric service reference
-     * @param type           control metric type
-     * @param deviceId       device identification
-     */
-    MetricsAggregator(MetricsService metricsService, ControlMetricType type,
-                      Optional<DeviceId> deviceId) {
-        init(metricsService, type, deviceId, null);
-    }
-
-    /**
-     * Constructs a new metrics aggregator for aggregating a metric.
-     * Instantiates the metrics service
-     * Initializes all the general metrics for that object
-     *
-     * @param metricsService metric service reference
-     * @param type           control metric type
-     * @param resourceName   resource name (e.g., ethernet interface name)
-     */
-    MetricsAggregator(MetricsService metricsService, ControlMetricType type,
-                      String resourceName) {
-        init(metricsService, type, Optional.ofNullable(null), resourceName);
-
-    }
-
-    /**
-     * Constructs a new metrics aggregator for aggregating a metric.
-     * Instantiates the metrics service
-     * Initializes all the general metrics for that object
-     *
-     * @param metricsService metrics service reference
-     * @param type           control metric type
-     */
-    MetricsAggregator(MetricsService metricsService, ControlMetricType type) {
-        init(metricsService, type, Optional.ofNullable(null), null);
-    }
-
-    /**
-     * Base method of the constructor of this class.
-     *
-     * @param metricsService metrics service reference
-     * @param type           control metric type
-     * @param deviceId       device identification
-     * @param resourceName   resource name
-     */
-    private void init(MetricsService metricsService, ControlMetricType type,
-                      Optional<DeviceId> deviceId, String resourceName) {
-        String primitiveName = type.toString();
-        String objName = "all";
-        if (deviceId.isPresent()) {
-            objName = deviceId.toString();
-        }
-
-        if (StringUtils.isNotEmpty(resourceName)) {
-            objName = resourceName;
-        }
-
-        checkNotNull(primitiveName, "Component name cannot be null");
-        checkNotNull(objName, "Feature name cannot be null");
-
-        this.metricsType = type;
-
-        this.metricsService = metricsService;
-        this.metricsComponent = metricsService.registerComponent(primitiveName);
-        this.metricsFeature = metricsComponent.registerFeature(objName);
-
-        this.rateMeter = metricsService.createMeter(metricsComponent, metricsFeature, RATE_NAME);
-        this.countMeter = metricsService.createMeter(metricsComponent, metricsFeature, COUNT_NAME);
-    }
-
-    /**
-     * Returns control metrics type.
-     *
-     * @return control metrics type
-     */
-    public ControlMetricType getMetricsType() {
-        return metricsType;
-    }
-
-    /**
-     * Increments the meter rate by n, and the meter counter by 1.
-     *
-     * @param n increment rate.
-     */
-    public void increment(long n) {
-        rateMeter.mark(n);
-        countMeter.mark(1);
-    }
-
-    /**
-     * Returns the average load value.
-     *
-     * @return load value
-     */
-    public long getLoad() {
-        return (long) rateMeter.getOneMinuteRate() / (long) countMeter.getOneMinuteRate();
-    }
-
-    /**
-     * Returns the average meter rate within recent 1 minute.
-     *
-     * @return rate value
-     */
-    public long getRate() {
-        return (long) rateMeter.getOneMinuteRate();
-    }
-
-    /**
-     * Returns the average meter count within recent 1 minute.
-     *
-     * @return count value
-     */
-    public long getCount() {
-        return (long) countMeter.getOneMinuteRate() * EXECUTE_PERIOD_IN_SECOND;
-    }
-}
\ No newline at end of file