/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_cluster.service.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.pb.h" |
4 | | #include "yb/master/master_cluster.service.h" |
5 | | |
6 | | #include <glog/logging.h> |
7 | | |
8 | | #include "yb/rpc/inbound_call.h" |
9 | | #include "yb/rpc/local_call.h" |
10 | | #include "yb/rpc/remote_method.h" |
11 | | #include "yb/rpc/rpc_context.h" |
12 | | #include "yb/rpc/rpc_service.h" |
13 | | #include "yb/rpc/service_if.h" |
14 | | #include "yb/util/metrics.h" |
15 | | |
16 | | METRIC_DEFINE_counter( |
17 | | server, service_request_bytes_yb_master_MasterCluster_ListTabletServers, |
18 | | "Bytes received by yb.master.MasterCluster.ListTabletServers() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.master.MasterCluster.ListTabletServers() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_master_MasterCluster_ListTabletServers, |
24 | | "Bytes sent in response to yb.master.MasterCluster.ListTabletServers() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.master.MasterCluster.ListTabletServers() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_master_MasterCluster_ListTabletServers, |
30 | | "Microseconds spent handling yb.master.MasterCluster.ListTabletServers() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.master.MasterCluster.ListTabletServers() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_master_MasterCluster_ListLiveTabletServers, |
37 | | "Bytes received by yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.master.MasterCluster.ListLiveTabletServers() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_master_MasterCluster_ListLiveTabletServers, |
43 | | "Bytes sent in response to yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.master.MasterCluster.ListLiveTabletServers() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_master_MasterCluster_ListLiveTabletServers, |
49 | | "Microseconds spent handling yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.master.MasterCluster.ListLiveTabletServers() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, service_request_bytes_yb_master_MasterCluster_ListMasters, |
56 | | "Bytes received by yb.master.MasterCluster.ListMasters() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received by yb.master.MasterCluster.ListMasters() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, service_response_bytes_yb_master_MasterCluster_ListMasters, |
62 | | "Bytes sent in response to yb.master.MasterCluster.ListMasters() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent in response to yb.master.MasterCluster.ListMasters() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_histogram_with_percentiles( |
67 | | server, handler_latency_yb_master_MasterCluster_ListMasters, |
68 | | "Microseconds spent handling yb.master.MasterCluster.ListMasters() RPC requests", |
69 | | yb::MetricUnit::kMicroseconds, |
70 | | "Microseconds spent handling yb.master.MasterCluster.ListMasters() RPC requests", |
71 | | 60000000LU, 2); |
72 | | |
73 | | METRIC_DEFINE_counter( |
74 | | server, service_request_bytes_yb_master_MasterCluster_ListMasterRaftPeers, |
75 | | "Bytes received by yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
76 | | yb::MetricUnit::kBytes, |
77 | | "Bytes received by yb.master.MasterCluster.ListMasterRaftPeers() RPC requests"); |
78 | | |
79 | | METRIC_DEFINE_counter( |
80 | | server, service_response_bytes_yb_master_MasterCluster_ListMasterRaftPeers, |
81 | | "Bytes sent in response to yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
82 | | yb::MetricUnit::kBytes, |
83 | | "Bytes sent in response to yb.master.MasterCluster.ListMasterRaftPeers() RPC requests"); |
84 | | |
85 | | METRIC_DEFINE_histogram_with_percentiles( |
86 | | server, handler_latency_yb_master_MasterCluster_ListMasterRaftPeers, |
87 | | "Microseconds spent handling yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
88 | | yb::MetricUnit::kMicroseconds, |
89 | | "Microseconds spent handling yb.master.MasterCluster.ListMasterRaftPeers() RPC requests", |
90 | | 60000000LU, 2); |
91 | | |
92 | | METRIC_DEFINE_counter( |
93 | | server, service_request_bytes_yb_master_MasterCluster_GetMasterRegistration, |
94 | | "Bytes received by yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
95 | | yb::MetricUnit::kBytes, |
96 | | "Bytes received by yb.master.MasterCluster.GetMasterRegistration() RPC requests"); |
97 | | |
98 | | METRIC_DEFINE_counter( |
99 | | server, service_response_bytes_yb_master_MasterCluster_GetMasterRegistration, |
100 | | "Bytes sent in response to yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
101 | | yb::MetricUnit::kBytes, |
102 | | "Bytes sent in response to yb.master.MasterCluster.GetMasterRegistration() RPC requests"); |
103 | | |
104 | | METRIC_DEFINE_histogram_with_percentiles( |
105 | | server, handler_latency_yb_master_MasterCluster_GetMasterRegistration, |
106 | | "Microseconds spent handling yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
107 | | yb::MetricUnit::kMicroseconds, |
108 | | "Microseconds spent handling yb.master.MasterCluster.GetMasterRegistration() RPC requests", |
109 | | 60000000LU, 2); |
110 | | |
111 | | METRIC_DEFINE_counter( |
112 | | server, service_request_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady, |
113 | | "Bytes received by yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
114 | | yb::MetricUnit::kBytes, |
115 | | "Bytes received by yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests"); |
116 | | |
117 | | METRIC_DEFINE_counter( |
118 | | server, service_response_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady, |
119 | | "Bytes sent in response to yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
120 | | yb::MetricUnit::kBytes, |
121 | | "Bytes sent in response to yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests"); |
122 | | |
123 | | METRIC_DEFINE_histogram_with_percentiles( |
124 | | server, handler_latency_yb_master_MasterCluster_IsMasterLeaderServiceReady, |
125 | | "Microseconds spent handling yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
126 | | yb::MetricUnit::kMicroseconds, |
127 | | "Microseconds spent handling yb.master.MasterCluster.IsMasterLeaderServiceReady() RPC requests", |
128 | | 60000000LU, 2); |
129 | | |
130 | | METRIC_DEFINE_counter( |
131 | | server, service_request_bytes_yb_master_MasterCluster_DumpState, |
132 | | "Bytes received by yb.master.MasterCluster.DumpState() RPC requests", |
133 | | yb::MetricUnit::kBytes, |
134 | | "Bytes received by yb.master.MasterCluster.DumpState() RPC requests"); |
135 | | |
136 | | METRIC_DEFINE_counter( |
137 | | server, service_response_bytes_yb_master_MasterCluster_DumpState, |
138 | | "Bytes sent in response to yb.master.MasterCluster.DumpState() RPC requests", |
139 | | yb::MetricUnit::kBytes, |
140 | | "Bytes sent in response to yb.master.MasterCluster.DumpState() RPC requests"); |
141 | | |
142 | | METRIC_DEFINE_histogram_with_percentiles( |
143 | | server, handler_latency_yb_master_MasterCluster_DumpState, |
144 | | "Microseconds spent handling yb.master.MasterCluster.DumpState() RPC requests", |
145 | | yb::MetricUnit::kMicroseconds, |
146 | | "Microseconds spent handling yb.master.MasterCluster.DumpState() RPC requests", |
147 | | 60000000LU, 2); |
148 | | |
149 | | METRIC_DEFINE_counter( |
150 | | server, service_request_bytes_yb_master_MasterCluster_ChangeLoadBalancerState, |
151 | | "Bytes received by yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
152 | | yb::MetricUnit::kBytes, |
153 | | "Bytes received by yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests"); |
154 | | |
155 | | METRIC_DEFINE_counter( |
156 | | server, service_response_bytes_yb_master_MasterCluster_ChangeLoadBalancerState, |
157 | | "Bytes sent in response to yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
158 | | yb::MetricUnit::kBytes, |
159 | | "Bytes sent in response to yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests"); |
160 | | |
161 | | METRIC_DEFINE_histogram_with_percentiles( |
162 | | server, handler_latency_yb_master_MasterCluster_ChangeLoadBalancerState, |
163 | | "Microseconds spent handling yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
164 | | yb::MetricUnit::kMicroseconds, |
165 | | "Microseconds spent handling yb.master.MasterCluster.ChangeLoadBalancerState() RPC requests", |
166 | | 60000000LU, 2); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, service_request_bytes_yb_master_MasterCluster_GetLoadBalancerState, |
170 | | "Bytes received by yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes received by yb.master.MasterCluster.GetLoadBalancerState() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, service_response_bytes_yb_master_MasterCluster_GetLoadBalancerState, |
176 | | "Bytes sent in response to yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes sent in response to yb.master.MasterCluster.GetLoadBalancerState() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_histogram_with_percentiles( |
181 | | server, handler_latency_yb_master_MasterCluster_GetLoadBalancerState, |
182 | | "Microseconds spent handling yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
183 | | yb::MetricUnit::kMicroseconds, |
184 | | "Microseconds spent handling yb.master.MasterCluster.GetLoadBalancerState() RPC requests", |
185 | | 60000000LU, 2); |
186 | | |
187 | | METRIC_DEFINE_counter( |
188 | | server, service_request_bytes_yb_master_MasterCluster_RemovedMasterUpdate, |
189 | | "Bytes received by yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
190 | | yb::MetricUnit::kBytes, |
191 | | "Bytes received by yb.master.MasterCluster.RemovedMasterUpdate() RPC requests"); |
192 | | |
193 | | METRIC_DEFINE_counter( |
194 | | server, service_response_bytes_yb_master_MasterCluster_RemovedMasterUpdate, |
195 | | "Bytes sent in response to yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
196 | | yb::MetricUnit::kBytes, |
197 | | "Bytes sent in response to yb.master.MasterCluster.RemovedMasterUpdate() RPC requests"); |
198 | | |
199 | | METRIC_DEFINE_histogram_with_percentiles( |
200 | | server, handler_latency_yb_master_MasterCluster_RemovedMasterUpdate, |
201 | | "Microseconds spent handling yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
202 | | yb::MetricUnit::kMicroseconds, |
203 | | "Microseconds spent handling yb.master.MasterCluster.RemovedMasterUpdate() RPC requests", |
204 | | 60000000LU, 2); |
205 | | |
206 | | METRIC_DEFINE_counter( |
207 | | server, service_request_bytes_yb_master_MasterCluster_SetPreferredZones, |
208 | | "Bytes received by yb.master.MasterCluster.SetPreferredZones() RPC requests", |
209 | | yb::MetricUnit::kBytes, |
210 | | "Bytes received by yb.master.MasterCluster.SetPreferredZones() RPC requests"); |
211 | | |
212 | | METRIC_DEFINE_counter( |
213 | | server, service_response_bytes_yb_master_MasterCluster_SetPreferredZones, |
214 | | "Bytes sent in response to yb.master.MasterCluster.SetPreferredZones() RPC requests", |
215 | | yb::MetricUnit::kBytes, |
216 | | "Bytes sent in response to yb.master.MasterCluster.SetPreferredZones() RPC requests"); |
217 | | |
218 | | METRIC_DEFINE_histogram_with_percentiles( |
219 | | server, handler_latency_yb_master_MasterCluster_SetPreferredZones, |
220 | | "Microseconds spent handling yb.master.MasterCluster.SetPreferredZones() RPC requests", |
221 | | yb::MetricUnit::kMicroseconds, |
222 | | "Microseconds spent handling yb.master.MasterCluster.SetPreferredZones() RPC requests", |
223 | | 60000000LU, 2); |
224 | | |
225 | | METRIC_DEFINE_counter( |
226 | | server, service_request_bytes_yb_master_MasterCluster_GetMasterClusterConfig, |
227 | | "Bytes received by yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
228 | | yb::MetricUnit::kBytes, |
229 | | "Bytes received by yb.master.MasterCluster.GetMasterClusterConfig() RPC requests"); |
230 | | |
231 | | METRIC_DEFINE_counter( |
232 | | server, service_response_bytes_yb_master_MasterCluster_GetMasterClusterConfig, |
233 | | "Bytes sent in response to yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
234 | | yb::MetricUnit::kBytes, |
235 | | "Bytes sent in response to yb.master.MasterCluster.GetMasterClusterConfig() RPC requests"); |
236 | | |
237 | | METRIC_DEFINE_histogram_with_percentiles( |
238 | | server, handler_latency_yb_master_MasterCluster_GetMasterClusterConfig, |
239 | | "Microseconds spent handling yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
240 | | yb::MetricUnit::kMicroseconds, |
241 | | "Microseconds spent handling yb.master.MasterCluster.GetMasterClusterConfig() RPC requests", |
242 | | 60000000LU, 2); |
243 | | |
244 | | METRIC_DEFINE_counter( |
245 | | server, service_request_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig, |
246 | | "Bytes received by yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
247 | | yb::MetricUnit::kBytes, |
248 | | "Bytes received by yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests"); |
249 | | |
250 | | METRIC_DEFINE_counter( |
251 | | server, service_response_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig, |
252 | | "Bytes sent in response to yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
253 | | yb::MetricUnit::kBytes, |
254 | | "Bytes sent in response to yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests"); |
255 | | |
256 | | METRIC_DEFINE_histogram_with_percentiles( |
257 | | server, handler_latency_yb_master_MasterCluster_ChangeMasterClusterConfig, |
258 | | "Microseconds spent handling yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
259 | | yb::MetricUnit::kMicroseconds, |
260 | | "Microseconds spent handling yb.master.MasterCluster.ChangeMasterClusterConfig() RPC requests", |
261 | | 60000000LU, 2); |
262 | | |
263 | | METRIC_DEFINE_counter( |
264 | | server, service_request_bytes_yb_master_MasterCluster_GetLoadMoveCompletion, |
265 | | "Bytes received by yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
266 | | yb::MetricUnit::kBytes, |
267 | | "Bytes received by yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests"); |
268 | | |
269 | | METRIC_DEFINE_counter( |
270 | | server, service_response_bytes_yb_master_MasterCluster_GetLoadMoveCompletion, |
271 | | "Bytes sent in response to yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
272 | | yb::MetricUnit::kBytes, |
273 | | "Bytes sent in response to yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests"); |
274 | | |
275 | | METRIC_DEFINE_histogram_with_percentiles( |
276 | | server, handler_latency_yb_master_MasterCluster_GetLoadMoveCompletion, |
277 | | "Microseconds spent handling yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
278 | | yb::MetricUnit::kMicroseconds, |
279 | | "Microseconds spent handling yb.master.MasterCluster.GetLoadMoveCompletion() RPC requests", |
280 | | 60000000LU, 2); |
281 | | |
282 | | METRIC_DEFINE_counter( |
283 | | server, service_request_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion, |
284 | | "Bytes received by yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
285 | | yb::MetricUnit::kBytes, |
286 | | "Bytes received by yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests"); |
287 | | |
288 | | METRIC_DEFINE_counter( |
289 | | server, service_response_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion, |
290 | | "Bytes sent in response to yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
291 | | yb::MetricUnit::kBytes, |
292 | | "Bytes sent in response to yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests"); |
293 | | |
294 | | METRIC_DEFINE_histogram_with_percentiles( |
295 | | server, handler_latency_yb_master_MasterCluster_GetLeaderBlacklistCompletion, |
296 | | "Microseconds spent handling yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
297 | | yb::MetricUnit::kMicroseconds, |
298 | | "Microseconds spent handling yb.master.MasterCluster.GetLeaderBlacklistCompletion() RPC requests", |
299 | | 60000000LU, 2); |
300 | | |
301 | | METRIC_DEFINE_counter( |
302 | | server, service_request_bytes_yb_master_MasterCluster_IsLoadBalanced, |
303 | | "Bytes received by yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
304 | | yb::MetricUnit::kBytes, |
305 | | "Bytes received by yb.master.MasterCluster.IsLoadBalanced() RPC requests"); |
306 | | |
307 | | METRIC_DEFINE_counter( |
308 | | server, service_response_bytes_yb_master_MasterCluster_IsLoadBalanced, |
309 | | "Bytes sent in response to yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
310 | | yb::MetricUnit::kBytes, |
311 | | "Bytes sent in response to yb.master.MasterCluster.IsLoadBalanced() RPC requests"); |
312 | | |
313 | | METRIC_DEFINE_histogram_with_percentiles( |
314 | | server, handler_latency_yb_master_MasterCluster_IsLoadBalanced, |
315 | | "Microseconds spent handling yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
316 | | yb::MetricUnit::kMicroseconds, |
317 | | "Microseconds spent handling yb.master.MasterCluster.IsLoadBalanced() RPC requests", |
318 | | 60000000LU, 2); |
319 | | |
320 | | METRIC_DEFINE_counter( |
321 | | server, service_request_bytes_yb_master_MasterCluster_IsLoadBalancerIdle, |
322 | | "Bytes received by yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
323 | | yb::MetricUnit::kBytes, |
324 | | "Bytes received by yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests"); |
325 | | |
326 | | METRIC_DEFINE_counter( |
327 | | server, service_response_bytes_yb_master_MasterCluster_IsLoadBalancerIdle, |
328 | | "Bytes sent in response to yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
329 | | yb::MetricUnit::kBytes, |
330 | | "Bytes sent in response to yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests"); |
331 | | |
332 | | METRIC_DEFINE_histogram_with_percentiles( |
333 | | server, handler_latency_yb_master_MasterCluster_IsLoadBalancerIdle, |
334 | | "Microseconds spent handling yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
335 | | yb::MetricUnit::kMicroseconds, |
336 | | "Microseconds spent handling yb.master.MasterCluster.IsLoadBalancerIdle() RPC requests", |
337 | | 60000000LU, 2); |
338 | | |
339 | | METRIC_DEFINE_counter( |
340 | | server, service_request_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly, |
341 | | "Bytes received by yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
342 | | yb::MetricUnit::kBytes, |
343 | | "Bytes received by yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests"); |
344 | | |
345 | | METRIC_DEFINE_counter( |
346 | | server, service_response_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly, |
347 | | "Bytes sent in response to yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
348 | | yb::MetricUnit::kBytes, |
349 | | "Bytes sent in response to yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests"); |
350 | | |
351 | | METRIC_DEFINE_histogram_with_percentiles( |
352 | | server, handler_latency_yb_master_MasterCluster_AreLeadersOnPreferredOnly, |
353 | | "Microseconds spent handling yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
354 | | yb::MetricUnit::kMicroseconds, |
355 | | "Microseconds spent handling yb.master.MasterCluster.AreLeadersOnPreferredOnly() RPC requests", |
356 | | 60000000LU, 2); |
357 | | |
358 | | namespace yb { |
359 | | namespace master { |
360 | | |
361 | 5.42k | MasterClusterIf::MasterClusterIf(const scoped_refptr<MetricEntity>& entity) { |
362 | 5.42k | InitMethods(entity); |
363 | 5.42k | } |
364 | | |
365 | 87 | MasterClusterIf::~MasterClusterIf() { |
366 | 87 | } |
367 | | |
368 | 5.42k | void MasterClusterIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
369 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers))); |
370 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers))); |
371 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters))); |
372 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers))); |
373 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration))); |
374 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady))); |
375 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState))); |
376 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState))); |
377 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState))); |
378 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate))); |
379 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones))); |
380 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig))); |
381 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig))); |
382 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion))); |
383 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion))); |
384 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced))); |
385 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle))); |
386 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly))); |
387 | 5.42k | } |
388 | | |
389 | 4.32M | void MasterClusterIf::Handle(::yb::rpc::InboundCallPtr call) { |
390 | 4.32M | auto index = call->method_index(); |
391 | 4.32M | methods_[index].handler(std::move(call)); |
392 | 4.32M | } |
393 | | |
394 | 17.3k | std::string MasterClusterIf::service_name() const { |
395 | 17.3k | return "yb.master.MasterService"; |
396 | 17.3k | } |
397 | 0 | std::string MasterClusterIf::static_service_name() { |
398 | 0 | return "yb.master.MasterService"; |
399 | 0 | } |
400 | | |
401 | 5.42k | void MasterClusterIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
402 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers)] = { |
403 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListTabletServers"), |
404 | 20.1k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
405 | 20.1k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListTabletServers)].metrics); |
406 | 20.1k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListTabletServersRequestPB, ::yb::master::ListTabletServersResponsePB>>( |
407 | 20.1k | std::move(call), [this](const ::yb::master::ListTabletServersRequestPB* req, ::yb::master::ListTabletServersResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
408 | 20.1k | ListTabletServers(req, resp, std::move(rpc_context)); |
409 | 20.1k | }); |
410 | 20.1k | }, |
411 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
412 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ListTabletServers.Instantiate(entity), |
413 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ListTabletServers.Instantiate(entity), |
414 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ListTabletServers.Instantiate(entity)) |
415 | 5.42k | }; |
416 | | |
417 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers)] = { |
418 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListLiveTabletServers"), |
419 | 2 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
420 | 2 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListLiveTabletServers)].metrics); |
421 | 2 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListLiveTabletServersRequestPB, ::yb::master::ListLiveTabletServersResponsePB>>( |
422 | 2 | std::move(call), [this](const ::yb::master::ListLiveTabletServersRequestPB* req, ::yb::master::ListLiveTabletServersResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
423 | 2 | ListLiveTabletServers(req, resp, std::move(rpc_context)); |
424 | 2 | }); |
425 | 2 | }, |
426 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
427 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ListLiveTabletServers.Instantiate(entity), |
428 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ListLiveTabletServers.Instantiate(entity), |
429 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ListLiveTabletServers.Instantiate(entity)) |
430 | 5.42k | }; |
431 | | |
432 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters)] = { |
433 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListMasters"), |
434 | 50 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
435 | 50 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasters)].metrics); |
436 | 50 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListMastersRequestPB, ::yb::master::ListMastersResponsePB>>( |
437 | 50 | std::move(call), [this](const ::yb::master::ListMastersRequestPB* req, ::yb::master::ListMastersResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
438 | 50 | ListMasters(req, resp, std::move(rpc_context)); |
439 | 50 | }); |
440 | 50 | }, |
441 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
442 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ListMasters.Instantiate(entity), |
443 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ListMasters.Instantiate(entity), |
444 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ListMasters.Instantiate(entity)) |
445 | 5.42k | }; |
446 | | |
447 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)] = { |
448 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListMasterRaftPeers"), |
449 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
450 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kListMasterRaftPeers)].metrics); |
451 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListMasterRaftPeersRequestPB, ::yb::master::ListMasterRaftPeersResponsePB>>( |
452 | 0 | std::move(call), [this](const ::yb::master::ListMasterRaftPeersRequestPB* req, ::yb::master::ListMasterRaftPeersResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
453 | 0 | ListMasterRaftPeers(req, resp, std::move(rpc_context)); |
454 | 0 | }); |
455 | 0 | }, |
456 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
457 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ListMasterRaftPeers.Instantiate(entity), |
458 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ListMasterRaftPeers.Instantiate(entity), |
459 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ListMasterRaftPeers.Instantiate(entity)) |
460 | 5.42k | }; |
461 | | |
462 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration)] = { |
463 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetMasterRegistration"), |
464 | 4.29M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
465 | 4.29M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterRegistration)].metrics); |
466 | 4.29M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetMasterRegistrationRequestPB, ::yb::master::GetMasterRegistrationResponsePB>>( |
467 | 4.29M | std::move(call), [this](const ::yb::master::GetMasterRegistrationRequestPB* req, ::yb::master::GetMasterRegistrationResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
468 | 4.29M | GetMasterRegistration(req, resp, std::move(rpc_context)); |
469 | 4.29M | }); |
470 | 4.29M | }, |
471 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
472 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_GetMasterRegistration.Instantiate(entity), |
473 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_GetMasterRegistration.Instantiate(entity), |
474 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_GetMasterRegistration.Instantiate(entity)) |
475 | 5.42k | }; |
476 | | |
477 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)] = { |
478 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsMasterLeaderServiceReady"), |
479 | 24 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
480 | 24 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsMasterLeaderServiceReady)].metrics); |
481 | 24 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsMasterLeaderReadyRequestPB, ::yb::master::IsMasterLeaderReadyResponsePB>>( |
482 | 24 | std::move(call), [this](const ::yb::master::IsMasterLeaderReadyRequestPB* req, ::yb::master::IsMasterLeaderReadyResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
483 | 24 | IsMasterLeaderServiceReady(req, resp, std::move(rpc_context)); |
484 | 24 | }); |
485 | 24 | }, |
486 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
487 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady.Instantiate(entity), |
488 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_IsMasterLeaderServiceReady.Instantiate(entity), |
489 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_IsMasterLeaderServiceReady.Instantiate(entity)) |
490 | 5.42k | }; |
491 | | |
492 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState)] = { |
493 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "DumpState"), |
494 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
495 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kDumpState)].metrics); |
496 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DumpMasterStateRequestPB, ::yb::master::DumpMasterStateResponsePB>>( |
497 | 0 | std::move(call), [this](const ::yb::master::DumpMasterStateRequestPB* req, ::yb::master::DumpMasterStateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
498 | 0 | DumpState(req, resp, std::move(rpc_context)); |
499 | 0 | }); |
500 | 0 | }, |
501 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
502 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_DumpState.Instantiate(entity), |
503 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_DumpState.Instantiate(entity), |
504 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_DumpState.Instantiate(entity)) |
505 | 5.42k | }; |
506 | | |
507 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)] = { |
508 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ChangeLoadBalancerState"), |
509 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
510 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeLoadBalancerState)].metrics); |
511 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ChangeLoadBalancerStateRequestPB, ::yb::master::ChangeLoadBalancerStateResponsePB>>( |
512 | 0 | std::move(call), [this](const ::yb::master::ChangeLoadBalancerStateRequestPB* req, ::yb::master::ChangeLoadBalancerStateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
513 | 0 | ChangeLoadBalancerState(req, resp, std::move(rpc_context)); |
514 | 0 | }); |
515 | 0 | }, |
516 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
517 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ChangeLoadBalancerState.Instantiate(entity), |
518 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ChangeLoadBalancerState.Instantiate(entity), |
519 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ChangeLoadBalancerState.Instantiate(entity)) |
520 | 5.42k | }; |
521 | | |
522 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)] = { |
523 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetLoadBalancerState"), |
524 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
525 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadBalancerState)].metrics); |
526 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetLoadBalancerStateRequestPB, ::yb::master::GetLoadBalancerStateResponsePB>>( |
527 | 0 | std::move(call), [this](const ::yb::master::GetLoadBalancerStateRequestPB* req, ::yb::master::GetLoadBalancerStateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
528 | 0 | GetLoadBalancerState(req, resp, std::move(rpc_context)); |
529 | 0 | }); |
530 | 0 | }, |
531 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
532 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_GetLoadBalancerState.Instantiate(entity), |
533 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_GetLoadBalancerState.Instantiate(entity), |
534 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_GetLoadBalancerState.Instantiate(entity)) |
535 | 5.42k | }; |
536 | | |
537 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)] = { |
538 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "RemovedMasterUpdate"), |
539 | 27 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
540 | 27 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kRemovedMasterUpdate)].metrics); |
541 | 27 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::RemovedMasterUpdateRequestPB, ::yb::master::RemovedMasterUpdateResponsePB>>( |
542 | 27 | std::move(call), [this](const ::yb::master::RemovedMasterUpdateRequestPB* req, ::yb::master::RemovedMasterUpdateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
543 | 27 | RemovedMasterUpdate(req, resp, std::move(rpc_context)); |
544 | 27 | }); |
545 | 27 | }, |
546 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
547 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_RemovedMasterUpdate.Instantiate(entity), |
548 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_RemovedMasterUpdate.Instantiate(entity), |
549 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_RemovedMasterUpdate.Instantiate(entity)) |
550 | 5.42k | }; |
551 | | |
552 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones)] = { |
553 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "SetPreferredZones"), |
554 | 3 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
555 | 3 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kSetPreferredZones)].metrics); |
556 | 3 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::SetPreferredZonesRequestPB, ::yb::master::SetPreferredZonesResponsePB>>( |
557 | 3 | std::move(call), [this](const ::yb::master::SetPreferredZonesRequestPB* req, ::yb::master::SetPreferredZonesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
558 | 3 | SetPreferredZones(req, resp, std::move(rpc_context)); |
559 | 3 | }); |
560 | 3 | }, |
561 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
562 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_SetPreferredZones.Instantiate(entity), |
563 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_SetPreferredZones.Instantiate(entity), |
564 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_SetPreferredZones.Instantiate(entity)) |
565 | 5.42k | }; |
566 | | |
567 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)] = { |
568 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetMasterClusterConfig"), |
569 | 206 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
570 | 206 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetMasterClusterConfig)].metrics); |
571 | 206 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetMasterClusterConfigRequestPB, ::yb::master::GetMasterClusterConfigResponsePB>>( |
572 | 206 | std::move(call), [this](const ::yb::master::GetMasterClusterConfigRequestPB* req, ::yb::master::GetMasterClusterConfigResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
573 | 206 | GetMasterClusterConfig(req, resp, std::move(rpc_context)); |
574 | 206 | }); |
575 | 206 | }, |
576 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
577 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_GetMasterClusterConfig.Instantiate(entity), |
578 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_GetMasterClusterConfig.Instantiate(entity), |
579 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_GetMasterClusterConfig.Instantiate(entity)) |
580 | 5.42k | }; |
581 | | |
582 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)] = { |
583 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ChangeMasterClusterConfig"), |
584 | 109 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
585 | 109 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kChangeMasterClusterConfig)].metrics); |
586 | 109 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ChangeMasterClusterConfigRequestPB, ::yb::master::ChangeMasterClusterConfigResponsePB>>( |
587 | 109 | std::move(call), [this](const ::yb::master::ChangeMasterClusterConfigRequestPB* req, ::yb::master::ChangeMasterClusterConfigResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
588 | 109 | ChangeMasterClusterConfig(req, resp, std::move(rpc_context)); |
589 | 109 | }); |
590 | 109 | }, |
591 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
592 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig.Instantiate(entity), |
593 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_ChangeMasterClusterConfig.Instantiate(entity), |
594 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_ChangeMasterClusterConfig.Instantiate(entity)) |
595 | 5.42k | }; |
596 | | |
597 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)] = { |
598 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetLoadMoveCompletion"), |
599 | 1.00k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
600 | 1.00k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLoadMoveCompletion)].metrics); |
601 | 1.00k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetLoadMovePercentRequestPB, ::yb::master::GetLoadMovePercentResponsePB>>( |
602 | 1.00k | std::move(call), [this](const ::yb::master::GetLoadMovePercentRequestPB* req, ::yb::master::GetLoadMovePercentResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
603 | 1.00k | GetLoadMoveCompletion(req, resp, std::move(rpc_context)); |
604 | 1.00k | }); |
605 | 1.00k | }, |
606 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
607 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_GetLoadMoveCompletion.Instantiate(entity), |
608 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_GetLoadMoveCompletion.Instantiate(entity), |
609 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_GetLoadMoveCompletion.Instantiate(entity)) |
610 | 5.42k | }; |
611 | | |
612 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)] = { |
613 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetLeaderBlacklistCompletion"), |
614 | 194 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
615 | 194 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kGetLeaderBlacklistCompletion)].metrics); |
616 | 194 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetLeaderBlacklistPercentRequestPB, ::yb::master::GetLoadMovePercentResponsePB>>( |
617 | 194 | std::move(call), [this](const ::yb::master::GetLeaderBlacklistPercentRequestPB* req, ::yb::master::GetLoadMovePercentResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
618 | 194 | GetLeaderBlacklistCompletion(req, resp, std::move(rpc_context)); |
619 | 194 | }); |
620 | 194 | }, |
621 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
622 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion.Instantiate(entity), |
623 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_GetLeaderBlacklistCompletion.Instantiate(entity), |
624 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_GetLeaderBlacklistCompletion.Instantiate(entity)) |
625 | 5.42k | }; |
626 | | |
627 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced)] = { |
628 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsLoadBalanced"), |
629 | 202 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
630 | 202 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalanced)].metrics); |
631 | 202 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsLoadBalancedRequestPB, ::yb::master::IsLoadBalancedResponsePB>>( |
632 | 202 | std::move(call), [this](const ::yb::master::IsLoadBalancedRequestPB* req, ::yb::master::IsLoadBalancedResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
633 | 202 | IsLoadBalanced(req, resp, std::move(rpc_context)); |
634 | 202 | }); |
635 | 202 | }, |
636 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
637 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_IsLoadBalanced.Instantiate(entity), |
638 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_IsLoadBalanced.Instantiate(entity), |
639 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_IsLoadBalanced.Instantiate(entity)) |
640 | 5.42k | }; |
641 | | |
642 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)] = { |
643 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsLoadBalancerIdle"), |
644 | 2.25k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
645 | 2.25k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kIsLoadBalancerIdle)].metrics); |
646 | 2.25k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsLoadBalancerIdleRequestPB, ::yb::master::IsLoadBalancerIdleResponsePB>>( |
647 | 2.25k | std::move(call), [this](const ::yb::master::IsLoadBalancerIdleRequestPB* req, ::yb::master::IsLoadBalancerIdleResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
648 | 2.25k | IsLoadBalancerIdle(req, resp, std::move(rpc_context)); |
649 | 2.25k | }); |
650 | 2.25k | }, |
651 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
652 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_IsLoadBalancerIdle.Instantiate(entity), |
653 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_IsLoadBalancerIdle.Instantiate(entity), |
654 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_IsLoadBalancerIdle.Instantiate(entity)) |
655 | 5.42k | }; |
656 | | |
657 | 5.42k | methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)] = { |
658 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "AreLeadersOnPreferredOnly"), |
659 | 153 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
660 | 153 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterClusterRpcMethodIndexes::kAreLeadersOnPreferredOnly)].metrics); |
661 | 153 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::AreLeadersOnPreferredOnlyRequestPB, ::yb::master::AreLeadersOnPreferredOnlyResponsePB>>( |
662 | 153 | std::move(call), [this](const ::yb::master::AreLeadersOnPreferredOnlyRequestPB* req, ::yb::master::AreLeadersOnPreferredOnlyResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
663 | 153 | AreLeadersOnPreferredOnly(req, resp, std::move(rpc_context)); |
664 | 153 | }); |
665 | 153 | }, |
666 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
667 | 5.42k | METRIC_service_request_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly.Instantiate(entity), |
668 | 5.42k | METRIC_service_response_bytes_yb_master_MasterCluster_AreLeadersOnPreferredOnly.Instantiate(entity), |
669 | 5.42k | METRIC_handler_latency_yb_master_MasterCluster_AreLeadersOnPreferredOnly.Instantiate(entity)) |
670 | 5.42k | }; |
671 | | |
672 | 5.42k | } |
673 | | |
674 | | } // namespace master |
675 | | } // namespace yb |