Searched refs:set_max_messages_per_second (Results 1 – 3 of 3) sorted by relevance
68 ds_config->mutable_for_testing()->set_max_messages_per_second(messages_per_s); in BenchmarkProducer()145 ds_config->mutable_for_testing()->set_max_messages_per_second(messages_per_s); in BenchmarkConsumer()
150 void set_max_messages_per_second(uint32_t value) { in set_max_messages_per_second() function
91 proto->set_max_messages_per_second( in ToProto()