Package io.grpc.internal.testing

Class StatsTestUtils.FakeStatsRecorder

java.lang.Object

io.opencensus.stats.StatsRecorder

io.grpc.internal.testing.StatsTestUtils.FakeStatsRecorder

Enclosing class:

StatsTestUtils

public static final class StatsTestUtils.FakeStatsRecorder
extends io.opencensus.stats.StatsRecorder

A Tagger implementation that saves metrics records to be accessible from pollRecord() and pollRecord(long, TimeUnit), until rolloverRecords() is called.

Field Summary

Fields

Modifier and Type	Field	Description
private BlockingQueue<StatsTestUtils.MetricsRecord>	records

Constructor Summary

Constructors

Constructor	Description
FakeStatsRecorder()

Method Summary

Modifier and Type	Method	Description
private BlockingQueue<StatsTestUtils.MetricsRecord>	getCurrentRecordSink()
io.opencensus.stats.MeasureMap	newMeasureMap()
StatsTestUtils.MetricsRecord	pollRecord()
StatsTestUtils.MetricsRecord	pollRecord(long timeout, TimeUnit unit)
void	rolloverRecords()	Disconnect this tagger with the contexts it has created so far.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

records

private BlockingQueue<StatsTestUtils.MetricsRecord> records

Constructor Details

FakeStatsRecorder

public FakeStatsRecorder()

Method Details

newMeasureMap

public io.opencensus.stats.MeasureMap newMeasureMap()

Specified by:

newMeasureMap in class io.opencensus.stats.StatsRecorder

pollRecord

public StatsTestUtils.MetricsRecord pollRecord()

pollRecord

public StatsTestUtils.MetricsRecord pollRecord(long timeout,
 TimeUnit unit)
                                        throws InterruptedException

Throws:

InterruptedException

rolloverRecords

public void rolloverRecords()

Disconnect this tagger with the contexts it has created so far. The records from those contexts will not show up in pollRecord(). Useful for isolating the records between test cases.

getCurrentRecordSink

private BlockingQueue<StatsTestUtils.MetricsRecord> getCurrentRecordSink()