public static class ReplicationDeliveryMetrics.ReplicationDeliveryMetricsAggregator extends java.lang.Object implements ReplicationMetricsPublisher.MetricsAggregator
Constructor and Description |
---|
ReplicationDeliveryMetricsAggregator() |
Modifier and Type | Method and Description |
---|---|
void |
addMetric(ReplicationDeliveryMetrics.ReplicationDeliveryMetric metric) |
void |
addMinMaxValueComparator(java.lang.String name,
java.util.Comparator comparator) |
ReplicationDeliveryMetrics.ReplicationDeliveryMetricsAggregator |
copy() |
java.util.Map |
copyMinMaxValues() |
java.util.Map |
copyMinMaxValuesEmpty() |
long |
getMaxTimestamp() |
Pair |
getMinMaxMetric(java.lang.String name) |
java.util.Map |
getMinMaxMetricMap() |
long |
getMinTimestamp() |
long |
getResetTime() |
ReplicationDeliveryMetrics.ReplicationDeliveryMetric |
getTotal() |
long |
getTotalCount() |
void |
reset() |
ReplicationDeliveryMetrics.ReplicaMetricsReportFacet |
toReport() |
public ReplicationDeliveryMetricsAggregator()
public void addMetric(ReplicationDeliveryMetrics.ReplicationDeliveryMetric metric)
addMetric
in interface ReplicationMetricsPublisher.MetricsAggregator
public void reset()
reset
in interface ReplicationMetricsPublisher.MetricsAggregator
public ReplicationDeliveryMetrics.ReplicationDeliveryMetricsAggregator copy()
copy
in interface ReplicationMetricsPublisher.MetricsAggregator
public java.util.Map copyMinMaxValues()
public java.util.Map copyMinMaxValuesEmpty()
public ReplicationDeliveryMetrics.ReplicaMetricsReportFacet toReport()
toReport
in interface ReplicationMetricsPublisher.MetricsAggregator
public Pair getMinMaxMetric(java.lang.String name)
public java.util.Map getMinMaxMetricMap()
public void addMinMaxValueComparator(java.lang.String name, java.util.Comparator comparator)
public long getMinTimestamp()
public long getMaxTimestamp()
public ReplicationDeliveryMetrics.ReplicationDeliveryMetric getTotal()
public long getTotalCount()
public long getResetTime()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.