Searched refs:LoadReporter (Results 1 – 7 of 7) sorted by relevance
39 : public grpc::lb::v1::LoadReporter::AsyncService {101 LoadReporter* load_reporter);107 LoadReporter* load_reporter);149 LoadReporter* load_reporter_;187 std::unique_ptr<LoadReporter> load_reporter_;
217 grpc::string LoadReporter::GenerateLbId() { in GenerateLbId()241 LoadReporter::GenerateLoadBalancingFeedback() { in GenerateLoadBalancingFeedback()291 LoadReporter::GenerateLoads(const grpc::string& hostname, in GenerateLoads()352 void LoadReporter::AttachOrphanLoadId( in AttachOrphanLoadId()366 void LoadReporter::AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors) { in AppendNewFeedbackRecord()379 void LoadReporter::ReportStreamCreated(const grpc::string& hostname, in ReportStreamCreated()389 void LoadReporter::ReportStreamClosed(const grpc::string& hostname, in ReportStreamClosed()397 void LoadReporter::ProcessViewDataCallStart( in ProcessViewDataCallStart()417 void LoadReporter::ProcessViewDataCallEnd( in ProcessViewDataCallEnd()470 void LoadReporter::ProcessViewDataOtherCallMetrics( in ProcessViewDataOtherCallMetrics()[all …]
41 load_reporter_ = std::unique_ptr<LoadReporter>(new LoadReporter( in LoadReporterAsyncServiceImpl()117 LoadReporter* load_reporter) { in CreateAndStart()140 LoadReporter* load_reporter) in ReportLoadHandler()
115 class LoadReporter {118 LoadReporter(uint32_t feedback_sample_window_seconds, in LoadReporter() function
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
128 auto stub = ::grpc::lb::v1::LoadReporter::NewStub(channel); in TEST_F()