Searched refs:LoadReporter (Results 1 – 7 of 7) sorted by relevance
40 : public grpc::lb::v1::LoadReporter::AsyncService {102 LoadReporter* load_reporter);108 LoadReporter* load_reporter);150 LoadReporter* load_reporter_;188 std::unique_ptr<LoadReporter> load_reporter_;
219 std::string LoadReporter::GenerateLbId() { in GenerateLbId()243 LoadReporter::GenerateLoadBalancingFeedback() { in GenerateLoadBalancingFeedback()293 LoadReporter::GenerateLoads(const std::string& hostname, in GenerateLoads()354 void LoadReporter::AttachOrphanLoadId( in AttachOrphanLoadId()368 void LoadReporter::AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors) { in AppendNewFeedbackRecord()381 void LoadReporter::ReportStreamCreated(const std::string& hostname, in ReportStreamCreated()391 void LoadReporter::ReportStreamClosed(const std::string& hostname, in ReportStreamClosed()399 void LoadReporter::ProcessViewDataCallStart( in ProcessViewDataCallStart()419 void LoadReporter::ProcessViewDataCallEnd( in ProcessViewDataCallEnd()472 void LoadReporter::ProcessViewDataOtherCallMetrics( in ProcessViewDataOtherCallMetrics()[all …]
117 class LoadReporter {120 LoadReporter(uint32_t feedback_sample_window_seconds, in LoadReporter() function
45 load_reporter_ = absl::make_unique<LoadReporter>( in LoadReporterAsyncServiceImpl()122 LoadReporter* load_reporter) { in CreateAndStart()145 LoadReporter* load_reporter) in ReportLoadHandler()
44 using ::grpc::load_reporter::LoadReporter;99 std::unique_ptr<LoadReporter> load_reporter_;143 load_reporter_ = std::unique_ptr<LoadReporter>( in SetUp()144 new LoadReporter(kFeedbackSampleWindowSeconds, in SetUp()
21 // The LoadReporter service.22 service LoadReporter { service181 // The unique ID generated by LoadReporter to identify balancers. Here it
127 auto stub = ::grpc::lb::v1::LoadReporter::NewStub(channel); in TEST_F()