/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_ddl.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_ddl.proto |
2 | | |
3 | | #include "yb/master/master_ddl.pb.h" |
4 | | #include "yb/master/master_ddl.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_MasterDdl_CreateTable, |
18 | | "Bytes received by yb.master.MasterDdl.CreateTable() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.master.MasterDdl.CreateTable() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_master_MasterDdl_CreateTable, |
24 | | "Bytes sent in response to yb.master.MasterDdl.CreateTable() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.master.MasterDdl.CreateTable() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_master_MasterDdl_CreateTable, |
30 | | "Microseconds spent handling yb.master.MasterDdl.CreateTable() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.master.MasterDdl.CreateTable() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_master_MasterDdl_IsCreateTableDone, |
37 | | "Bytes received by yb.master.MasterDdl.IsCreateTableDone() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.master.MasterDdl.IsCreateTableDone() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_master_MasterDdl_IsCreateTableDone, |
43 | | "Bytes sent in response to yb.master.MasterDdl.IsCreateTableDone() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.master.MasterDdl.IsCreateTableDone() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_master_MasterDdl_IsCreateTableDone, |
49 | | "Microseconds spent handling yb.master.MasterDdl.IsCreateTableDone() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.master.MasterDdl.IsCreateTableDone() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, service_request_bytes_yb_master_MasterDdl_ListTables, |
56 | | "Bytes received by yb.master.MasterDdl.ListTables() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received by yb.master.MasterDdl.ListTables() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, service_response_bytes_yb_master_MasterDdl_ListTables, |
62 | | "Bytes sent in response to yb.master.MasterDdl.ListTables() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent in response to yb.master.MasterDdl.ListTables() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_histogram_with_percentiles( |
67 | | server, handler_latency_yb_master_MasterDdl_ListTables, |
68 | | "Microseconds spent handling yb.master.MasterDdl.ListTables() RPC requests", |
69 | | yb::MetricUnit::kMicroseconds, |
70 | | "Microseconds spent handling yb.master.MasterDdl.ListTables() RPC requests", |
71 | | 60000000LU, 2); |
72 | | |
73 | | METRIC_DEFINE_counter( |
74 | | server, service_request_bytes_yb_master_MasterDdl_GetTableSchema, |
75 | | "Bytes received by yb.master.MasterDdl.GetTableSchema() RPC requests", |
76 | | yb::MetricUnit::kBytes, |
77 | | "Bytes received by yb.master.MasterDdl.GetTableSchema() RPC requests"); |
78 | | |
79 | | METRIC_DEFINE_counter( |
80 | | server, service_response_bytes_yb_master_MasterDdl_GetTableSchema, |
81 | | "Bytes sent in response to yb.master.MasterDdl.GetTableSchema() RPC requests", |
82 | | yb::MetricUnit::kBytes, |
83 | | "Bytes sent in response to yb.master.MasterDdl.GetTableSchema() RPC requests"); |
84 | | |
85 | | METRIC_DEFINE_histogram_with_percentiles( |
86 | | server, handler_latency_yb_master_MasterDdl_GetTableSchema, |
87 | | "Microseconds spent handling yb.master.MasterDdl.GetTableSchema() RPC requests", |
88 | | yb::MetricUnit::kMicroseconds, |
89 | | "Microseconds spent handling yb.master.MasterDdl.GetTableSchema() RPC requests", |
90 | | 60000000LU, 2); |
91 | | |
92 | | METRIC_DEFINE_counter( |
93 | | server, service_request_bytes_yb_master_MasterDdl_GetTablegroupSchema, |
94 | | "Bytes received by yb.master.MasterDdl.GetTablegroupSchema() RPC requests", |
95 | | yb::MetricUnit::kBytes, |
96 | | "Bytes received by yb.master.MasterDdl.GetTablegroupSchema() RPC requests"); |
97 | | |
98 | | METRIC_DEFINE_counter( |
99 | | server, service_response_bytes_yb_master_MasterDdl_GetTablegroupSchema, |
100 | | "Bytes sent in response to yb.master.MasterDdl.GetTablegroupSchema() RPC requests", |
101 | | yb::MetricUnit::kBytes, |
102 | | "Bytes sent in response to yb.master.MasterDdl.GetTablegroupSchema() RPC requests"); |
103 | | |
104 | | METRIC_DEFINE_histogram_with_percentiles( |
105 | | server, handler_latency_yb_master_MasterDdl_GetTablegroupSchema, |
106 | | "Microseconds spent handling yb.master.MasterDdl.GetTablegroupSchema() RPC requests", |
107 | | yb::MetricUnit::kMicroseconds, |
108 | | "Microseconds spent handling yb.master.MasterDdl.GetTablegroupSchema() RPC requests", |
109 | | 60000000LU, 2); |
110 | | |
111 | | METRIC_DEFINE_counter( |
112 | | server, service_request_bytes_yb_master_MasterDdl_GetColocatedTabletSchema, |
113 | | "Bytes received by yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests", |
114 | | yb::MetricUnit::kBytes, |
115 | | "Bytes received by yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests"); |
116 | | |
117 | | METRIC_DEFINE_counter( |
118 | | server, service_response_bytes_yb_master_MasterDdl_GetColocatedTabletSchema, |
119 | | "Bytes sent in response to yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests", |
120 | | yb::MetricUnit::kBytes, |
121 | | "Bytes sent in response to yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests"); |
122 | | |
123 | | METRIC_DEFINE_histogram_with_percentiles( |
124 | | server, handler_latency_yb_master_MasterDdl_GetColocatedTabletSchema, |
125 | | "Microseconds spent handling yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests", |
126 | | yb::MetricUnit::kMicroseconds, |
127 | | "Microseconds spent handling yb.master.MasterDdl.GetColocatedTabletSchema() RPC requests", |
128 | | 60000000LU, 2); |
129 | | |
130 | | METRIC_DEFINE_counter( |
131 | | server, service_request_bytes_yb_master_MasterDdl_TruncateTable, |
132 | | "Bytes received by yb.master.MasterDdl.TruncateTable() RPC requests", |
133 | | yb::MetricUnit::kBytes, |
134 | | "Bytes received by yb.master.MasterDdl.TruncateTable() RPC requests"); |
135 | | |
136 | | METRIC_DEFINE_counter( |
137 | | server, service_response_bytes_yb_master_MasterDdl_TruncateTable, |
138 | | "Bytes sent in response to yb.master.MasterDdl.TruncateTable() RPC requests", |
139 | | yb::MetricUnit::kBytes, |
140 | | "Bytes sent in response to yb.master.MasterDdl.TruncateTable() RPC requests"); |
141 | | |
142 | | METRIC_DEFINE_histogram_with_percentiles( |
143 | | server, handler_latency_yb_master_MasterDdl_TruncateTable, |
144 | | "Microseconds spent handling yb.master.MasterDdl.TruncateTable() RPC requests", |
145 | | yb::MetricUnit::kMicroseconds, |
146 | | "Microseconds spent handling yb.master.MasterDdl.TruncateTable() RPC requests", |
147 | | 60000000LU, 2); |
148 | | |
149 | | METRIC_DEFINE_counter( |
150 | | server, service_request_bytes_yb_master_MasterDdl_IsTruncateTableDone, |
151 | | "Bytes received by yb.master.MasterDdl.IsTruncateTableDone() RPC requests", |
152 | | yb::MetricUnit::kBytes, |
153 | | "Bytes received by yb.master.MasterDdl.IsTruncateTableDone() RPC requests"); |
154 | | |
155 | | METRIC_DEFINE_counter( |
156 | | server, service_response_bytes_yb_master_MasterDdl_IsTruncateTableDone, |
157 | | "Bytes sent in response to yb.master.MasterDdl.IsTruncateTableDone() RPC requests", |
158 | | yb::MetricUnit::kBytes, |
159 | | "Bytes sent in response to yb.master.MasterDdl.IsTruncateTableDone() RPC requests"); |
160 | | |
161 | | METRIC_DEFINE_histogram_with_percentiles( |
162 | | server, handler_latency_yb_master_MasterDdl_IsTruncateTableDone, |
163 | | "Microseconds spent handling yb.master.MasterDdl.IsTruncateTableDone() RPC requests", |
164 | | yb::MetricUnit::kMicroseconds, |
165 | | "Microseconds spent handling yb.master.MasterDdl.IsTruncateTableDone() RPC requests", |
166 | | 60000000LU, 2); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, service_request_bytes_yb_master_MasterDdl_BackfillIndex, |
170 | | "Bytes received by yb.master.MasterDdl.BackfillIndex() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes received by yb.master.MasterDdl.BackfillIndex() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, service_response_bytes_yb_master_MasterDdl_BackfillIndex, |
176 | | "Bytes sent in response to yb.master.MasterDdl.BackfillIndex() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes sent in response to yb.master.MasterDdl.BackfillIndex() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_histogram_with_percentiles( |
181 | | server, handler_latency_yb_master_MasterDdl_BackfillIndex, |
182 | | "Microseconds spent handling yb.master.MasterDdl.BackfillIndex() RPC requests", |
183 | | yb::MetricUnit::kMicroseconds, |
184 | | "Microseconds spent handling yb.master.MasterDdl.BackfillIndex() RPC requests", |
185 | | 60000000LU, 2); |
186 | | |
187 | | METRIC_DEFINE_counter( |
188 | | server, service_request_bytes_yb_master_MasterDdl_LaunchBackfillIndexForTable, |
189 | | "Bytes received by yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests", |
190 | | yb::MetricUnit::kBytes, |
191 | | "Bytes received by yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests"); |
192 | | |
193 | | METRIC_DEFINE_counter( |
194 | | server, service_response_bytes_yb_master_MasterDdl_LaunchBackfillIndexForTable, |
195 | | "Bytes sent in response to yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests", |
196 | | yb::MetricUnit::kBytes, |
197 | | "Bytes sent in response to yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests"); |
198 | | |
199 | | METRIC_DEFINE_histogram_with_percentiles( |
200 | | server, handler_latency_yb_master_MasterDdl_LaunchBackfillIndexForTable, |
201 | | "Microseconds spent handling yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests", |
202 | | yb::MetricUnit::kMicroseconds, |
203 | | "Microseconds spent handling yb.master.MasterDdl.LaunchBackfillIndexForTable() RPC requests", |
204 | | 60000000LU, 2); |
205 | | |
206 | | METRIC_DEFINE_counter( |
207 | | server, service_request_bytes_yb_master_MasterDdl_GetBackfillJobs, |
208 | | "Bytes received by yb.master.MasterDdl.GetBackfillJobs() RPC requests", |
209 | | yb::MetricUnit::kBytes, |
210 | | "Bytes received by yb.master.MasterDdl.GetBackfillJobs() RPC requests"); |
211 | | |
212 | | METRIC_DEFINE_counter( |
213 | | server, service_response_bytes_yb_master_MasterDdl_GetBackfillJobs, |
214 | | "Bytes sent in response to yb.master.MasterDdl.GetBackfillJobs() RPC requests", |
215 | | yb::MetricUnit::kBytes, |
216 | | "Bytes sent in response to yb.master.MasterDdl.GetBackfillJobs() RPC requests"); |
217 | | |
218 | | METRIC_DEFINE_histogram_with_percentiles( |
219 | | server, handler_latency_yb_master_MasterDdl_GetBackfillJobs, |
220 | | "Microseconds spent handling yb.master.MasterDdl.GetBackfillJobs() RPC requests", |
221 | | yb::MetricUnit::kMicroseconds, |
222 | | "Microseconds spent handling yb.master.MasterDdl.GetBackfillJobs() RPC requests", |
223 | | 60000000LU, 2); |
224 | | |
225 | | METRIC_DEFINE_counter( |
226 | | server, service_request_bytes_yb_master_MasterDdl_DeleteTable, |
227 | | "Bytes received by yb.master.MasterDdl.DeleteTable() RPC requests", |
228 | | yb::MetricUnit::kBytes, |
229 | | "Bytes received by yb.master.MasterDdl.DeleteTable() RPC requests"); |
230 | | |
231 | | METRIC_DEFINE_counter( |
232 | | server, service_response_bytes_yb_master_MasterDdl_DeleteTable, |
233 | | "Bytes sent in response to yb.master.MasterDdl.DeleteTable() RPC requests", |
234 | | yb::MetricUnit::kBytes, |
235 | | "Bytes sent in response to yb.master.MasterDdl.DeleteTable() RPC requests"); |
236 | | |
237 | | METRIC_DEFINE_histogram_with_percentiles( |
238 | | server, handler_latency_yb_master_MasterDdl_DeleteTable, |
239 | | "Microseconds spent handling yb.master.MasterDdl.DeleteTable() RPC requests", |
240 | | yb::MetricUnit::kMicroseconds, |
241 | | "Microseconds spent handling yb.master.MasterDdl.DeleteTable() RPC requests", |
242 | | 60000000LU, 2); |
243 | | |
244 | | METRIC_DEFINE_counter( |
245 | | server, service_request_bytes_yb_master_MasterDdl_IsDeleteTableDone, |
246 | | "Bytes received by yb.master.MasterDdl.IsDeleteTableDone() RPC requests", |
247 | | yb::MetricUnit::kBytes, |
248 | | "Bytes received by yb.master.MasterDdl.IsDeleteTableDone() RPC requests"); |
249 | | |
250 | | METRIC_DEFINE_counter( |
251 | | server, service_response_bytes_yb_master_MasterDdl_IsDeleteTableDone, |
252 | | "Bytes sent in response to yb.master.MasterDdl.IsDeleteTableDone() RPC requests", |
253 | | yb::MetricUnit::kBytes, |
254 | | "Bytes sent in response to yb.master.MasterDdl.IsDeleteTableDone() RPC requests"); |
255 | | |
256 | | METRIC_DEFINE_histogram_with_percentiles( |
257 | | server, handler_latency_yb_master_MasterDdl_IsDeleteTableDone, |
258 | | "Microseconds spent handling yb.master.MasterDdl.IsDeleteTableDone() RPC requests", |
259 | | yb::MetricUnit::kMicroseconds, |
260 | | "Microseconds spent handling yb.master.MasterDdl.IsDeleteTableDone() RPC requests", |
261 | | 60000000LU, 2); |
262 | | |
263 | | METRIC_DEFINE_counter( |
264 | | server, service_request_bytes_yb_master_MasterDdl_AlterTable, |
265 | | "Bytes received by yb.master.MasterDdl.AlterTable() RPC requests", |
266 | | yb::MetricUnit::kBytes, |
267 | | "Bytes received by yb.master.MasterDdl.AlterTable() RPC requests"); |
268 | | |
269 | | METRIC_DEFINE_counter( |
270 | | server, service_response_bytes_yb_master_MasterDdl_AlterTable, |
271 | | "Bytes sent in response to yb.master.MasterDdl.AlterTable() RPC requests", |
272 | | yb::MetricUnit::kBytes, |
273 | | "Bytes sent in response to yb.master.MasterDdl.AlterTable() RPC requests"); |
274 | | |
275 | | METRIC_DEFINE_histogram_with_percentiles( |
276 | | server, handler_latency_yb_master_MasterDdl_AlterTable, |
277 | | "Microseconds spent handling yb.master.MasterDdl.AlterTable() RPC requests", |
278 | | yb::MetricUnit::kMicroseconds, |
279 | | "Microseconds spent handling yb.master.MasterDdl.AlterTable() RPC requests", |
280 | | 60000000LU, 2); |
281 | | |
282 | | METRIC_DEFINE_counter( |
283 | | server, service_request_bytes_yb_master_MasterDdl_IsAlterTableDone, |
284 | | "Bytes received by yb.master.MasterDdl.IsAlterTableDone() RPC requests", |
285 | | yb::MetricUnit::kBytes, |
286 | | "Bytes received by yb.master.MasterDdl.IsAlterTableDone() RPC requests"); |
287 | | |
288 | | METRIC_DEFINE_counter( |
289 | | server, service_response_bytes_yb_master_MasterDdl_IsAlterTableDone, |
290 | | "Bytes sent in response to yb.master.MasterDdl.IsAlterTableDone() RPC requests", |
291 | | yb::MetricUnit::kBytes, |
292 | | "Bytes sent in response to yb.master.MasterDdl.IsAlterTableDone() RPC requests"); |
293 | | |
294 | | METRIC_DEFINE_histogram_with_percentiles( |
295 | | server, handler_latency_yb_master_MasterDdl_IsAlterTableDone, |
296 | | "Microseconds spent handling yb.master.MasterDdl.IsAlterTableDone() RPC requests", |
297 | | yb::MetricUnit::kMicroseconds, |
298 | | "Microseconds spent handling yb.master.MasterDdl.IsAlterTableDone() RPC requests", |
299 | | 60000000LU, 2); |
300 | | |
301 | | METRIC_DEFINE_counter( |
302 | | server, service_request_bytes_yb_master_MasterDdl_CreateNamespace, |
303 | | "Bytes received by yb.master.MasterDdl.CreateNamespace() RPC requests", |
304 | | yb::MetricUnit::kBytes, |
305 | | "Bytes received by yb.master.MasterDdl.CreateNamespace() RPC requests"); |
306 | | |
307 | | METRIC_DEFINE_counter( |
308 | | server, service_response_bytes_yb_master_MasterDdl_CreateNamespace, |
309 | | "Bytes sent in response to yb.master.MasterDdl.CreateNamespace() RPC requests", |
310 | | yb::MetricUnit::kBytes, |
311 | | "Bytes sent in response to yb.master.MasterDdl.CreateNamespace() RPC requests"); |
312 | | |
313 | | METRIC_DEFINE_histogram_with_percentiles( |
314 | | server, handler_latency_yb_master_MasterDdl_CreateNamespace, |
315 | | "Microseconds spent handling yb.master.MasterDdl.CreateNamespace() RPC requests", |
316 | | yb::MetricUnit::kMicroseconds, |
317 | | "Microseconds spent handling yb.master.MasterDdl.CreateNamespace() RPC requests", |
318 | | 60000000LU, 2); |
319 | | |
320 | | METRIC_DEFINE_counter( |
321 | | server, service_request_bytes_yb_master_MasterDdl_IsCreateNamespaceDone, |
322 | | "Bytes received by yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests", |
323 | | yb::MetricUnit::kBytes, |
324 | | "Bytes received by yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests"); |
325 | | |
326 | | METRIC_DEFINE_counter( |
327 | | server, service_response_bytes_yb_master_MasterDdl_IsCreateNamespaceDone, |
328 | | "Bytes sent in response to yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests", |
329 | | yb::MetricUnit::kBytes, |
330 | | "Bytes sent in response to yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests"); |
331 | | |
332 | | METRIC_DEFINE_histogram_with_percentiles( |
333 | | server, handler_latency_yb_master_MasterDdl_IsCreateNamespaceDone, |
334 | | "Microseconds spent handling yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests", |
335 | | yb::MetricUnit::kMicroseconds, |
336 | | "Microseconds spent handling yb.master.MasterDdl.IsCreateNamespaceDone() RPC requests", |
337 | | 60000000LU, 2); |
338 | | |
339 | | METRIC_DEFINE_counter( |
340 | | server, service_request_bytes_yb_master_MasterDdl_DeleteNamespace, |
341 | | "Bytes received by yb.master.MasterDdl.DeleteNamespace() RPC requests", |
342 | | yb::MetricUnit::kBytes, |
343 | | "Bytes received by yb.master.MasterDdl.DeleteNamespace() RPC requests"); |
344 | | |
345 | | METRIC_DEFINE_counter( |
346 | | server, service_response_bytes_yb_master_MasterDdl_DeleteNamespace, |
347 | | "Bytes sent in response to yb.master.MasterDdl.DeleteNamespace() RPC requests", |
348 | | yb::MetricUnit::kBytes, |
349 | | "Bytes sent in response to yb.master.MasterDdl.DeleteNamespace() RPC requests"); |
350 | | |
351 | | METRIC_DEFINE_histogram_with_percentiles( |
352 | | server, handler_latency_yb_master_MasterDdl_DeleteNamespace, |
353 | | "Microseconds spent handling yb.master.MasterDdl.DeleteNamespace() RPC requests", |
354 | | yb::MetricUnit::kMicroseconds, |
355 | | "Microseconds spent handling yb.master.MasterDdl.DeleteNamespace() RPC requests", |
356 | | 60000000LU, 2); |
357 | | |
358 | | METRIC_DEFINE_counter( |
359 | | server, service_request_bytes_yb_master_MasterDdl_IsDeleteNamespaceDone, |
360 | | "Bytes received by yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests", |
361 | | yb::MetricUnit::kBytes, |
362 | | "Bytes received by yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests"); |
363 | | |
364 | | METRIC_DEFINE_counter( |
365 | | server, service_response_bytes_yb_master_MasterDdl_IsDeleteNamespaceDone, |
366 | | "Bytes sent in response to yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests", |
367 | | yb::MetricUnit::kBytes, |
368 | | "Bytes sent in response to yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests"); |
369 | | |
370 | | METRIC_DEFINE_histogram_with_percentiles( |
371 | | server, handler_latency_yb_master_MasterDdl_IsDeleteNamespaceDone, |
372 | | "Microseconds spent handling yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests", |
373 | | yb::MetricUnit::kMicroseconds, |
374 | | "Microseconds spent handling yb.master.MasterDdl.IsDeleteNamespaceDone() RPC requests", |
375 | | 60000000LU, 2); |
376 | | |
377 | | METRIC_DEFINE_counter( |
378 | | server, service_request_bytes_yb_master_MasterDdl_AlterNamespace, |
379 | | "Bytes received by yb.master.MasterDdl.AlterNamespace() RPC requests", |
380 | | yb::MetricUnit::kBytes, |
381 | | "Bytes received by yb.master.MasterDdl.AlterNamespace() RPC requests"); |
382 | | |
383 | | METRIC_DEFINE_counter( |
384 | | server, service_response_bytes_yb_master_MasterDdl_AlterNamespace, |
385 | | "Bytes sent in response to yb.master.MasterDdl.AlterNamespace() RPC requests", |
386 | | yb::MetricUnit::kBytes, |
387 | | "Bytes sent in response to yb.master.MasterDdl.AlterNamespace() RPC requests"); |
388 | | |
389 | | METRIC_DEFINE_histogram_with_percentiles( |
390 | | server, handler_latency_yb_master_MasterDdl_AlterNamespace, |
391 | | "Microseconds spent handling yb.master.MasterDdl.AlterNamespace() RPC requests", |
392 | | yb::MetricUnit::kMicroseconds, |
393 | | "Microseconds spent handling yb.master.MasterDdl.AlterNamespace() RPC requests", |
394 | | 60000000LU, 2); |
395 | | |
396 | | METRIC_DEFINE_counter( |
397 | | server, service_request_bytes_yb_master_MasterDdl_ListNamespaces, |
398 | | "Bytes received by yb.master.MasterDdl.ListNamespaces() RPC requests", |
399 | | yb::MetricUnit::kBytes, |
400 | | "Bytes received by yb.master.MasterDdl.ListNamespaces() RPC requests"); |
401 | | |
402 | | METRIC_DEFINE_counter( |
403 | | server, service_response_bytes_yb_master_MasterDdl_ListNamespaces, |
404 | | "Bytes sent in response to yb.master.MasterDdl.ListNamespaces() RPC requests", |
405 | | yb::MetricUnit::kBytes, |
406 | | "Bytes sent in response to yb.master.MasterDdl.ListNamespaces() RPC requests"); |
407 | | |
408 | | METRIC_DEFINE_histogram_with_percentiles( |
409 | | server, handler_latency_yb_master_MasterDdl_ListNamespaces, |
410 | | "Microseconds spent handling yb.master.MasterDdl.ListNamespaces() RPC requests", |
411 | | yb::MetricUnit::kMicroseconds, |
412 | | "Microseconds spent handling yb.master.MasterDdl.ListNamespaces() RPC requests", |
413 | | 60000000LU, 2); |
414 | | |
415 | | METRIC_DEFINE_counter( |
416 | | server, service_request_bytes_yb_master_MasterDdl_GetNamespaceInfo, |
417 | | "Bytes received by yb.master.MasterDdl.GetNamespaceInfo() RPC requests", |
418 | | yb::MetricUnit::kBytes, |
419 | | "Bytes received by yb.master.MasterDdl.GetNamespaceInfo() RPC requests"); |
420 | | |
421 | | METRIC_DEFINE_counter( |
422 | | server, service_response_bytes_yb_master_MasterDdl_GetNamespaceInfo, |
423 | | "Bytes sent in response to yb.master.MasterDdl.GetNamespaceInfo() RPC requests", |
424 | | yb::MetricUnit::kBytes, |
425 | | "Bytes sent in response to yb.master.MasterDdl.GetNamespaceInfo() RPC requests"); |
426 | | |
427 | | METRIC_DEFINE_histogram_with_percentiles( |
428 | | server, handler_latency_yb_master_MasterDdl_GetNamespaceInfo, |
429 | | "Microseconds spent handling yb.master.MasterDdl.GetNamespaceInfo() RPC requests", |
430 | | yb::MetricUnit::kMicroseconds, |
431 | | "Microseconds spent handling yb.master.MasterDdl.GetNamespaceInfo() RPC requests", |
432 | | 60000000LU, 2); |
433 | | |
434 | | METRIC_DEFINE_counter( |
435 | | server, service_request_bytes_yb_master_MasterDdl_CreateTablegroup, |
436 | | "Bytes received by yb.master.MasterDdl.CreateTablegroup() RPC requests", |
437 | | yb::MetricUnit::kBytes, |
438 | | "Bytes received by yb.master.MasterDdl.CreateTablegroup() RPC requests"); |
439 | | |
440 | | METRIC_DEFINE_counter( |
441 | | server, service_response_bytes_yb_master_MasterDdl_CreateTablegroup, |
442 | | "Bytes sent in response to yb.master.MasterDdl.CreateTablegroup() RPC requests", |
443 | | yb::MetricUnit::kBytes, |
444 | | "Bytes sent in response to yb.master.MasterDdl.CreateTablegroup() RPC requests"); |
445 | | |
446 | | METRIC_DEFINE_histogram_with_percentiles( |
447 | | server, handler_latency_yb_master_MasterDdl_CreateTablegroup, |
448 | | "Microseconds spent handling yb.master.MasterDdl.CreateTablegroup() RPC requests", |
449 | | yb::MetricUnit::kMicroseconds, |
450 | | "Microseconds spent handling yb.master.MasterDdl.CreateTablegroup() RPC requests", |
451 | | 60000000LU, 2); |
452 | | |
453 | | METRIC_DEFINE_counter( |
454 | | server, service_request_bytes_yb_master_MasterDdl_DeleteTablegroup, |
455 | | "Bytes received by yb.master.MasterDdl.DeleteTablegroup() RPC requests", |
456 | | yb::MetricUnit::kBytes, |
457 | | "Bytes received by yb.master.MasterDdl.DeleteTablegroup() RPC requests"); |
458 | | |
459 | | METRIC_DEFINE_counter( |
460 | | server, service_response_bytes_yb_master_MasterDdl_DeleteTablegroup, |
461 | | "Bytes sent in response to yb.master.MasterDdl.DeleteTablegroup() RPC requests", |
462 | | yb::MetricUnit::kBytes, |
463 | | "Bytes sent in response to yb.master.MasterDdl.DeleteTablegroup() RPC requests"); |
464 | | |
465 | | METRIC_DEFINE_histogram_with_percentiles( |
466 | | server, handler_latency_yb_master_MasterDdl_DeleteTablegroup, |
467 | | "Microseconds spent handling yb.master.MasterDdl.DeleteTablegroup() RPC requests", |
468 | | yb::MetricUnit::kMicroseconds, |
469 | | "Microseconds spent handling yb.master.MasterDdl.DeleteTablegroup() RPC requests", |
470 | | 60000000LU, 2); |
471 | | |
472 | | METRIC_DEFINE_counter( |
473 | | server, service_request_bytes_yb_master_MasterDdl_ListTablegroups, |
474 | | "Bytes received by yb.master.MasterDdl.ListTablegroups() RPC requests", |
475 | | yb::MetricUnit::kBytes, |
476 | | "Bytes received by yb.master.MasterDdl.ListTablegroups() RPC requests"); |
477 | | |
478 | | METRIC_DEFINE_counter( |
479 | | server, service_response_bytes_yb_master_MasterDdl_ListTablegroups, |
480 | | "Bytes sent in response to yb.master.MasterDdl.ListTablegroups() RPC requests", |
481 | | yb::MetricUnit::kBytes, |
482 | | "Bytes sent in response to yb.master.MasterDdl.ListTablegroups() RPC requests"); |
483 | | |
484 | | METRIC_DEFINE_histogram_with_percentiles( |
485 | | server, handler_latency_yb_master_MasterDdl_ListTablegroups, |
486 | | "Microseconds spent handling yb.master.MasterDdl.ListTablegroups() RPC requests", |
487 | | yb::MetricUnit::kMicroseconds, |
488 | | "Microseconds spent handling yb.master.MasterDdl.ListTablegroups() RPC requests", |
489 | | 60000000LU, 2); |
490 | | |
491 | | METRIC_DEFINE_counter( |
492 | | server, service_request_bytes_yb_master_MasterDdl_CreateUDType, |
493 | | "Bytes received by yb.master.MasterDdl.CreateUDType() RPC requests", |
494 | | yb::MetricUnit::kBytes, |
495 | | "Bytes received by yb.master.MasterDdl.CreateUDType() RPC requests"); |
496 | | |
497 | | METRIC_DEFINE_counter( |
498 | | server, service_response_bytes_yb_master_MasterDdl_CreateUDType, |
499 | | "Bytes sent in response to yb.master.MasterDdl.CreateUDType() RPC requests", |
500 | | yb::MetricUnit::kBytes, |
501 | | "Bytes sent in response to yb.master.MasterDdl.CreateUDType() RPC requests"); |
502 | | |
503 | | METRIC_DEFINE_histogram_with_percentiles( |
504 | | server, handler_latency_yb_master_MasterDdl_CreateUDType, |
505 | | "Microseconds spent handling yb.master.MasterDdl.CreateUDType() RPC requests", |
506 | | yb::MetricUnit::kMicroseconds, |
507 | | "Microseconds spent handling yb.master.MasterDdl.CreateUDType() RPC requests", |
508 | | 60000000LU, 2); |
509 | | |
510 | | METRIC_DEFINE_counter( |
511 | | server, service_request_bytes_yb_master_MasterDdl_DeleteUDType, |
512 | | "Bytes received by yb.master.MasterDdl.DeleteUDType() RPC requests", |
513 | | yb::MetricUnit::kBytes, |
514 | | "Bytes received by yb.master.MasterDdl.DeleteUDType() RPC requests"); |
515 | | |
516 | | METRIC_DEFINE_counter( |
517 | | server, service_response_bytes_yb_master_MasterDdl_DeleteUDType, |
518 | | "Bytes sent in response to yb.master.MasterDdl.DeleteUDType() RPC requests", |
519 | | yb::MetricUnit::kBytes, |
520 | | "Bytes sent in response to yb.master.MasterDdl.DeleteUDType() RPC requests"); |
521 | | |
522 | | METRIC_DEFINE_histogram_with_percentiles( |
523 | | server, handler_latency_yb_master_MasterDdl_DeleteUDType, |
524 | | "Microseconds spent handling yb.master.MasterDdl.DeleteUDType() RPC requests", |
525 | | yb::MetricUnit::kMicroseconds, |
526 | | "Microseconds spent handling yb.master.MasterDdl.DeleteUDType() RPC requests", |
527 | | 60000000LU, 2); |
528 | | |
529 | | METRIC_DEFINE_counter( |
530 | | server, service_request_bytes_yb_master_MasterDdl_ListUDTypes, |
531 | | "Bytes received by yb.master.MasterDdl.ListUDTypes() RPC requests", |
532 | | yb::MetricUnit::kBytes, |
533 | | "Bytes received by yb.master.MasterDdl.ListUDTypes() RPC requests"); |
534 | | |
535 | | METRIC_DEFINE_counter( |
536 | | server, service_response_bytes_yb_master_MasterDdl_ListUDTypes, |
537 | | "Bytes sent in response to yb.master.MasterDdl.ListUDTypes() RPC requests", |
538 | | yb::MetricUnit::kBytes, |
539 | | "Bytes sent in response to yb.master.MasterDdl.ListUDTypes() RPC requests"); |
540 | | |
541 | | METRIC_DEFINE_histogram_with_percentiles( |
542 | | server, handler_latency_yb_master_MasterDdl_ListUDTypes, |
543 | | "Microseconds spent handling yb.master.MasterDdl.ListUDTypes() RPC requests", |
544 | | yb::MetricUnit::kMicroseconds, |
545 | | "Microseconds spent handling yb.master.MasterDdl.ListUDTypes() RPC requests", |
546 | | 60000000LU, 2); |
547 | | |
548 | | METRIC_DEFINE_counter( |
549 | | server, service_request_bytes_yb_master_MasterDdl_GetUDTypeInfo, |
550 | | "Bytes received by yb.master.MasterDdl.GetUDTypeInfo() RPC requests", |
551 | | yb::MetricUnit::kBytes, |
552 | | "Bytes received by yb.master.MasterDdl.GetUDTypeInfo() RPC requests"); |
553 | | |
554 | | METRIC_DEFINE_counter( |
555 | | server, service_response_bytes_yb_master_MasterDdl_GetUDTypeInfo, |
556 | | "Bytes sent in response to yb.master.MasterDdl.GetUDTypeInfo() RPC requests", |
557 | | yb::MetricUnit::kBytes, |
558 | | "Bytes sent in response to yb.master.MasterDdl.GetUDTypeInfo() RPC requests"); |
559 | | |
560 | | METRIC_DEFINE_histogram_with_percentiles( |
561 | | server, handler_latency_yb_master_MasterDdl_GetUDTypeInfo, |
562 | | "Microseconds spent handling yb.master.MasterDdl.GetUDTypeInfo() RPC requests", |
563 | | yb::MetricUnit::kMicroseconds, |
564 | | "Microseconds spent handling yb.master.MasterDdl.GetUDTypeInfo() RPC requests", |
565 | | 60000000LU, 2); |
566 | | |
567 | | namespace yb { |
568 | | namespace master { |
569 | | |
570 | 5.42k | MasterDdlIf::MasterDdlIf(const scoped_refptr<MetricEntity>& entity) { |
571 | 5.42k | InitMethods(entity); |
572 | 5.42k | } |
573 | | |
574 | 87 | MasterDdlIf::~MasterDdlIf() { |
575 | 87 | } |
576 | | |
577 | 5.42k | void MasterDdlIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
578 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTable))); |
579 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateTableDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateTableDone))); |
580 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTables)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTables))); |
581 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTableSchema)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTableSchema))); |
582 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTablegroupSchema)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTablegroupSchema))); |
583 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetColocatedTabletSchema)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetColocatedTabletSchema))); |
584 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kTruncateTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kTruncateTable))); |
585 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsTruncateTableDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsTruncateTableDone))); |
586 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kBackfillIndex)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kBackfillIndex))); |
587 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kLaunchBackfillIndexForTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kLaunchBackfillIndexForTable))); |
588 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetBackfillJobs)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetBackfillJobs))); |
589 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTable))); |
590 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteTableDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteTableDone))); |
591 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterTable))); |
592 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsAlterTableDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsAlterTableDone))); |
593 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateNamespace)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateNamespace))); |
594 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateNamespaceDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateNamespaceDone))); |
595 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteNamespace)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteNamespace))); |
596 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteNamespaceDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteNamespaceDone))); |
597 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterNamespace)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterNamespace))); |
598 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListNamespaces)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kListNamespaces))); |
599 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetNamespaceInfo)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetNamespaceInfo))); |
600 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTablegroup)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTablegroup))); |
601 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTablegroup)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTablegroup))); |
602 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTablegroups)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTablegroups))); |
603 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateUDType)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateUDType))); |
604 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteUDType)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteUDType))); |
605 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListUDTypes)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kListUDTypes))); |
606 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetUDTypeInfo)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetUDTypeInfo))); |
607 | 5.42k | } |
608 | | |
609 | 182k | void MasterDdlIf::Handle(::yb::rpc::InboundCallPtr call) { |
610 | 182k | auto index = call->method_index(); |
611 | 182k | methods_[index].handler(std::move(call)); |
612 | 182k | } |
613 | | |
614 | 16.2k | std::string MasterDdlIf::service_name() const { |
615 | 16.2k | return "yb.master.MasterService"; |
616 | 16.2k | } |
617 | 0 | std::string MasterDdlIf::static_service_name() { |
618 | 0 | return "yb.master.MasterService"; |
619 | 0 | } |
620 | | |
621 | 5.42k | void MasterDdlIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
622 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTable)] = { |
623 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "CreateTable"), |
624 | 3.36k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
625 | 3.36k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTable)].metrics); |
626 | 3.36k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateTableRequestPB, ::yb::master::CreateTableResponsePB>>( |
627 | 3.36k | std::move(call), [this](const ::yb::master::CreateTableRequestPB* req, ::yb::master::CreateTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
628 | 3.36k | CreateTable(req, resp, std::move(rpc_context)); |
629 | 3.36k | }); |
630 | 3.36k | }, |
631 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
632 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_CreateTable.Instantiate(entity), |
633 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_CreateTable.Instantiate(entity), |
634 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_CreateTable.Instantiate(entity)) |
635 | 5.42k | }; |
636 | | |
637 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateTableDone)] = { |
638 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsCreateTableDone"), |
639 | 16.2k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
640 | 16.2k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateTableDone)].metrics); |
641 | 16.2k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsCreateTableDoneRequestPB, ::yb::master::IsCreateTableDoneResponsePB>>( |
642 | 16.2k | std::move(call), [this](const ::yb::master::IsCreateTableDoneRequestPB* req, ::yb::master::IsCreateTableDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
643 | 16.2k | IsCreateTableDone(req, resp, std::move(rpc_context)); |
644 | 16.2k | }); |
645 | 16.2k | }, |
646 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
647 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsCreateTableDone.Instantiate(entity), |
648 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsCreateTableDone.Instantiate(entity), |
649 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsCreateTableDone.Instantiate(entity)) |
650 | 5.42k | }; |
651 | | |
652 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTables)] = { |
653 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListTables"), |
654 | 1.83k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
655 | 1.83k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTables)].metrics); |
656 | 1.83k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListTablesRequestPB, ::yb::master::ListTablesResponsePB>>( |
657 | 1.83k | std::move(call), [this](const ::yb::master::ListTablesRequestPB* req, ::yb::master::ListTablesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
658 | 1.83k | ListTables(req, resp, std::move(rpc_context)); |
659 | 1.83k | }); |
660 | 1.83k | }, |
661 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
662 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_ListTables.Instantiate(entity), |
663 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_ListTables.Instantiate(entity), |
664 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_ListTables.Instantiate(entity)) |
665 | 5.42k | }; |
666 | | |
667 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTableSchema)] = { |
668 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetTableSchema"), |
669 | 116k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
670 | 116k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTableSchema)].metrics); |
671 | 116k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetTableSchemaRequestPB, ::yb::master::GetTableSchemaResponsePB>>( |
672 | 117k | std::move(call), [this](const ::yb::master::GetTableSchemaRequestPB* req, ::yb::master::GetTableSchemaResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
673 | 117k | GetTableSchema(req, resp, std::move(rpc_context)); |
674 | 117k | }); |
675 | 116k | }, |
676 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
677 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetTableSchema.Instantiate(entity), |
678 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetTableSchema.Instantiate(entity), |
679 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetTableSchema.Instantiate(entity)) |
680 | 5.42k | }; |
681 | | |
682 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTablegroupSchema)] = { |
683 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetTablegroupSchema"), |
684 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
685 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetTablegroupSchema)].metrics); |
686 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetTablegroupSchemaRequestPB, ::yb::master::GetTablegroupSchemaResponsePB>>( |
687 | 0 | std::move(call), [this](const ::yb::master::GetTablegroupSchemaRequestPB* req, ::yb::master::GetTablegroupSchemaResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
688 | 0 | GetTablegroupSchema(req, resp, std::move(rpc_context)); |
689 | 0 | }); |
690 | 0 | }, |
691 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
692 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetTablegroupSchema.Instantiate(entity), |
693 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetTablegroupSchema.Instantiate(entity), |
694 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetTablegroupSchema.Instantiate(entity)) |
695 | 5.42k | }; |
696 | | |
697 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetColocatedTabletSchema)] = { |
698 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetColocatedTabletSchema"), |
699 | 8.84k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
700 | 8.84k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetColocatedTabletSchema)].metrics); |
701 | 8.84k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetColocatedTabletSchemaRequestPB, ::yb::master::GetColocatedTabletSchemaResponsePB>>( |
702 | 0 | std::move(call), [this](const ::yb::master::GetColocatedTabletSchemaRequestPB* req, ::yb::master::GetColocatedTabletSchemaResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
703 | 0 | GetColocatedTabletSchema(req, resp, std::move(rpc_context)); |
704 | 0 | }); |
705 | 8.84k | }, |
706 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
707 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetColocatedTabletSchema.Instantiate(entity), |
708 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetColocatedTabletSchema.Instantiate(entity), |
709 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetColocatedTabletSchema.Instantiate(entity)) |
710 | 5.42k | }; |
711 | | |
712 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kTruncateTable)] = { |
713 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "TruncateTable"), |
714 | 3.05k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
715 | 3.05k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kTruncateTable)].metrics); |
716 | 3.05k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::TruncateTableRequestPB, ::yb::master::TruncateTableResponsePB>>( |
717 | 3.05k | std::move(call), [this](const ::yb::master::TruncateTableRequestPB* req, ::yb::master::TruncateTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
718 | 3.05k | TruncateTable(req, resp, std::move(rpc_context)); |
719 | 3.05k | }); |
720 | 3.05k | }, |
721 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
722 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_TruncateTable.Instantiate(entity), |
723 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_TruncateTable.Instantiate(entity), |
724 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_TruncateTable.Instantiate(entity)) |
725 | 5.42k | }; |
726 | | |
727 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsTruncateTableDone)] = { |
728 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsTruncateTableDone"), |
729 | 8.89k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
730 | 8.89k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsTruncateTableDone)].metrics); |
731 | 8.89k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsTruncateTableDoneRequestPB, ::yb::master::IsTruncateTableDoneResponsePB>>( |
732 | 8.89k | std::move(call), [this](const ::yb::master::IsTruncateTableDoneRequestPB* req, ::yb::master::IsTruncateTableDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
733 | 8.89k | IsTruncateTableDone(req, resp, std::move(rpc_context)); |
734 | 8.89k | }); |
735 | 8.89k | }, |
736 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
737 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsTruncateTableDone.Instantiate(entity), |
738 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsTruncateTableDone.Instantiate(entity), |
739 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsTruncateTableDone.Instantiate(entity)) |
740 | 5.42k | }; |
741 | | |
742 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kBackfillIndex)] = { |
743 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "BackfillIndex"), |
744 | 90 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
745 | 90 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kBackfillIndex)].metrics); |
746 | 90 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::BackfillIndexRequestPB, ::yb::master::BackfillIndexResponsePB>>( |
747 | 89 | std::move(call), [this](const ::yb::master::BackfillIndexRequestPB* req, ::yb::master::BackfillIndexResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
748 | 89 | BackfillIndex(req, resp, std::move(rpc_context)); |
749 | 89 | }); |
750 | 90 | }, |
751 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
752 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_BackfillIndex.Instantiate(entity), |
753 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_BackfillIndex.Instantiate(entity), |
754 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_BackfillIndex.Instantiate(entity)) |
755 | 5.42k | }; |
756 | | |
757 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kLaunchBackfillIndexForTable)] = { |
758 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "LaunchBackfillIndexForTable"), |
759 | 695 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
760 | 695 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kLaunchBackfillIndexForTable)].metrics); |
761 | 695 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::LaunchBackfillIndexForTableRequestPB, ::yb::master::LaunchBackfillIndexForTableResponsePB>>( |
762 | 0 | std::move(call), [this](const ::yb::master::LaunchBackfillIndexForTableRequestPB* req, ::yb::master::LaunchBackfillIndexForTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
763 | 0 | LaunchBackfillIndexForTable(req, resp, std::move(rpc_context)); |
764 | 0 | }); |
765 | 695 | }, |
766 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
767 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_LaunchBackfillIndexForTable.Instantiate(entity), |
768 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_LaunchBackfillIndexForTable.Instantiate(entity), |
769 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_LaunchBackfillIndexForTable.Instantiate(entity)) |
770 | 5.42k | }; |
771 | | |
772 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetBackfillJobs)] = { |
773 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetBackfillJobs"), |
774 | 74 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
775 | 74 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetBackfillJobs)].metrics); |
776 | 74 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetBackfillJobsRequestPB, ::yb::master::GetBackfillJobsResponsePB>>( |
777 | 0 | std::move(call), [this](const ::yb::master::GetBackfillJobsRequestPB* req, ::yb::master::GetBackfillJobsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
778 | 0 | GetBackfillJobs(req, resp, std::move(rpc_context)); |
779 | 0 | }); |
780 | 74 | }, |
781 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
782 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetBackfillJobs.Instantiate(entity), |
783 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetBackfillJobs.Instantiate(entity), |
784 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetBackfillJobs.Instantiate(entity)) |
785 | 5.42k | }; |
786 | | |
787 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTable)] = { |
788 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "DeleteTable"), |
789 | 2.53k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
790 | 2.53k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTable)].metrics); |
791 | 2.53k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteTableRequestPB, ::yb::master::DeleteTableResponsePB>>( |
792 | 2.39k | std::move(call), [this](const ::yb::master::DeleteTableRequestPB* req, ::yb::master::DeleteTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
793 | 2.39k | DeleteTable(req, resp, std::move(rpc_context)); |
794 | 2.39k | }); |
795 | 2.53k | }, |
796 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
797 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_DeleteTable.Instantiate(entity), |
798 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_DeleteTable.Instantiate(entity), |
799 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_DeleteTable.Instantiate(entity)) |
800 | 5.42k | }; |
801 | | |
802 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteTableDone)] = { |
803 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsDeleteTableDone"), |
804 | 5.56k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
805 | 5.56k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteTableDone)].metrics); |
806 | 5.56k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsDeleteTableDoneRequestPB, ::yb::master::IsDeleteTableDoneResponsePB>>( |
807 | 5.44k | std::move(call), [this](const ::yb::master::IsDeleteTableDoneRequestPB* req, ::yb::master::IsDeleteTableDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
808 | 5.44k | IsDeleteTableDone(req, resp, std::move(rpc_context)); |
809 | 5.44k | }); |
810 | 5.56k | }, |
811 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
812 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsDeleteTableDone.Instantiate(entity), |
813 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsDeleteTableDone.Instantiate(entity), |
814 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsDeleteTableDone.Instantiate(entity)) |
815 | 5.42k | }; |
816 | | |
817 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterTable)] = { |
818 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "AlterTable"), |
819 | 442 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
820 | 442 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterTable)].metrics); |
821 | 442 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::AlterTableRequestPB, ::yb::master::AlterTableResponsePB>>( |
822 | 211 | std::move(call), [this](const ::yb::master::AlterTableRequestPB* req, ::yb::master::AlterTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
823 | 211 | AlterTable(req, resp, std::move(rpc_context)); |
824 | 211 | }); |
825 | 442 | }, |
826 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
827 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_AlterTable.Instantiate(entity), |
828 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_AlterTable.Instantiate(entity), |
829 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_AlterTable.Instantiate(entity)) |
830 | 5.42k | }; |
831 | | |
832 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsAlterTableDone)] = { |
833 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsAlterTableDone"), |
834 | 692 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
835 | 692 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsAlterTableDone)].metrics); |
836 | 692 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsAlterTableDoneRequestPB, ::yb::master::IsAlterTableDoneResponsePB>>( |
837 | 418 | std::move(call), [this](const ::yb::master::IsAlterTableDoneRequestPB* req, ::yb::master::IsAlterTableDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
838 | 418 | IsAlterTableDone(req, resp, std::move(rpc_context)); |
839 | 418 | }); |
840 | 692 | }, |
841 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
842 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsAlterTableDone.Instantiate(entity), |
843 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsAlterTableDone.Instantiate(entity), |
844 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsAlterTableDone.Instantiate(entity)) |
845 | 5.42k | }; |
846 | | |
847 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateNamespace)] = { |
848 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "CreateNamespace"), |
849 | 2.13k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
850 | 2.13k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateNamespace)].metrics); |
851 | 2.13k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateNamespaceRequestPB, ::yb::master::CreateNamespaceResponsePB>>( |
852 | 1.80k | std::move(call), [this](const ::yb::master::CreateNamespaceRequestPB* req, ::yb::master::CreateNamespaceResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
853 | 1.80k | CreateNamespace(req, resp, std::move(rpc_context)); |
854 | 1.80k | }); |
855 | 2.13k | }, |
856 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
857 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_CreateNamespace.Instantiate(entity), |
858 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_CreateNamespace.Instantiate(entity), |
859 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_CreateNamespace.Instantiate(entity)) |
860 | 5.42k | }; |
861 | | |
862 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateNamespaceDone)] = { |
863 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsCreateNamespaceDone"), |
864 | 1.85k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
865 | 1.85k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsCreateNamespaceDone)].metrics); |
866 | 1.85k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsCreateNamespaceDoneRequestPB, ::yb::master::IsCreateNamespaceDoneResponsePB>>( |
867 | 1.81k | std::move(call), [this](const ::yb::master::IsCreateNamespaceDoneRequestPB* req, ::yb::master::IsCreateNamespaceDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
868 | 1.81k | IsCreateNamespaceDone(req, resp, std::move(rpc_context)); |
869 | 1.81k | }); |
870 | 1.85k | }, |
871 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
872 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsCreateNamespaceDone.Instantiate(entity), |
873 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsCreateNamespaceDone.Instantiate(entity), |
874 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsCreateNamespaceDone.Instantiate(entity)) |
875 | 5.42k | }; |
876 | | |
877 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteNamespace)] = { |
878 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "DeleteNamespace"), |
879 | 1.57k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
880 | 1.57k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteNamespace)].metrics); |
881 | 1.57k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteNamespaceRequestPB, ::yb::master::DeleteNamespaceResponsePB>>( |
882 | 1.51k | std::move(call), [this](const ::yb::master::DeleteNamespaceRequestPB* req, ::yb::master::DeleteNamespaceResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
883 | 1.51k | DeleteNamespace(req, resp, std::move(rpc_context)); |
884 | 1.51k | }); |
885 | 1.57k | }, |
886 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
887 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_DeleteNamespace.Instantiate(entity), |
888 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_DeleteNamespace.Instantiate(entity), |
889 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_DeleteNamespace.Instantiate(entity)) |
890 | 5.42k | }; |
891 | | |
892 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteNamespaceDone)] = { |
893 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "IsDeleteNamespaceDone"), |
894 | 1.54k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
895 | 1.54k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kIsDeleteNamespaceDone)].metrics); |
896 | 1.54k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::IsDeleteNamespaceDoneRequestPB, ::yb::master::IsDeleteNamespaceDoneResponsePB>>( |
897 | 1.53k | std::move(call), [this](const ::yb::master::IsDeleteNamespaceDoneRequestPB* req, ::yb::master::IsDeleteNamespaceDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
898 | 1.53k | IsDeleteNamespaceDone(req, resp, std::move(rpc_context)); |
899 | 1.53k | }); |
900 | 1.54k | }, |
901 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
902 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_IsDeleteNamespaceDone.Instantiate(entity), |
903 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_IsDeleteNamespaceDone.Instantiate(entity), |
904 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_IsDeleteNamespaceDone.Instantiate(entity)) |
905 | 5.42k | }; |
906 | | |
907 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterNamespace)] = { |
908 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "AlterNamespace"), |
909 | 415 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
910 | 415 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kAlterNamespace)].metrics); |
911 | 415 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::AlterNamespaceRequestPB, ::yb::master::AlterNamespaceResponsePB>>( |
912 | 0 | std::move(call), [this](const ::yb::master::AlterNamespaceRequestPB* req, ::yb::master::AlterNamespaceResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
913 | 0 | AlterNamespace(req, resp, std::move(rpc_context)); |
914 | 0 | }); |
915 | 415 | }, |
916 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
917 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_AlterNamespace.Instantiate(entity), |
918 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_AlterNamespace.Instantiate(entity), |
919 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_AlterNamespace.Instantiate(entity)) |
920 | 5.42k | }; |
921 | | |
922 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListNamespaces)] = { |
923 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListNamespaces"), |
924 | 4.02k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
925 | 4.02k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListNamespaces)].metrics); |
926 | 4.02k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListNamespacesRequestPB, ::yb::master::ListNamespacesResponsePB>>( |
927 | 4.02k | std::move(call), [this](const ::yb::master::ListNamespacesRequestPB* req, ::yb::master::ListNamespacesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
928 | 4.02k | ListNamespaces(req, resp, std::move(rpc_context)); |
929 | 4.02k | }); |
930 | 4.02k | }, |
931 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
932 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_ListNamespaces.Instantiate(entity), |
933 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_ListNamespaces.Instantiate(entity), |
934 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_ListNamespaces.Instantiate(entity)) |
935 | 5.42k | }; |
936 | | |
937 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetNamespaceInfo)] = { |
938 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetNamespaceInfo"), |
939 | 1.77k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
940 | 1.77k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetNamespaceInfo)].metrics); |
941 | 1.77k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetNamespaceInfoRequestPB, ::yb::master::GetNamespaceInfoResponsePB>>( |
942 | 1.77k | std::move(call), [this](const ::yb::master::GetNamespaceInfoRequestPB* req, ::yb::master::GetNamespaceInfoResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
943 | 1.77k | GetNamespaceInfo(req, resp, std::move(rpc_context)); |
944 | 1.77k | }); |
945 | 1.77k | }, |
946 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
947 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetNamespaceInfo.Instantiate(entity), |
948 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetNamespaceInfo.Instantiate(entity), |
949 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetNamespaceInfo.Instantiate(entity)) |
950 | 5.42k | }; |
951 | | |
952 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTablegroup)] = { |
953 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "CreateTablegroup"), |
954 | 2 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
955 | 2 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateTablegroup)].metrics); |
956 | 2 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateTablegroupRequestPB, ::yb::master::CreateTablegroupResponsePB>>( |
957 | 1 | std::move(call), [this](const ::yb::master::CreateTablegroupRequestPB* req, ::yb::master::CreateTablegroupResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
958 | 1 | CreateTablegroup(req, resp, std::move(rpc_context)); |
959 | 1 | }); |
960 | 2 | }, |
961 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
962 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_CreateTablegroup.Instantiate(entity), |
963 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_CreateTablegroup.Instantiate(entity), |
964 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_CreateTablegroup.Instantiate(entity)) |
965 | 5.42k | }; |
966 | | |
967 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTablegroup)] = { |
968 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "DeleteTablegroup"), |
969 | 4 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
970 | 4 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteTablegroup)].metrics); |
971 | 4 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteTablegroupRequestPB, ::yb::master::DeleteTablegroupResponsePB>>( |
972 | 1 | std::move(call), [this](const ::yb::master::DeleteTablegroupRequestPB* req, ::yb::master::DeleteTablegroupResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
973 | 1 | DeleteTablegroup(req, resp, std::move(rpc_context)); |
974 | 1 | }); |
975 | 4 | }, |
976 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
977 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_DeleteTablegroup.Instantiate(entity), |
978 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_DeleteTablegroup.Instantiate(entity), |
979 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_DeleteTablegroup.Instantiate(entity)) |
980 | 5.42k | }; |
981 | | |
982 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTablegroups)] = { |
983 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListTablegroups"), |
984 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
985 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListTablegroups)].metrics); |
986 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListTablegroupsRequestPB, ::yb::master::ListTablegroupsResponsePB>>( |
987 | 0 | std::move(call), [this](const ::yb::master::ListTablegroupsRequestPB* req, ::yb::master::ListTablegroupsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
988 | 0 | ListTablegroups(req, resp, std::move(rpc_context)); |
989 | 0 | }); |
990 | 0 | }, |
991 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
992 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_ListTablegroups.Instantiate(entity), |
993 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_ListTablegroups.Instantiate(entity), |
994 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_ListTablegroups.Instantiate(entity)) |
995 | 5.42k | }; |
996 | | |
997 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateUDType)] = { |
998 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "CreateUDType"), |
999 | 46 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
1000 | 46 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kCreateUDType)].metrics); |
1001 | 46 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateUDTypeRequestPB, ::yb::master::CreateUDTypeResponsePB>>( |
1002 | 46 | std::move(call), [this](const ::yb::master::CreateUDTypeRequestPB* req, ::yb::master::CreateUDTypeResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
1003 | 46 | CreateUDType(req, resp, std::move(rpc_context)); |
1004 | 46 | }); |
1005 | 46 | }, |
1006 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
1007 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_CreateUDType.Instantiate(entity), |
1008 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_CreateUDType.Instantiate(entity), |
1009 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_CreateUDType.Instantiate(entity)) |
1010 | 5.42k | }; |
1011 | | |
1012 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteUDType)] = { |
1013 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "DeleteUDType"), |
1014 | 53 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
1015 | 53 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kDeleteUDType)].metrics); |
1016 | 53 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteUDTypeRequestPB, ::yb::master::DeleteUDTypeResponsePB>>( |
1017 | 53 | std::move(call), [this](const ::yb::master::DeleteUDTypeRequestPB* req, ::yb::master::DeleteUDTypeResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
1018 | 53 | DeleteUDType(req, resp, std::move(rpc_context)); |
1019 | 53 | }); |
1020 | 53 | }, |
1021 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
1022 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_DeleteUDType.Instantiate(entity), |
1023 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_DeleteUDType.Instantiate(entity), |
1024 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_DeleteUDType.Instantiate(entity)) |
1025 | 5.42k | }; |
1026 | | |
1027 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListUDTypes)] = { |
1028 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "ListUDTypes"), |
1029 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
1030 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kListUDTypes)].metrics); |
1031 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListUDTypesRequestPB, ::yb::master::ListUDTypesResponsePB>>( |
1032 | 0 | std::move(call), [this](const ::yb::master::ListUDTypesRequestPB* req, ::yb::master::ListUDTypesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
1033 | 0 | ListUDTypes(req, resp, std::move(rpc_context)); |
1034 | 0 | }); |
1035 | 0 | }, |
1036 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
1037 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_ListUDTypes.Instantiate(entity), |
1038 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_ListUDTypes.Instantiate(entity), |
1039 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_ListUDTypes.Instantiate(entity)) |
1040 | 5.42k | }; |
1041 | | |
1042 | 5.42k | methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetUDTypeInfo)] = { |
1043 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterService", "GetUDTypeInfo"), |
1044 | 55 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
1045 | 55 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterDdlRpcMethodIndexes::kGetUDTypeInfo)].metrics); |
1046 | 55 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::GetUDTypeInfoRequestPB, ::yb::master::GetUDTypeInfoResponsePB>>( |
1047 | 55 | std::move(call), [this](const ::yb::master::GetUDTypeInfoRequestPB* req, ::yb::master::GetUDTypeInfoResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
1048 | 55 | GetUDTypeInfo(req, resp, std::move(rpc_context)); |
1049 | 55 | }); |
1050 | 55 | }, |
1051 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
1052 | 5.42k | METRIC_service_request_bytes_yb_master_MasterDdl_GetUDTypeInfo.Instantiate(entity), |
1053 | 5.42k | METRIC_service_response_bytes_yb_master_MasterDdl_GetUDTypeInfo.Instantiate(entity), |
1054 | 5.42k | METRIC_handler_latency_yb_master_MasterDdl_GetUDTypeInfo.Instantiate(entity)) |
1055 | 5.42k | }; |
1056 | | |
1057 | 5.42k | } |
1058 | | |
1059 | | } // namespace master |
1060 | | } // namespace yb |