YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/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