Class QueueMetricProducer
- java.lang.Object
-
- io.opencensus.metrics.export.MetricProducer
-
- io.opencensus.exporter.metrics.util.QueueMetricProducer
-
public final class QueueMetricProducer extends MetricProducer
Wrapper ofMetricProducerwhich allows metrics to be pushed and buffered.- Since:
- 0.20
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classQueueMetricProducer.OptionsOptions forQueueMetricProducer.
-
Field Summary
Fields Modifier and Type Field Description private java.util.Queue<Metric>bufferedMetricsprivate static intDEFAULT_BUFFER_SIZEprivate static java.lang.Objectmonitor
-
Constructor Summary
Constructors Modifier Constructor Description privateQueueMetricProducer(int bufferSize)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static QueueMetricProducercreate(QueueMetricProducer.Options options)Creates a newQueueMetricProducer.java.util.Collection<Metric>getMetrics()Returns a collection of producedMetrics to be exported.voidpushMetrics(java.util.Collection<Metric> metrics)PushesMetrics to thisQueueMetricProducer.
-
-
-
Field Detail
-
monitor
private static final java.lang.Object monitor
-
DEFAULT_BUFFER_SIZE
private static final int DEFAULT_BUFFER_SIZE
- See Also:
- Constant Field Values
-
bufferedMetrics
private final java.util.Queue<Metric> bufferedMetrics
-
-
Method Detail
-
create
public static QueueMetricProducer create(QueueMetricProducer.Options options)
Creates a newQueueMetricProducer.- Parameters:
options- the options forQueueMetricProducer.- Returns:
- a
QueueMetricProducer. - Since:
- 0.20
-
pushMetrics
public void pushMetrics(java.util.Collection<Metric> metrics)
PushesMetrics to thisQueueMetricProducer.When buffer of this
QueueMetricProduceris full, the oldestMetrics will be dropped.- Parameters:
metrics-Metricsto be added to thisQueueMetricProducer.- Since:
- 0.20
-
getMetrics
public java.util.Collection<Metric> getMetrics()
Description copied from class:MetricProducerReturns a collection of producedMetrics to be exported.- Specified by:
getMetricsin classMetricProducer- Returns:
- a collection of produced
Metrics to be exported.
-
-