49 const ConfigKey kConfigKey(0, 12345);  variable
180             EXPECT_CALL(*pullerManager, RegisterReceiver(tagId, kConfigKey, _, _, _))
182             EXPECT_CALL(*pullerManager, UnRegisterReceiver(tagId, kConfigKey, _))
186                 TimeUnitToBucketSizeInMillisGuardrailed(kConfigKey.GetUid(), metric.bucket()));
211                 kConfigKey, metric, protoHash, {pullAtomId, pullerManager},
336     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
400     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST_P()
461     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
518     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
571     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
623     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
761     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST_P()
815     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
839     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST_P()
1065     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
1100     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
1176     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
1241     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
1682     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
1748     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
1840     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
1956     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 8, _))  in TEST()
1992     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2033     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2074     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 1, _))  in TEST()
2116     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 1, _))  in TEST()
2147     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2222     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 2, _))  in TEST()
2279     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2356     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2427     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
2486     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2559     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2618     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 10, _))  in TEST()
2656     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST_P()
2723     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2798     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
2829     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST_P()
2870     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2915     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
2972     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
3009     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3068     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3119     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 8, _))  in TEST()
3169     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3214     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 20, _))  in TEST()
3262     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 50, _))  in TEST()
3320     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3386     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3442     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3492     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3569     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3660     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3750     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3815     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs + 10, _))  in TEST()
3866     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
3986     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
4252     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
4585     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
4815     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
5030     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
5116     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
5340     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
5569     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
5815     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6011     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6204     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6466     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6546     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6596     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6651     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6710     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6768     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6840     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
6897     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, bucketStartTimeNs, _))  in TEST()
6950     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7006     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7063     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7133     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7190     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7243     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7350     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()
7438     EXPECT_CALL(*pullerManager, Pull(tagId, kConfigKey, _, _))  in TEST()