135             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
137                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs);  in TEST()
139                 data->push_back(makeLogEvent(tagId, eventTimeNs + 10, 3, "some value", 11));  in TEST()
304             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST_P()
306                 EXPECT_EQ(eventTimeNs, partialBucketSplitTimeNs);  in TEST_P()
308                 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 2));  in TEST_P()
427             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
430                 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs + 10, 100));  in TEST()
510             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
513                 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs + 10, 1000, 100));  in TEST()
642             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
644                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10);  in TEST()
646                 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 4));  in TEST()
649             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()  argument
651                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20);  in TEST()
653                 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 5));  in TEST()
710             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
712                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 3);  in TEST()
714                 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs, 3, 4));  in TEST()
717             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()  argument
719                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 10);  in TEST()
721                 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs, 4, 5));  in TEST()
724             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()  argument
726                 EXPECT_EQ(eventTimeNs, bucketStartTimeNs + 20);  in TEST()
728                 data->push_back(CreateTwoValueLogEvent(tagId, eventTimeNs, 4, 6));  in TEST()
785             .WillOnce(Invoke([](int tagId, const ConfigKey&, const int64_t eventTimeNs,  in TEST()
788                 data->push_back(CreateRepeatedValueLogEvent(tagId, eventTimeNs, 10));  in TEST()