Searched refs:recordSink (Results 1 – 1 of 1) sorted by relevance
224 private final BlockingQueue<MetricsRecord> recordSink; field in StatsTestUtils.FakeStatsRecord228 this.recordSink = statsRecorder.getCurrentRecordSink(); in FakeStatsRecord()245 recordSink.add(new MetricsRecord(getTags(tags), ImmutableMap.copyOf(metrics))); in record()