io.grpc.internal.testing

Class StatsTestUtils.FakeStatsContextFactory

java.lang.Object

com.google.instrumentation.stats.StatsContextFactory

io.grpc.internal.testing.StatsTestUtils.FakeStatsContextFactory

Enclosing class:

StatsTestUtils

public static final class StatsTestUtils.FakeStatsContextFactory
extends com.google.instrumentation.stats.StatsContextFactory

A factory that makes fake StatsContexts and saves the created contexts to be accessible from pollContextOrFail(). The contexts it has created would save metrics records to be accessible from pollRecord() and pollRecord(long, TimeUnit), until rolloverRecords() is called.

Field Summary

Fields

Modifier and Type	Field and Description
BlockingQueue<StatsTestUtils.FakeStatsContext>	contexts

Constructor Summary

Constructors

Constructor and Description
FakeStatsContextFactory() Constructor.

Method Summary

Modifier and Type	Method and Description
com.google.instrumentation.stats.StatsContext	deserialize(InputStream buffer)
StatsTestUtils.FakeStatsContext	getDefault()
com.google.instrumentation.stats.StatsContext	pollContextOrFail()
StatsTestUtils.MetricsRecord	pollRecord()
StatsTestUtils.MetricsRecord	pollRecord(long timeout, TimeUnit unit)
void	rolloverRecords() Disconnect this factory with the contexts it has created so far.

Methods inherited from class com.google.instrumentation.stats.StatsContextFactory

getCurrentStatsContext, withStatsContext

Methods inherited from class java.lang.Object

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

Field Detail

contexts

public final BlockingQueue<StatsTestUtils.FakeStatsContext> contexts

Constructor Detail

FakeStatsContextFactory

public FakeStatsContextFactory()

Constructor.

Method Detail

pollContextOrFail

public com.google.instrumentation.stats.StatsContext pollContextOrFail()

pollRecord

public StatsTestUtils.MetricsRecord pollRecord()

pollRecord

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

Throws:

InterruptedException

deserialize

public com.google.instrumentation.stats.StatsContext deserialize(InputStream buffer)
                                                          throws IOException

Specified by:

deserialize in class com.google.instrumentation.stats.StatsContextFactory

Throws:

IOException

getDefault

public StatsTestUtils.FakeStatsContext getDefault()

Specified by:

getDefault in class com.google.instrumentation.stats.StatsContextFactory

rolloverRecords

public void rolloverRecords()

Disconnect this factory 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.