Searched refs:MetricsRecord (Results 1 – 3 of 3) sorted by relevance
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | StatsTestUtils.java | 65 public static class MetricsRecord { class in StatsTestUtils
70 private MetricsRecord( in MetricsRecord() method in StatsTestUtils.MetricsRecord
128 private BlockingQueue<MetricsRecord> records;
139 public MetricsRecord pollRecord() { in pollRecord()
143 public MetricsRecord pollRecord(long timeout, TimeUnit unit) throws InterruptedException { in pollRecord()
154 records = new LinkedBlockingQueue<MetricsRecord>(); in rolloverRecords()
157 private synchronized BlockingQueue<MetricsRecord> getCurrentRecordSink() { in getCurrentRecordSink()
224 private final BlockingQueue<MetricsRecord> recordSink;
245 recordSink.add(new MetricsRecord(getTags(tags), ImmutableMap.copyOf(metrics))); in record()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | CensusModulesTest.java | 280 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in testClientInterceptors()
364 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in subtestClientBasicStatsDefaultContext()
399 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in subtestClientBasicStatsDefaultContext()
492 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in clientStreamNeverCreatedStillRecordStats()
582 StatsTestUtils.MetricsRecord clientRecord = statsRecorder.pollRecord(); in subtestStatsHeadersPropagateTags()
617 StatsTestUtils.MetricsRecord serverRecord = statsRecorder.pollRecord(); in subtestStatsHeadersPropagateTags()
645 StatsTestUtils.MetricsRecord clientRecord = statsRecorder.pollRecord(); in subtestStatsHeadersPropagateTags()
813 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in subtestServerBasicStatsNoHeaders()
857 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord(); in subtestServerBasicStatsNoHeaders()
997 private static void assertNoServerContent(StatsTestUtils.MetricsRecord record) { in assertNoServerContent()
[all …]
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | AbstractInteropTest.java | 76 import io.grpc.internal.testing.StatsTestUtils.MetricsRecord;
767 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in cancelAfterBegin()
772 MetricsRecord clientEndRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in cancelAfterBegin()
1098 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineExceeded()
1100 MetricsRecord clientEndRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineExceeded()
1134 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineExceededServerStreaming()
1136 MetricsRecord clientEndRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineExceededServerStreaming()
1161 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineInPast()
1163 MetricsRecord clientEndRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineInPast()
1181 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS); in deadlineInPast()
[all …]
|