/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_cluster.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_cluster.proto |
2 | | |
3 | | #include "yb/master/master_cluster.proxy.h" |
4 | | |
5 | | #include "yb/master/master_cluster.service.h" |
6 | | |
7 | | #include "yb/rpc/proxy.h" |
8 | | #include "yb/rpc/outbound_call.h" |
9 | | #include "yb/util/metrics.h" |
10 | | #include "yb/util/net/sockaddr.h" |
11 | | |
12 | | METRIC_DEFINE_counter( |
13 | | server, proxy_request_bytes_yb_master_MasterCluster_ListTabletServers, |
14 | | "Bytes sent by yb.master.MasterCluster.ListTabletServers() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterCluster.ListTabletServers() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterCluster_ListTabletServers, |
20 | | "Bytes received in response to yb.master.MasterCluster.ListTabletServers() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterCluster.ListTabletServers() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_master_MasterCluster_ListLiveTabletServers, |
26 | | "Bytes sent by yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.master.MasterCluster.ListLiveTabletServers() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_master_MasterCluster_ListLiveTabletServers, |
32 | | "Bytes received in response to yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.master.MasterCluster.ListLiveTabletServers() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_master_MasterCluster_ListMasters, |
38 | | "Bytes sent by yb.master.MasterCluster.ListMasters() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.master.MasterCluster.ListMasters() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_master_MasterCluster_ListMasters, |
44 | | "Bytes received in response to yb.master.MasterCluster.ListMasters() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.master.MasterCluster.ListMasters() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_master_MasterCluster_ListMasterRaftPeers, |
50 | | "Bytes sent by yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.master.MasterCluster.ListMasterRaftPeers() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_master_MasterCluster_ListMasterRaftPeers, |
56 | | "Bytes received in response to yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.master.MasterCluster.ListMasterRaftPeers() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_master_MasterCluster_GetMasterRegistration, |
62 | | "Bytes sent by yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.master.MasterCluster.GetMasterRegistration() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_master_MasterCluster_GetMasterRegistration, |
68 | | "Bytes received in response to yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.master.MasterCluster.GetMasterRegistration() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady, |
74 | | "Bytes sent by yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady, |
80 | | "Bytes received in response to yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_master_MasterCluster_DumpState, |
86 | | "Bytes sent by yb.master.MasterCluster.DumpState() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.master.MasterCluster.DumpState() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_master_MasterCluster_DumpState, |
92 | | "Bytes received in response to yb.master.MasterCluster.DumpState() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.master.MasterCluster.DumpState() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_master_MasterCluster_ChangeLoadBalancerState, |
98 | | "Bytes sent by yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_master_MasterCluster_ChangeLoadBalancerState, |
104 | | "Bytes received in response to yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_master_MasterCluster_GetLoadBalancerState, |
110 | | "Bytes sent by yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.master.MasterCluster.GetLoadBalancerState() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_master_MasterCluster_GetLoadBalancerState, |
116 | | "Bytes received in response to yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.master.MasterCluster.GetLoadBalancerState() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_master_MasterCluster_RemovedMasterUpdate, |
122 | | "Bytes sent by yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.master.MasterCluster.RemovedMasterUpdate() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_master_MasterCluster_RemovedMasterUpdate, |
128 | | "Bytes received in response to yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.master.MasterCluster.RemovedMasterUpdate() RPC requests"); |
131 | | |
132 | | METRIC_DEFINE_counter( |
133 | | server, proxy_request_bytes_yb_master_MasterCluster_SetPreferredZones, |
134 | | "Bytes sent by yb.master.MasterCluster.SetPreferredZones() RPC requests", |
135 | | yb::MetricUnit::kBytes, |
136 | | "Bytes sent by yb.master.MasterCluster.SetPreferredZones() RPC requests"); |
137 | | |
138 | | METRIC_DEFINE_counter( |
139 | | server, proxy_response_bytes_yb_master_MasterCluster_SetPreferredZones, |
140 | | "Bytes received in response to yb.master.MasterCluster.SetPreferredZones() RPC requests", |
141 | | yb::MetricUnit::kBytes, |
142 | | "Bytes received in response to yb.master.MasterCluster.SetPreferredZones() RPC requests"); |
143 | | |
144 | | METRIC_DEFINE_counter( |
145 | | server, proxy_request_bytes_yb_master_MasterCluster_GetMasterClusterConfig, |
146 | | "Bytes sent by yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
147 | | yb::MetricUnit::kBytes, |
148 | | "Bytes sent by yb.master.MasterCluster.GetMasterClusterConfig() RPC requests"); |
149 | | |
150 | | METRIC_DEFINE_counter( |
151 | | server, proxy_response_bytes_yb_master_MasterCluster_GetMasterClusterConfig, |
152 | | "Bytes received in response to yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
153 | | yb::MetricUnit::kBytes, |
154 | | "Bytes received in response to yb.master.MasterCluster.GetMasterClusterConfig() RPC requests"); |
155 | | |
156 | | METRIC_DEFINE_counter( |
157 | | server, proxy_request_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig, |
158 | | "Bytes sent by yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
159 | | yb::MetricUnit::kBytes, |
160 | | "Bytes sent by yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests"); |
161 | | |
162 | | METRIC_DEFINE_counter( |
163 | | server, proxy_response_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig, |
164 | | "Bytes received in response to yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
165 | | yb::MetricUnit::kBytes, |
166 | | "Bytes received in response to yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests"); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, proxy_request_bytes_yb_master_MasterCluster_GetLoadMoveCompletion, |
170 | | "Bytes sent by yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes sent by yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, proxy_response_bytes_yb_master_MasterCluster_GetLoadMoveCompletion, |
176 | | "Bytes received in response to yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes received in response to yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_counter( |
181 | | server, proxy_request_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion, |
182 | | "Bytes sent by yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
183 | | yb::MetricUnit::kBytes, |
184 | | "Bytes sent by yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests"); |
185 | | |
186 | | METRIC_DEFINE_counter( |
187 | | server, proxy_response_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion, |
188 | | "Bytes received in response to yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
189 | | yb::MetricUnit::kBytes, |
190 | | "Bytes received in response to yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests"); |
191 | | |
192 | | METRIC_DEFINE_counter( |
193 | | server, proxy_request_bytes_yb_master_MasterCluster_IsLoadBalanced, |
194 | | "Bytes sent by yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
195 | | yb::MetricUnit::kBytes, |
196 | | "Bytes sent by yb.master.MasterCluster.IsLoadBalanced() RPC requests"); |
197 | | |
198 | | METRIC_DEFINE_counter( |
199 | | server, proxy_response_bytes_yb_master_MasterCluster_IsLoadBalanced, |
200 | | "Bytes received in response to yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
201 | | yb::MetricUnit::kBytes, |
202 | | "Bytes received in response to yb.master.MasterCluster.IsLoadBalanced() RPC requests"); |
203 | | |
204 | | METRIC_DEFINE_counter( |
205 | | server, proxy_request_bytes_yb_master_MasterCluster_IsLoadBalancerIdle, |
206 | | "Bytes sent by yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
207 | | yb::MetricUnit::kBytes, |
208 | | "Bytes sent by yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests"); |
209 | | |
210 | | METRIC_DEFINE_counter( |
211 | | server, proxy_response_bytes_yb_master_MasterCluster_IsLoadBalancerIdle, |
212 | | "Bytes received in response to yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
213 | | yb::MetricUnit::kBytes, |
214 | | "Bytes received in response to yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests"); |
215 | | |
216 | | METRIC_DEFINE_counter( |
217 | | server, proxy_request_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly, |
218 | | "Bytes sent by yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
219 | | yb::MetricUnit::kBytes, |
220 | | "Bytes sent by yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests"); |
221 | | |
222 | | METRIC_DEFINE_counter( |
223 | | server, proxy_response_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly, |
224 | | "Bytes received in response to yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
225 | | yb::MetricUnit::kBytes, |
226 | | "Bytes received in response to yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests"); |
227 | | |
228 | | namespace yb { |
229 | | namespace master { |
230 | | |
231 | | |
232 | | namespace { |
233 | | |
234 | | const std::string kFullMasterClusterName = "yb.master.MasterCluster"; |
235 | | |
236 | 35.4k | ::yb::rpc::ProxyMetricsPtr CreateMasterClusterMetrics(const scoped_refptr<MetricEntity>& entity) { |
237 | 35.4k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<18>>(); |
238 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kListTabletServers)] = { |
239 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ListTabletServers.Instantiate(entity), |
240 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ListTabletServers.Instantiate(entity) |
241 | 35.4k | }; |
242 | | |
243 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kListLiveTabletServers)] = { |
244 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ListLiveTabletServers.Instantiate(entity), |
245 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ListLiveTabletServers.Instantiate(entity) |
246 | 35.4k | }; |
247 | | |
248 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kListMasters)] = { |
249 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ListMasters.Instantiate(entity), |
250 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ListMasters.Instantiate(entity) |
251 | 35.4k | }; |
252 | | |
253 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)] = { |
254 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ListMasterRaftPeers.Instantiate(entity), |
255 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ListMasterRaftPeers.Instantiate(entity) |
256 | 35.4k | }; |
257 | | |
258 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kGetMasterRegistration)] = { |
259 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_GetMasterRegistration.Instantiate(entity), |
260 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_GetMasterRegistration.Instantiate(entity) |
261 | 35.4k | }; |
262 | | |
263 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)] = { |
264 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady.Instantiate(entity), |
265 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady.Instantiate(entity) |
266 | 35.4k | }; |
267 | | |
268 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kDumpState)] = { |
269 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_DumpState.Instantiate(entity), |
270 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_DumpState.Instantiate(entity) |
271 | 35.4k | }; |
272 | | |
273 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)] = { |
274 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ChangeLoadBalancerState.Instantiate(entity), |
275 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ChangeLoadBalancerState.Instantiate(entity) |
276 | 35.4k | }; |
277 | | |
278 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)] = { |
279 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_GetLoadBalancerState.Instantiate(entity), |
280 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_GetLoadBalancerState.Instantiate(entity) |
281 | 35.4k | }; |
282 | | |
283 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)] = { |
284 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_RemovedMasterUpdate.Instantiate(entity), |
285 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_RemovedMasterUpdate.Instantiate(entity) |
286 | 35.4k | }; |
287 | | |
288 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kSetPreferredZones)] = { |
289 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_SetPreferredZones.Instantiate(entity), |
290 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_SetPreferredZones.Instantiate(entity) |
291 | 35.4k | }; |
292 | | |
293 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)] = { |
294 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_GetMasterClusterConfig.Instantiate(entity), |
295 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_GetMasterClusterConfig.Instantiate(entity) |
296 | 35.4k | }; |
297 | | |
298 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)] = { |
299 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig.Instantiate(entity), |
300 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig.Instantiate(entity) |
301 | 35.4k | }; |
302 | | |
303 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)] = { |
304 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_GetLoadMoveCompletion.Instantiate(entity), |
305 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_GetLoadMoveCompletion.Instantiate(entity) |
306 | 35.4k | }; |
307 | | |
308 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)] = { |
309 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion.Instantiate(entity), |
310 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion.Instantiate(entity) |
311 | 35.4k | }; |
312 | | |
313 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kIsLoadBalanced)] = { |
314 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_IsLoadBalanced.Instantiate(entity), |
315 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_IsLoadBalanced.Instantiate(entity) |
316 | 35.4k | }; |
317 | | |
318 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)] = { |
319 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_IsLoadBalancerIdle.Instantiate(entity), |
320 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_IsLoadBalancerIdle.Instantiate(entity) |
321 | 35.4k | }; |
322 | | |
323 | 35.4k | result->value[to_underlying(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)] = { |
324 | 35.4k | METRIC_proxy_request_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly.Instantiate(entity), |
325 | 35.4k | METRIC_proxy_response_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly.Instantiate(entity) |
326 | 35.4k | }; |
327 | | |
328 | 35.4k | return result; |
329 | 35.4k | } |
330 | | |
331 | | |
332 | | } // namespace |
333 | | |
334 | | MasterClusterProxy::MasterClusterProxy( |
335 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
336 | | const ::yb::rpc::Protocol* protocol, |
337 | | const ::yb::MonoDelta& resolve_cache_timeout) |
338 | | : ProxyBase(kFullMasterClusterName, &CreateMasterClusterMetrics, |
339 | 4.61M | cache, remote, protocol, resolve_cache_timeout) {} |
340 | | |
341 | | ::yb::Status MasterClusterProxy::ListTabletServers( |
342 | 41.8k | const ::yb::master::ListTabletServersRequestPB &req, ::yb::master::ListTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
343 | 41.8k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListTabletServers"); |
344 | 41.8k | return proxy().SyncRequest( |
345 | 41.8k | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers)), req, resp, controller); |
346 | 41.8k | } |
347 | | |
348 | | void MasterClusterProxy::ListTabletServersAsync( |
349 | | const ::yb::master::ListTabletServersRequestPB &req, ::yb::master::ListTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller, |
350 | 2.86k | ::yb::rpc::ResponseCallback callback) const { |
351 | 2.86k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListTabletServers"); |
352 | 2.86k | proxy().AsyncRequest( |
353 | 2.86k | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers)), req, resp, controller, std::move(callback)); |
354 | 2.86k | } |
355 | | |
356 | | ::yb::Status MasterClusterProxy::ListLiveTabletServers( |
357 | 0 | const ::yb::master::ListLiveTabletServersRequestPB &req, ::yb::master::ListLiveTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
358 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListLiveTabletServers"); |
359 | 0 | return proxy().SyncRequest( |
360 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers)), req, resp, controller); |
361 | 0 | } |
362 | | |
363 | | void MasterClusterProxy::ListLiveTabletServersAsync( |
364 | | const ::yb::master::ListLiveTabletServersRequestPB &req, ::yb::master::ListLiveTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller, |
365 | 2 | ::yb::rpc::ResponseCallback callback) const { |
366 | 2 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListLiveTabletServers"); |
367 | 2 | proxy().AsyncRequest( |
368 | 2 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers)), req, resp, controller, std::move(callback)); |
369 | 2 | } |
370 | | |
371 | | ::yb::Status MasterClusterProxy::ListMasters( |
372 | 23 | const ::yb::master::ListMastersRequestPB &req, ::yb::master::ListMastersResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
373 | 23 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListMasters"); |
374 | 23 | return proxy().SyncRequest( |
375 | 23 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters)), req, resp, controller); |
376 | 23 | } |
377 | | |
378 | | void MasterClusterProxy::ListMastersAsync( |
379 | | const ::yb::master::ListMastersRequestPB &req, ::yb::master::ListMastersResponsePB *resp, ::yb::rpc::RpcController *controller, |
380 | 0 | ::yb::rpc::ResponseCallback callback) const { |
381 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListMasters"); |
382 | 0 | proxy().AsyncRequest( |
383 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters)), req, resp, controller, std::move(callback)); |
384 | 0 | } |
385 | | |
386 | | ::yb::Status MasterClusterProxy::ListMasterRaftPeers( |
387 | 0 | const ::yb::master::ListMasterRaftPeersRequestPB &req, ::yb::master::ListMasterRaftPeersResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
388 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListMasterRaftPeers"); |
389 | 0 | return proxy().SyncRequest( |
390 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)), req, resp, controller); |
391 | 0 | } |
392 | | |
393 | | void MasterClusterProxy::ListMasterRaftPeersAsync( |
394 | | const ::yb::master::ListMasterRaftPeersRequestPB &req, ::yb::master::ListMasterRaftPeersResponsePB *resp, ::yb::rpc::RpcController *controller, |
395 | 0 | ::yb::rpc::ResponseCallback callback) const { |
396 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListMasterRaftPeers"); |
397 | 0 | proxy().AsyncRequest( |
398 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)), req, resp, controller, std::move(callback)); |
399 | 0 | } |
400 | | |
401 | | ::yb::Status MasterClusterProxy::GetMasterRegistration( |
402 | 0 | const ::yb::master::GetMasterRegistrationRequestPB &req, ::yb::master::GetMasterRegistrationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
403 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetMasterRegistration"); |
404 | 0 | return proxy().SyncRequest( |
405 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration)), req, resp, controller); |
406 | 0 | } |
407 | | |
408 | | void MasterClusterProxy::GetMasterRegistrationAsync( |
409 | | const ::yb::master::GetMasterRegistrationRequestPB &req, ::yb::master::GetMasterRegistrationResponsePB *resp, ::yb::rpc::RpcController *controller, |
410 | 4.54M | ::yb::rpc::ResponseCallback callback) const { |
411 | 4.54M | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetMasterRegistration"); |
412 | 4.54M | proxy().AsyncRequest( |
413 | 4.54M | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration)), req, resp, controller, std::move(callback)); |
414 | 4.54M | } |
415 | | |
416 | | ::yb::Status MasterClusterProxy::IsMasterLeaderServiceReady( |
417 | 24 | const ::yb::master::IsMasterLeaderReadyRequestPB &req, ::yb::master::IsMasterLeaderReadyResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
418 | 24 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsMasterLeaderServiceReady"); |
419 | 24 | return proxy().SyncRequest( |
420 | 24 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)), req, resp, controller); |
421 | 24 | } |
422 | | |
423 | | void MasterClusterProxy::IsMasterLeaderServiceReadyAsync( |
424 | | const ::yb::master::IsMasterLeaderReadyRequestPB &req, ::yb::master::IsMasterLeaderReadyResponsePB *resp, ::yb::rpc::RpcController *controller, |
425 | 0 | ::yb::rpc::ResponseCallback callback) const { |
426 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsMasterLeaderServiceReady"); |
427 | 0 | proxy().AsyncRequest( |
428 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)), req, resp, controller, std::move(callback)); |
429 | 0 | } |
430 | | |
431 | | ::yb::Status MasterClusterProxy::DumpState( |
432 | 0 | const ::yb::master::DumpMasterStateRequestPB &req, ::yb::master::DumpMasterStateResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
433 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DumpState"); |
434 | 0 | return proxy().SyncRequest( |
435 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState)), req, resp, controller); |
436 | 0 | } |
437 | | |
438 | | void MasterClusterProxy::DumpStateAsync( |
439 | | const ::yb::master::DumpMasterStateRequestPB &req, ::yb::master::DumpMasterStateResponsePB *resp, ::yb::rpc::RpcController *controller, |
440 | 0 | ::yb::rpc::ResponseCallback callback) const { |
441 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DumpState"); |
442 | 0 | proxy().AsyncRequest( |
443 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState)), req, resp, controller, std::move(callback)); |
444 | 0 | } |
445 | | |
446 | | ::yb::Status MasterClusterProxy::ChangeLoadBalancerState( |
447 | 0 | const ::yb::master::ChangeLoadBalancerStateRequestPB &req, ::yb::master::ChangeLoadBalancerStateResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
448 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ChangeLoadBalancerState"); |
449 | 0 | return proxy().SyncRequest( |
450 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)), req, resp, controller); |
451 | 0 | } |
452 | | |
453 | | void MasterClusterProxy::ChangeLoadBalancerStateAsync( |
454 | | const ::yb::master::ChangeLoadBalancerStateRequestPB &req, ::yb::master::ChangeLoadBalancerStateResponsePB *resp, ::yb::rpc::RpcController *controller, |
455 | 0 | ::yb::rpc::ResponseCallback callback) const { |
456 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ChangeLoadBalancerState"); |
457 | 0 | proxy().AsyncRequest( |
458 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)), req, resp, controller, std::move(callback)); |
459 | 0 | } |
460 | | |
461 | | ::yb::Status MasterClusterProxy::GetLoadBalancerState( |
462 | 0 | const ::yb::master::GetLoadBalancerStateRequestPB &req, ::yb::master::GetLoadBalancerStateResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
463 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLoadBalancerState"); |
464 | 0 | return proxy().SyncRequest( |
465 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)), req, resp, controller); |
466 | 0 | } |
467 | | |
468 | | void MasterClusterProxy::GetLoadBalancerStateAsync( |
469 | | const ::yb::master::GetLoadBalancerStateRequestPB &req, ::yb::master::GetLoadBalancerStateResponsePB *resp, ::yb::rpc::RpcController *controller, |
470 | 0 | ::yb::rpc::ResponseCallback callback) const { |
471 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLoadBalancerState"); |
472 | 0 | proxy().AsyncRequest( |
473 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)), req, resp, controller, std::move(callback)); |
474 | 0 | } |
475 | | |
476 | | ::yb::Status MasterClusterProxy::RemovedMasterUpdate( |
477 | 32 | const ::yb::master::RemovedMasterUpdateRequestPB &req, ::yb::master::RemovedMasterUpdateResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
478 | 32 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RemovedMasterUpdate"); |
479 | 32 | return proxy().SyncRequest( |
480 | 32 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)), req, resp, controller); |
481 | 32 | } |
482 | | |
483 | | void MasterClusterProxy::RemovedMasterUpdateAsync( |
484 | | const ::yb::master::RemovedMasterUpdateRequestPB &req, ::yb::master::RemovedMasterUpdateResponsePB *resp, ::yb::rpc::RpcController *controller, |
485 | 0 | ::yb::rpc::ResponseCallback callback) const { |
486 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RemovedMasterUpdate"); |
487 | 0 | proxy().AsyncRequest( |
488 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)), req, resp, controller, std::move(callback)); |
489 | 0 | } |
490 | | |
491 | | ::yb::Status MasterClusterProxy::SetPreferredZones( |
492 | 3 | const ::yb::master::SetPreferredZonesRequestPB &req, ::yb::master::SetPreferredZonesResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
493 | 3 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetPreferredZones"); |
494 | 3 | return proxy().SyncRequest( |
495 | 3 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones)), req, resp, controller); |
496 | 3 | } |
497 | | |
498 | | void MasterClusterProxy::SetPreferredZonesAsync( |
499 | | const ::yb::master::SetPreferredZonesRequestPB &req, ::yb::master::SetPreferredZonesResponsePB *resp, ::yb::rpc::RpcController *controller, |
500 | 0 | ::yb::rpc::ResponseCallback callback) const { |
501 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetPreferredZones"); |
502 | 0 | proxy().AsyncRequest( |
503 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones)), req, resp, controller, std::move(callback)); |
504 | 0 | } |
505 | | |
506 | | ::yb::Status MasterClusterProxy::GetMasterClusterConfig( |
507 | 36 | const ::yb::master::GetMasterClusterConfigRequestPB &req, ::yb::master::GetMasterClusterConfigResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
508 | 36 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetMasterClusterConfig"); |
509 | 36 | return proxy().SyncRequest( |
510 | 36 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)), req, resp, controller); |
511 | 36 | } |
512 | | |
513 | | void MasterClusterProxy::GetMasterClusterConfigAsync( |
514 | | const ::yb::master::GetMasterClusterConfigRequestPB &req, ::yb::master::GetMasterClusterConfigResponsePB *resp, ::yb::rpc::RpcController *controller, |
515 | 6 | ::yb::rpc::ResponseCallback callback) const { |
516 | 6 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetMasterClusterConfig"); |
517 | 6 | proxy().AsyncRequest( |
518 | 6 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)), req, resp, controller, std::move(callback)); |
519 | 6 | } |
520 | | |
521 | | ::yb::Status MasterClusterProxy::ChangeMasterClusterConfig( |
522 | 30 | const ::yb::master::ChangeMasterClusterConfigRequestPB &req, ::yb::master::ChangeMasterClusterConfigResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
523 | 30 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ChangeMasterClusterConfig"); |
524 | 30 | return proxy().SyncRequest( |
525 | 30 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)), req, resp, controller); |
526 | 30 | } |
527 | | |
528 | | void MasterClusterProxy::ChangeMasterClusterConfigAsync( |
529 | | const ::yb::master::ChangeMasterClusterConfigRequestPB &req, ::yb::master::ChangeMasterClusterConfigResponsePB *resp, ::yb::rpc::RpcController *controller, |
530 | 4 | ::yb::rpc::ResponseCallback callback) const { |
531 | 4 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ChangeMasterClusterConfig"); |
532 | 4 | proxy().AsyncRequest( |
533 | 4 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)), req, resp, controller, std::move(callback)); |
534 | 4 | } |
535 | | |
536 | | ::yb::Status MasterClusterProxy::GetLoadMoveCompletion( |
537 | 2 | const ::yb::master::GetLoadMovePercentRequestPB &req, ::yb::master::GetLoadMovePercentResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
538 | 2 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLoadMoveCompletion"); |
539 | 2 | return proxy().SyncRequest( |
540 | 2 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)), req, resp, controller); |
541 | 2 | } |
542 | | |
543 | | void MasterClusterProxy::GetLoadMoveCompletionAsync( |
544 | | const ::yb::master::GetLoadMovePercentRequestPB &req, ::yb::master::GetLoadMovePercentResponsePB *resp, ::yb::rpc::RpcController *controller, |
545 | 0 | ::yb::rpc::ResponseCallback callback) const { |
546 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLoadMoveCompletion"); |
547 | 0 | proxy().AsyncRequest( |
548 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)), req, resp, controller, std::move(callback)); |
549 | 0 | } |
550 | | |
551 | | ::yb::Status MasterClusterProxy::GetLeaderBlacklistCompletion( |
552 | 0 | const ::yb::master::GetLeaderBlacklistPercentRequestPB &req, ::yb::master::GetLoadMovePercentResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
553 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLeaderBlacklistCompletion"); |
554 | 0 | return proxy().SyncRequest( |
555 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)), req, resp, controller); |
556 | 0 | } |
557 | | |
558 | | void MasterClusterProxy::GetLeaderBlacklistCompletionAsync( |
559 | | const ::yb::master::GetLeaderBlacklistPercentRequestPB &req, ::yb::master::GetLoadMovePercentResponsePB *resp, ::yb::rpc::RpcController *controller, |
560 | 0 | ::yb::rpc::ResponseCallback callback) const { |
561 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetLeaderBlacklistCompletion"); |
562 | 0 | proxy().AsyncRequest( |
563 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)), req, resp, controller, std::move(callback)); |
564 | 0 | } |
565 | | |
566 | | ::yb::Status MasterClusterProxy::IsLoadBalanced( |
567 | 0 | const ::yb::master::IsLoadBalancedRequestPB &req, ::yb::master::IsLoadBalancedResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
568 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsLoadBalanced"); |
569 | 0 | return proxy().SyncRequest( |
570 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced)), req, resp, controller); |
571 | 0 | } |
572 | | |
573 | | void MasterClusterProxy::IsLoadBalancedAsync( |
574 | | const ::yb::master::IsLoadBalancedRequestPB &req, ::yb::master::IsLoadBalancedResponsePB *resp, ::yb::rpc::RpcController *controller, |
575 | 178 | ::yb::rpc::ResponseCallback callback) const { |
576 | 178 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsLoadBalanced"); |
577 | 178 | proxy().AsyncRequest( |
578 | 178 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced)), req, resp, controller, std::move(callback)); |
579 | 178 | } |
580 | | |
581 | | ::yb::Status MasterClusterProxy::IsLoadBalancerIdle( |
582 | 0 | const ::yb::master::IsLoadBalancerIdleRequestPB &req, ::yb::master::IsLoadBalancerIdleResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
583 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsLoadBalancerIdle"); |
584 | 0 | return proxy().SyncRequest( |
585 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)), req, resp, controller); |
586 | 0 | } |
587 | | |
588 | | void MasterClusterProxy::IsLoadBalancerIdleAsync( |
589 | | const ::yb::master::IsLoadBalancerIdleRequestPB &req, ::yb::master::IsLoadBalancerIdleResponsePB *resp, ::yb::rpc::RpcController *controller, |
590 | 2.27k | ::yb::rpc::ResponseCallback callback) const { |
591 | 2.27k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsLoadBalancerIdle"); |
592 | 2.27k | proxy().AsyncRequest( |
593 | 2.27k | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)), req, resp, controller, std::move(callback)); |
594 | 2.27k | } |
595 | | |
596 | | ::yb::Status MasterClusterProxy::AreLeadersOnPreferredOnly( |
597 | 115 | const ::yb::master::AreLeadersOnPreferredOnlyRequestPB &req, ::yb::master::AreLeadersOnPreferredOnlyResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
598 | 115 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AreLeadersOnPreferredOnly"); |
599 | 115 | return proxy().SyncRequest( |
600 | 115 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)), req, resp, controller); |
601 | 115 | } |
602 | | |
603 | | void MasterClusterProxy::AreLeadersOnPreferredOnlyAsync( |
604 | | const ::yb::master::AreLeadersOnPreferredOnlyRequestPB &req, ::yb::master::AreLeadersOnPreferredOnlyResponsePB *resp, ::yb::rpc::RpcController *controller, |
605 | 0 | ::yb::rpc::ResponseCallback callback) const { |
606 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AreLeadersOnPreferredOnly"); |
607 | 0 | proxy().AsyncRequest( |
608 | 0 | &method, metrics<18>(static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)), req, resp, controller, std::move(callback)); |
609 | 0 | } |
610 | | |
611 | | } // namespace master |
612 | | } // namespace yb |