Lines Matching refs:allData

152     vector<shared_ptr<LogEvent>> allData;  in TEST()  local
153 allData.clear(); in TEST()
154 allData.push_back(makeLogEvent(tagId, bucket2StartTimeNs + 1, 10, "some value", 11)); in TEST()
156 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs); in TEST()
172 allData.clear(); in TEST()
173 allData.push_back(makeLogEvent(tagId, bucket3StartTimeNs + 10, 24, "some value", 25)); in TEST()
174 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket3StartTimeNs); in TEST()
339 vector<shared_ptr<LogEvent>> allData; in TEST_P() local
340 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST_P()
341 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST_P()
369 allData.clear(); in TEST_P()
370 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + bucketSizeNs + 1, 3)); in TEST_P()
371 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, in TEST_P()
410 vector<shared_ptr<LogEvent>> allData; in TEST() local
411 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 1)); in TEST()
412 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
474 vector<shared_ptr<LogEvent>> allData; in TEST() local
475 allData.clear(); in TEST()
476 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucket2StartTimeNs + 1, 110)); in TEST()
477 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs); in TEST()
565 vector<shared_ptr<LogEvent>> allData; in TEST() local
566 allData.clear(); in TEST()
567 allData.push_back(CreateTwoValueLogEvent(tagId, bucket2StartTimeNs + 1, 1000, 110)); in TEST()
568 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs); in TEST()
614 vector<shared_ptr<LogEvent>> allData; in TEST() local
615 allData.clear(); in TEST()
616 allData.push_back(CreateRepeatedValueLogEvent(tagId, bucketStartTimeNs + 1, 13)); in TEST()
617 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucketStartTimeNs); in TEST()
628 allData.clear(); in TEST()
629 allData.push_back(event2); in TEST()
630 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, in TEST()
640 allData.clear(); in TEST()
641 allData.push_back( in TEST()
643 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, in TEST()
654 allData.clear(); in TEST()
655 allData.push_back(CreateNoValuesLogEvent(tagId, bucketStartTimeNs + 3 * bucketSizeNs + 10)); in TEST()
656 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, in TEST()
769 vector<std::shared_ptr<LogEvent>> allData; in TEST() local
770 allData.push_back(CreateNoValuesLogEvent(tagId, bucket2StartTimeNs + 10)); in TEST()
771 gaugeProducer.onDataPulled(allData, PullResult::PULL_RESULT_SUCCESS, bucket2StartTimeNs + 30); in TEST()