Searched refs:serverlist (Results 1 – 8 of 8) sorted by relevance
| /third_party/grpc/test/cpp/grpclb/ |
| D | grpclb_api_test.cc | 98 EXPECT_EQ(resp.serverlist.size(), 0); in TEST_F()
104 auto* serverlist = response.mutable_server_list(); in TEST_F() local
105 auto* server = serverlist->add_servers(); in TEST_F()
125 EXPECT_EQ(resp.serverlist.size(), 2); in TEST_F()
126 EXPECT_EQ(PackedStringToIp(resp.serverlist[0]), "127.0.0.1"); in TEST_F()
127 EXPECT_EQ(resp.serverlist[0].port, 12345); in TEST_F()
128 EXPECT_STREQ(resp.serverlist[0].load_balance_token, "rate_limting"); in TEST_F()
129 EXPECT_TRUE(resp.serverlist[0].drop); in TEST_F()
130 EXPECT_EQ(PackedStringToIp(resp.serverlist[1]), "10.0.0.1"); in TEST_F()
131 EXPECT_EQ(resp.serverlist[1].port, 54321); in TEST_F()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 295 explicit Serverlist(std::vector<GrpcLbServer> serverlist) in Serverlist() argument
296 : serverlist_(std::move(serverlist)) {} in Serverlist()
300 const std::vector<GrpcLbServer>& serverlist() const { return serverlist_; } in serverlist() function in grpc_core::__anone44b111d0111::GrpcLb::Serverlist
333 Picker(RefCountedPtr<Serverlist> serverlist, in Picker() argument
336 : serverlist_(std::move(serverlist)), in Picker()
702 RefCountedPtr<Serverlist> serverlist; in UpdateState() local
706 serverlist = parent_->serverlist_; in UpdateState()
718 status.ToString().c_str(), picker.get(), serverlist.get(), in UpdateState()
723 absl::make_unique<Picker>(std::move(serverlist), std::move(picker), in UpdateState()
1080 MakeRefCounted<Serverlist>(std::move(response.serverlist)); in OnBalancerMessageReceivedLocked()
[all …]
|
| D | load_balancer_api.h | 53 std::vector<GrpcLbServer> serverlist; member
|
| D | load_balancer_api.cc | 166 if (ParseServerList(*response, &result->serverlist)) { in GrpcLbResponseParse()
|
| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_api.h | 183 return *name == *other.name && serverlist == other.serverlist &&
195 ServerAddressList serverlist; member
|
| D | xds_client.cc | 1093 locality.lb_weight, locality.serverlist.size()); in AcceptEdsUpdate()
1094 for (size_t i = 0; i < locality.serverlist.size(); ++i) { in AcceptEdsUpdate()
1096 &locality.serverlist[i].address(), false); in AcceptEdsUpdate()
|
| D | xds_api.cc | 1630 lb_endpoints[i], &output_locality->serverlist); in LocalityParse()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | eds.cc | 586 for (size_t i = 0; i < locality.serverlist.size(); ++i) { in CreateChildPolicyAddressesLocked()
587 const ServerAddress& address = locality.serverlist[i]; in CreateChildPolicyAddressesLocked()
|