/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/tserver_service.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/tserver_service.proto |
2 | | |
3 | | #include "yb/tserver/tserver_service.pb.h" |
4 | | #include "yb/tserver/tserver_service.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_tserver_TabletServerService_Write, |
18 | | "Bytes received by yb.tserver.TabletServerService.Write() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.tserver.TabletServerService.Write() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_tserver_TabletServerService_Write, |
24 | | "Bytes sent in response to yb.tserver.TabletServerService.Write() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.tserver.TabletServerService.Write() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_tserver_TabletServerService_Write, |
30 | | "Microseconds spent handling yb.tserver.TabletServerService.Write() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.tserver.TabletServerService.Write() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_tserver_TabletServerService_Read, |
37 | | "Bytes received by yb.tserver.TabletServerService.Read() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.tserver.TabletServerService.Read() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_tserver_TabletServerService_Read, |
43 | | "Bytes sent in response to yb.tserver.TabletServerService.Read() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.tserver.TabletServerService.Read() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_tserver_TabletServerService_Read, |
49 | | "Microseconds spent handling yb.tserver.TabletServerService.Read() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.tserver.TabletServerService.Read() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, service_request_bytes_yb_tserver_TabletServerService_VerifyTableRowRange, |
56 | | "Bytes received by yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received by yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, service_response_bytes_yb_tserver_TabletServerService_VerifyTableRowRange, |
62 | | "Bytes sent in response to yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent in response to yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_histogram_with_percentiles( |
67 | | server, handler_latency_yb_tserver_TabletServerService_VerifyTableRowRange, |
68 | | "Microseconds spent handling yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
69 | | yb::MetricUnit::kMicroseconds, |
70 | | "Microseconds spent handling yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
71 | | 60000000LU, 2); |
72 | | |
73 | | METRIC_DEFINE_counter( |
74 | | server, service_request_bytes_yb_tserver_TabletServerService_NoOp, |
75 | | "Bytes received by yb.tserver.TabletServerService.NoOp() RPC requests", |
76 | | yb::MetricUnit::kBytes, |
77 | | "Bytes received by yb.tserver.TabletServerService.NoOp() RPC requests"); |
78 | | |
79 | | METRIC_DEFINE_counter( |
80 | | server, service_response_bytes_yb_tserver_TabletServerService_NoOp, |
81 | | "Bytes sent in response to yb.tserver.TabletServerService.NoOp() RPC requests", |
82 | | yb::MetricUnit::kBytes, |
83 | | "Bytes sent in response to yb.tserver.TabletServerService.NoOp() RPC requests"); |
84 | | |
85 | | METRIC_DEFINE_histogram_with_percentiles( |
86 | | server, handler_latency_yb_tserver_TabletServerService_NoOp, |
87 | | "Microseconds spent handling yb.tserver.TabletServerService.NoOp() RPC requests", |
88 | | yb::MetricUnit::kMicroseconds, |
89 | | "Microseconds spent handling yb.tserver.TabletServerService.NoOp() RPC requests", |
90 | | 60000000LU, 2); |
91 | | |
92 | | METRIC_DEFINE_counter( |
93 | | server, service_request_bytes_yb_tserver_TabletServerService_ListTablets, |
94 | | "Bytes received by yb.tserver.TabletServerService.ListTablets() RPC requests", |
95 | | yb::MetricUnit::kBytes, |
96 | | "Bytes received by yb.tserver.TabletServerService.ListTablets() RPC requests"); |
97 | | |
98 | | METRIC_DEFINE_counter( |
99 | | server, service_response_bytes_yb_tserver_TabletServerService_ListTablets, |
100 | | "Bytes sent in response to yb.tserver.TabletServerService.ListTablets() RPC requests", |
101 | | yb::MetricUnit::kBytes, |
102 | | "Bytes sent in response to yb.tserver.TabletServerService.ListTablets() RPC requests"); |
103 | | |
104 | | METRIC_DEFINE_histogram_with_percentiles( |
105 | | server, handler_latency_yb_tserver_TabletServerService_ListTablets, |
106 | | "Microseconds spent handling yb.tserver.TabletServerService.ListTablets() RPC requests", |
107 | | yb::MetricUnit::kMicroseconds, |
108 | | "Microseconds spent handling yb.tserver.TabletServerService.ListTablets() RPC requests", |
109 | | 60000000LU, 2); |
110 | | |
111 | | METRIC_DEFINE_counter( |
112 | | server, service_request_bytes_yb_tserver_TabletServerService_GetLogLocation, |
113 | | "Bytes received by yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
114 | | yb::MetricUnit::kBytes, |
115 | | "Bytes received by yb.tserver.TabletServerService.GetLogLocation() RPC requests"); |
116 | | |
117 | | METRIC_DEFINE_counter( |
118 | | server, service_response_bytes_yb_tserver_TabletServerService_GetLogLocation, |
119 | | "Bytes sent in response to yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
120 | | yb::MetricUnit::kBytes, |
121 | | "Bytes sent in response to yb.tserver.TabletServerService.GetLogLocation() RPC requests"); |
122 | | |
123 | | METRIC_DEFINE_histogram_with_percentiles( |
124 | | server, handler_latency_yb_tserver_TabletServerService_GetLogLocation, |
125 | | "Microseconds spent handling yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
126 | | yb::MetricUnit::kMicroseconds, |
127 | | "Microseconds spent handling yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
128 | | 60000000LU, 2); |
129 | | |
130 | | METRIC_DEFINE_counter( |
131 | | server, service_request_bytes_yb_tserver_TabletServerService_Checksum, |
132 | | "Bytes received by yb.tserver.TabletServerService.Checksum() RPC requests", |
133 | | yb::MetricUnit::kBytes, |
134 | | "Bytes received by yb.tserver.TabletServerService.Checksum() RPC requests"); |
135 | | |
136 | | METRIC_DEFINE_counter( |
137 | | server, service_response_bytes_yb_tserver_TabletServerService_Checksum, |
138 | | "Bytes sent in response to yb.tserver.TabletServerService.Checksum() RPC requests", |
139 | | yb::MetricUnit::kBytes, |
140 | | "Bytes sent in response to yb.tserver.TabletServerService.Checksum() RPC requests"); |
141 | | |
142 | | METRIC_DEFINE_histogram_with_percentiles( |
143 | | server, handler_latency_yb_tserver_TabletServerService_Checksum, |
144 | | "Microseconds spent handling yb.tserver.TabletServerService.Checksum() RPC requests", |
145 | | yb::MetricUnit::kMicroseconds, |
146 | | "Microseconds spent handling yb.tserver.TabletServerService.Checksum() RPC requests", |
147 | | 60000000LU, 2); |
148 | | |
149 | | METRIC_DEFINE_counter( |
150 | | server, service_request_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer, |
151 | | "Bytes received by yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
152 | | yb::MetricUnit::kBytes, |
153 | | "Bytes received by yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests"); |
154 | | |
155 | | METRIC_DEFINE_counter( |
156 | | server, service_response_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer, |
157 | | "Bytes sent in response to yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
158 | | yb::MetricUnit::kBytes, |
159 | | "Bytes sent in response to yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests"); |
160 | | |
161 | | METRIC_DEFINE_histogram_with_percentiles( |
162 | | server, handler_latency_yb_tserver_TabletServerService_ListTabletsForTabletServer, |
163 | | "Microseconds spent handling yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
164 | | yb::MetricUnit::kMicroseconds, |
165 | | "Microseconds spent handling yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
166 | | 60000000LU, 2); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, service_request_bytes_yb_tserver_TabletServerService_ImportData, |
170 | | "Bytes received by yb.tserver.TabletServerService.ImportData() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes received by yb.tserver.TabletServerService.ImportData() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, service_response_bytes_yb_tserver_TabletServerService_ImportData, |
176 | | "Bytes sent in response to yb.tserver.TabletServerService.ImportData() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes sent in response to yb.tserver.TabletServerService.ImportData() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_histogram_with_percentiles( |
181 | | server, handler_latency_yb_tserver_TabletServerService_ImportData, |
182 | | "Microseconds spent handling yb.tserver.TabletServerService.ImportData() RPC requests", |
183 | | yb::MetricUnit::kMicroseconds, |
184 | | "Microseconds spent handling yb.tserver.TabletServerService.ImportData() RPC requests", |
185 | | 60000000LU, 2); |
186 | | |
187 | | METRIC_DEFINE_counter( |
188 | | server, service_request_bytes_yb_tserver_TabletServerService_UpdateTransaction, |
189 | | "Bytes received by yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
190 | | yb::MetricUnit::kBytes, |
191 | | "Bytes received by yb.tserver.TabletServerService.UpdateTransaction() RPC requests"); |
192 | | |
193 | | METRIC_DEFINE_counter( |
194 | | server, service_response_bytes_yb_tserver_TabletServerService_UpdateTransaction, |
195 | | "Bytes sent in response to yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
196 | | yb::MetricUnit::kBytes, |
197 | | "Bytes sent in response to yb.tserver.TabletServerService.UpdateTransaction() RPC requests"); |
198 | | |
199 | | METRIC_DEFINE_histogram_with_percentiles( |
200 | | server, handler_latency_yb_tserver_TabletServerService_UpdateTransaction, |
201 | | "Microseconds spent handling yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
202 | | yb::MetricUnit::kMicroseconds, |
203 | | "Microseconds spent handling yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
204 | | 60000000LU, 2); |
205 | | |
206 | | METRIC_DEFINE_counter( |
207 | | server, service_request_bytes_yb_tserver_TabletServerService_GetTransactionStatus, |
208 | | "Bytes received by yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
209 | | yb::MetricUnit::kBytes, |
210 | | "Bytes received by yb.tserver.TabletServerService.GetTransactionStatus() RPC requests"); |
211 | | |
212 | | METRIC_DEFINE_counter( |
213 | | server, service_response_bytes_yb_tserver_TabletServerService_GetTransactionStatus, |
214 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
215 | | yb::MetricUnit::kBytes, |
216 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTransactionStatus() RPC requests"); |
217 | | |
218 | | METRIC_DEFINE_histogram_with_percentiles( |
219 | | server, handler_latency_yb_tserver_TabletServerService_GetTransactionStatus, |
220 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
221 | | yb::MetricUnit::kMicroseconds, |
222 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
223 | | 60000000LU, 2); |
224 | | |
225 | | METRIC_DEFINE_counter( |
226 | | server, service_request_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant, |
227 | | "Bytes received by yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
228 | | yb::MetricUnit::kBytes, |
229 | | "Bytes received by yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests"); |
230 | | |
231 | | METRIC_DEFINE_counter( |
232 | | server, service_response_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant, |
233 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
234 | | yb::MetricUnit::kBytes, |
235 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests"); |
236 | | |
237 | | METRIC_DEFINE_histogram_with_percentiles( |
238 | | server, handler_latency_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant, |
239 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
240 | | yb::MetricUnit::kMicroseconds, |
241 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
242 | | 60000000LU, 2); |
243 | | |
244 | | METRIC_DEFINE_counter( |
245 | | server, service_request_bytes_yb_tserver_TabletServerService_AbortTransaction, |
246 | | "Bytes received by yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
247 | | yb::MetricUnit::kBytes, |
248 | | "Bytes received by yb.tserver.TabletServerService.AbortTransaction() RPC requests"); |
249 | | |
250 | | METRIC_DEFINE_counter( |
251 | | server, service_response_bytes_yb_tserver_TabletServerService_AbortTransaction, |
252 | | "Bytes sent in response to yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
253 | | yb::MetricUnit::kBytes, |
254 | | "Bytes sent in response to yb.tserver.TabletServerService.AbortTransaction() RPC requests"); |
255 | | |
256 | | METRIC_DEFINE_histogram_with_percentiles( |
257 | | server, handler_latency_yb_tserver_TabletServerService_AbortTransaction, |
258 | | "Microseconds spent handling yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
259 | | yb::MetricUnit::kMicroseconds, |
260 | | "Microseconds spent handling yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
261 | | 60000000LU, 2); |
262 | | |
263 | | METRIC_DEFINE_counter( |
264 | | server, service_request_bytes_yb_tserver_TabletServerService_Truncate, |
265 | | "Bytes received by yb.tserver.TabletServerService.Truncate() RPC requests", |
266 | | yb::MetricUnit::kBytes, |
267 | | "Bytes received by yb.tserver.TabletServerService.Truncate() RPC requests"); |
268 | | |
269 | | METRIC_DEFINE_counter( |
270 | | server, service_response_bytes_yb_tserver_TabletServerService_Truncate, |
271 | | "Bytes sent in response to yb.tserver.TabletServerService.Truncate() RPC requests", |
272 | | yb::MetricUnit::kBytes, |
273 | | "Bytes sent in response to yb.tserver.TabletServerService.Truncate() RPC requests"); |
274 | | |
275 | | METRIC_DEFINE_histogram_with_percentiles( |
276 | | server, handler_latency_yb_tserver_TabletServerService_Truncate, |
277 | | "Microseconds spent handling yb.tserver.TabletServerService.Truncate() RPC requests", |
278 | | yb::MetricUnit::kMicroseconds, |
279 | | "Microseconds spent handling yb.tserver.TabletServerService.Truncate() RPC requests", |
280 | | 60000000LU, 2); |
281 | | |
282 | | METRIC_DEFINE_counter( |
283 | | server, service_request_bytes_yb_tserver_TabletServerService_GetTabletStatus, |
284 | | "Bytes received by yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
285 | | yb::MetricUnit::kBytes, |
286 | | "Bytes received by yb.tserver.TabletServerService.GetTabletStatus() RPC requests"); |
287 | | |
288 | | METRIC_DEFINE_counter( |
289 | | server, service_response_bytes_yb_tserver_TabletServerService_GetTabletStatus, |
290 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
291 | | yb::MetricUnit::kBytes, |
292 | | "Bytes sent in response to yb.tserver.TabletServerService.GetTabletStatus() RPC requests"); |
293 | | |
294 | | METRIC_DEFINE_histogram_with_percentiles( |
295 | | server, handler_latency_yb_tserver_TabletServerService_GetTabletStatus, |
296 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
297 | | yb::MetricUnit::kMicroseconds, |
298 | | "Microseconds spent handling yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
299 | | 60000000LU, 2); |
300 | | |
301 | | METRIC_DEFINE_counter( |
302 | | server, service_request_bytes_yb_tserver_TabletServerService_GetMasterAddresses, |
303 | | "Bytes received by yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
304 | | yb::MetricUnit::kBytes, |
305 | | "Bytes received by yb.tserver.TabletServerService.GetMasterAddresses() RPC requests"); |
306 | | |
307 | | METRIC_DEFINE_counter( |
308 | | server, service_response_bytes_yb_tserver_TabletServerService_GetMasterAddresses, |
309 | | "Bytes sent in response to yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
310 | | yb::MetricUnit::kBytes, |
311 | | "Bytes sent in response to yb.tserver.TabletServerService.GetMasterAddresses() RPC requests"); |
312 | | |
313 | | METRIC_DEFINE_histogram_with_percentiles( |
314 | | server, handler_latency_yb_tserver_TabletServerService_GetMasterAddresses, |
315 | | "Microseconds spent handling yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
316 | | yb::MetricUnit::kMicroseconds, |
317 | | "Microseconds spent handling yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
318 | | 60000000LU, 2); |
319 | | |
320 | | METRIC_DEFINE_counter( |
321 | | server, service_request_bytes_yb_tserver_TabletServerService_Publish, |
322 | | "Bytes received by yb.tserver.TabletServerService.Publish() RPC requests", |
323 | | yb::MetricUnit::kBytes, |
324 | | "Bytes received by yb.tserver.TabletServerService.Publish() RPC requests"); |
325 | | |
326 | | METRIC_DEFINE_counter( |
327 | | server, service_response_bytes_yb_tserver_TabletServerService_Publish, |
328 | | "Bytes sent in response to yb.tserver.TabletServerService.Publish() RPC requests", |
329 | | yb::MetricUnit::kBytes, |
330 | | "Bytes sent in response to yb.tserver.TabletServerService.Publish() RPC requests"); |
331 | | |
332 | | METRIC_DEFINE_histogram_with_percentiles( |
333 | | server, handler_latency_yb_tserver_TabletServerService_Publish, |
334 | | "Microseconds spent handling yb.tserver.TabletServerService.Publish() RPC requests", |
335 | | yb::MetricUnit::kMicroseconds, |
336 | | "Microseconds spent handling yb.tserver.TabletServerService.Publish() RPC requests", |
337 | | 60000000LU, 2); |
338 | | |
339 | | METRIC_DEFINE_counter( |
340 | | server, service_request_bytes_yb_tserver_TabletServerService_IsTabletServerReady, |
341 | | "Bytes received by yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
342 | | yb::MetricUnit::kBytes, |
343 | | "Bytes received by yb.tserver.TabletServerService.IsTabletServerReady() RPC requests"); |
344 | | |
345 | | METRIC_DEFINE_counter( |
346 | | server, service_response_bytes_yb_tserver_TabletServerService_IsTabletServerReady, |
347 | | "Bytes sent in response to yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
348 | | yb::MetricUnit::kBytes, |
349 | | "Bytes sent in response to yb.tserver.TabletServerService.IsTabletServerReady() RPC requests"); |
350 | | |
351 | | METRIC_DEFINE_histogram_with_percentiles( |
352 | | server, handler_latency_yb_tserver_TabletServerService_IsTabletServerReady, |
353 | | "Microseconds spent handling yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
354 | | yb::MetricUnit::kMicroseconds, |
355 | | "Microseconds spent handling yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
356 | | 60000000LU, 2); |
357 | | |
358 | | METRIC_DEFINE_counter( |
359 | | server, service_request_bytes_yb_tserver_TabletServerService_TakeTransaction, |
360 | | "Bytes received by yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
361 | | yb::MetricUnit::kBytes, |
362 | | "Bytes received by yb.tserver.TabletServerService.TakeTransaction() RPC requests"); |
363 | | |
364 | | METRIC_DEFINE_counter( |
365 | | server, service_response_bytes_yb_tserver_TabletServerService_TakeTransaction, |
366 | | "Bytes sent in response to yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
367 | | yb::MetricUnit::kBytes, |
368 | | "Bytes sent in response to yb.tserver.TabletServerService.TakeTransaction() RPC requests"); |
369 | | |
370 | | METRIC_DEFINE_histogram_with_percentiles( |
371 | | server, handler_latency_yb_tserver_TabletServerService_TakeTransaction, |
372 | | "Microseconds spent handling yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
373 | | yb::MetricUnit::kMicroseconds, |
374 | | "Microseconds spent handling yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
375 | | 60000000LU, 2); |
376 | | |
377 | | METRIC_DEFINE_counter( |
378 | | server, service_request_bytes_yb_tserver_TabletServerService_GetSplitKey, |
379 | | "Bytes received by yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
380 | | yb::MetricUnit::kBytes, |
381 | | "Bytes received by yb.tserver.TabletServerService.GetSplitKey() RPC requests"); |
382 | | |
383 | | METRIC_DEFINE_counter( |
384 | | server, service_response_bytes_yb_tserver_TabletServerService_GetSplitKey, |
385 | | "Bytes sent in response to yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
386 | | yb::MetricUnit::kBytes, |
387 | | "Bytes sent in response to yb.tserver.TabletServerService.GetSplitKey() RPC requests"); |
388 | | |
389 | | METRIC_DEFINE_histogram_with_percentiles( |
390 | | server, handler_latency_yb_tserver_TabletServerService_GetSplitKey, |
391 | | "Microseconds spent handling yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
392 | | yb::MetricUnit::kMicroseconds, |
393 | | "Microseconds spent handling yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
394 | | 60000000LU, 2); |
395 | | |
396 | | METRIC_DEFINE_counter( |
397 | | server, service_request_bytes_yb_tserver_TabletServerService_GetSharedData, |
398 | | "Bytes received by yb.tserver.TabletServerService.GetSharedData() RPC requests", |
399 | | yb::MetricUnit::kBytes, |
400 | | "Bytes received by yb.tserver.TabletServerService.GetSharedData() RPC requests"); |
401 | | |
402 | | METRIC_DEFINE_counter( |
403 | | server, service_response_bytes_yb_tserver_TabletServerService_GetSharedData, |
404 | | "Bytes sent in response to yb.tserver.TabletServerService.GetSharedData() RPC requests", |
405 | | yb::MetricUnit::kBytes, |
406 | | "Bytes sent in response to yb.tserver.TabletServerService.GetSharedData() RPC requests"); |
407 | | |
408 | | METRIC_DEFINE_histogram_with_percentiles( |
409 | | server, handler_latency_yb_tserver_TabletServerService_GetSharedData, |
410 | | "Microseconds spent handling yb.tserver.TabletServerService.GetSharedData() RPC requests", |
411 | | yb::MetricUnit::kMicroseconds, |
412 | | "Microseconds spent handling yb.tserver.TabletServerService.GetSharedData() RPC requests", |
413 | | 60000000LU, 2); |
414 | | |
415 | | namespace yb { |
416 | | namespace tserver { |
417 | | |
418 | 11.2k | TabletServerServiceIf::TabletServerServiceIf(const scoped_refptr<MetricEntity>& entity) { |
419 | 11.2k | InitMethods(entity); |
420 | 11.2k | } |
421 | | |
422 | 160 | TabletServerServiceIf::~TabletServerServiceIf() { |
423 | 160 | } |
424 | | |
425 | 11.2k | void TabletServerServiceIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
426 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite))); |
427 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead))); |
428 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange))); |
429 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp))); |
430 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets))); |
431 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation))); |
432 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum))); |
433 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer))); |
434 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData))); |
435 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction))); |
436 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus))); |
437 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant))); |
438 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction))); |
439 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate))); |
440 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus))); |
441 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses))); |
442 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish))); |
443 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady))); |
444 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction))); |
445 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey))); |
446 | 11.2k | map->emplace(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData))); |
447 | 11.2k | } |
448 | | |
449 | 7.97M | void TabletServerServiceIf::Handle(::yb::rpc::InboundCallPtr call) { |
450 | 7.97M | auto index = call->method_index(); |
451 | 7.97M | methods_[index].handler(std::move(call)); |
452 | 7.97M | } |
453 | | |
454 | 33.7k | std::string TabletServerServiceIf::service_name() const { |
455 | 33.7k | return "yb.tserver.TabletServerService"; |
456 | 33.7k | } |
457 | 0 | std::string TabletServerServiceIf::static_service_name() { |
458 | 0 | return "yb.tserver.TabletServerService"; |
459 | 0 | } |
460 | | |
461 | 11.2k | void TabletServerServiceIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
462 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite)] = { |
463 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "Write"), |
464 | 1.39M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
465 | 1.39M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite)].metrics); |
466 | 1.39M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::WriteRequestPB, ::yb::tserver::WriteResponsePB>>( |
467 | 1.39M | std::move(call), [this](const ::yb::tserver::WriteRequestPB* req, ::yb::tserver::WriteResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
468 | 1.39M | Write(req, resp, std::move(rpc_context)); |
469 | 1.39M | }); |
470 | 1.39M | }, |
471 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
472 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_Write.Instantiate(entity), |
473 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_Write.Instantiate(entity), |
474 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_Write.Instantiate(entity)) |
475 | 11.2k | }; |
476 | | |
477 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead)] = { |
478 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "Read"), |
479 | 4.70M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
480 | 4.70M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead)].metrics); |
481 | 4.70M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ReadRequestPB, ::yb::tserver::ReadResponsePB>>( |
482 | 4.70M | std::move(call), [this](const ::yb::tserver::ReadRequestPB* req, ::yb::tserver::ReadResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
483 | 4.70M | Read(req, resp, std::move(rpc_context)); |
484 | 4.70M | }); |
485 | 4.70M | }, |
486 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
487 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_Read.Instantiate(entity), |
488 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_Read.Instantiate(entity), |
489 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_Read.Instantiate(entity)) |
490 | 11.2k | }; |
491 | | |
492 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)] = { |
493 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "VerifyTableRowRange"), |
494 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
495 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)].metrics); |
496 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::VerifyTableRowRangeRequestPB, ::yb::tserver::VerifyTableRowRangeResponsePB>>( |
497 | 0 | std::move(call), [this](const ::yb::tserver::VerifyTableRowRangeRequestPB* req, ::yb::tserver::VerifyTableRowRangeResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
498 | 0 | VerifyTableRowRange(req, resp, std::move(rpc_context)); |
499 | 0 | }); |
500 | 0 | }, |
501 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
502 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_VerifyTableRowRange.Instantiate(entity), |
503 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_VerifyTableRowRange.Instantiate(entity), |
504 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_VerifyTableRowRange.Instantiate(entity)) |
505 | 11.2k | }; |
506 | | |
507 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp)] = { |
508 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "NoOp"), |
509 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
510 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp)].metrics); |
511 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::NoOpRequestPB, ::yb::tserver::NoOpResponsePB>>( |
512 | 0 | std::move(call), [this](const ::yb::tserver::NoOpRequestPB* req, ::yb::tserver::NoOpResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
513 | 0 | NoOp(req, resp, std::move(rpc_context)); |
514 | 0 | }); |
515 | 0 | }, |
516 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
517 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_NoOp.Instantiate(entity), |
518 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_NoOp.Instantiate(entity), |
519 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_NoOp.Instantiate(entity)) |
520 | 11.2k | }; |
521 | | |
522 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets)] = { |
523 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "ListTablets"), |
524 | 213 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
525 | 213 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets)].metrics); |
526 | 213 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ListTabletsRequestPB, ::yb::tserver::ListTabletsResponsePB>>( |
527 | 213 | std::move(call), [this](const ::yb::tserver::ListTabletsRequestPB* req, ::yb::tserver::ListTabletsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
528 | 213 | ListTablets(req, resp, std::move(rpc_context)); |
529 | 213 | }); |
530 | 213 | }, |
531 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
532 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_ListTablets.Instantiate(entity), |
533 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_ListTablets.Instantiate(entity), |
534 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_ListTablets.Instantiate(entity)) |
535 | 11.2k | }; |
536 | | |
537 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation)] = { |
538 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetLogLocation"), |
539 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
540 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation)].metrics); |
541 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetLogLocationRequestPB, ::yb::tserver::GetLogLocationResponsePB>>( |
542 | 0 | std::move(call), [this](const ::yb::tserver::GetLogLocationRequestPB* req, ::yb::tserver::GetLogLocationResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
543 | 0 | GetLogLocation(req, resp, std::move(rpc_context)); |
544 | 0 | }); |
545 | 0 | }, |
546 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
547 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetLogLocation.Instantiate(entity), |
548 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetLogLocation.Instantiate(entity), |
549 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetLogLocation.Instantiate(entity)) |
550 | 11.2k | }; |
551 | | |
552 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum)] = { |
553 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "Checksum"), |
554 | 2.90k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
555 | 2.90k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum)].metrics); |
556 | 2.90k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ChecksumRequestPB, ::yb::tserver::ChecksumResponsePB>>( |
557 | 2.90k | std::move(call), [this](const ::yb::tserver::ChecksumRequestPB* req, ::yb::tserver::ChecksumResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
558 | 2.90k | Checksum(req, resp, std::move(rpc_context)); |
559 | 2.90k | }); |
560 | 2.90k | }, |
561 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
562 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_Checksum.Instantiate(entity), |
563 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_Checksum.Instantiate(entity), |
564 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_Checksum.Instantiate(entity)) |
565 | 11.2k | }; |
566 | | |
567 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)] = { |
568 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "ListTabletsForTabletServer"), |
569 | 892 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
570 | 892 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)].metrics); |
571 | 892 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ListTabletsForTabletServerRequestPB, ::yb::tserver::ListTabletsForTabletServerResponsePB>>( |
572 | 892 | std::move(call), [this](const ::yb::tserver::ListTabletsForTabletServerRequestPB* req, ::yb::tserver::ListTabletsForTabletServerResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
573 | 892 | ListTabletsForTabletServer(req, resp, std::move(rpc_context)); |
574 | 892 | }); |
575 | 892 | }, |
576 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
577 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer.Instantiate(entity), |
578 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer.Instantiate(entity), |
579 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_ListTabletsForTabletServer.Instantiate(entity)) |
580 | 11.2k | }; |
581 | | |
582 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData)] = { |
583 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "ImportData"), |
584 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
585 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData)].metrics); |
586 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::ImportDataRequestPB, ::yb::tserver::ImportDataResponsePB>>( |
587 | 0 | std::move(call), [this](const ::yb::tserver::ImportDataRequestPB* req, ::yb::tserver::ImportDataResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
588 | 0 | ImportData(req, resp, std::move(rpc_context)); |
589 | 0 | }); |
590 | 0 | }, |
591 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
592 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_ImportData.Instantiate(entity), |
593 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_ImportData.Instantiate(entity), |
594 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_ImportData.Instantiate(entity)) |
595 | 11.2k | }; |
596 | | |
597 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)] = { |
598 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "UpdateTransaction"), |
599 | 1.48M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
600 | 1.48M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)].metrics); |
601 | 1.48M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::UpdateTransactionRequestPB, ::yb::tserver::UpdateTransactionResponsePB>>( |
602 | 1.48M | std::move(call), [this](const ::yb::tserver::UpdateTransactionRequestPB* req, ::yb::tserver::UpdateTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
603 | 1.48M | UpdateTransaction(req, resp, std::move(rpc_context)); |
604 | 1.48M | }); |
605 | 1.48M | }, |
606 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
607 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_UpdateTransaction.Instantiate(entity), |
608 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_UpdateTransaction.Instantiate(entity), |
609 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_UpdateTransaction.Instantiate(entity)) |
610 | 11.2k | }; |
611 | | |
612 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)] = { |
613 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetTransactionStatus"), |
614 | 208k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
615 | 208k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)].metrics); |
616 | 208k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetTransactionStatusRequestPB, ::yb::tserver::GetTransactionStatusResponsePB>>( |
617 | 208k | std::move(call), [this](const ::yb::tserver::GetTransactionStatusRequestPB* req, ::yb::tserver::GetTransactionStatusResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
618 | 208k | GetTransactionStatus(req, resp, std::move(rpc_context)); |
619 | 208k | }); |
620 | 208k | }, |
621 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
622 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetTransactionStatus.Instantiate(entity), |
623 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetTransactionStatus.Instantiate(entity), |
624 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetTransactionStatus.Instantiate(entity)) |
625 | 11.2k | }; |
626 | | |
627 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)] = { |
628 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetTransactionStatusAtParticipant"), |
629 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
630 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)].metrics); |
631 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetTransactionStatusAtParticipantRequestPB, ::yb::tserver::GetTransactionStatusAtParticipantResponsePB>>( |
632 | 0 | std::move(call), [this](const ::yb::tserver::GetTransactionStatusAtParticipantRequestPB* req, ::yb::tserver::GetTransactionStatusAtParticipantResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
633 | 0 | GetTransactionStatusAtParticipant(req, resp, std::move(rpc_context)); |
634 | 0 | }); |
635 | 0 | }, |
636 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
637 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant.Instantiate(entity), |
638 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant.Instantiate(entity), |
639 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant.Instantiate(entity)) |
640 | 11.2k | }; |
641 | | |
642 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction)] = { |
643 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "AbortTransaction"), |
644 | 126k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
645 | 126k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction)].metrics); |
646 | 126k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::AbortTransactionRequestPB, ::yb::tserver::AbortTransactionResponsePB>>( |
647 | 126k | std::move(call), [this](const ::yb::tserver::AbortTransactionRequestPB* req, ::yb::tserver::AbortTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
648 | 126k | AbortTransaction(req, resp, std::move(rpc_context)); |
649 | 126k | }); |
650 | 126k | }, |
651 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
652 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_AbortTransaction.Instantiate(entity), |
653 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_AbortTransaction.Instantiate(entity), |
654 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_AbortTransaction.Instantiate(entity)) |
655 | 11.2k | }; |
656 | | |
657 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate)] = { |
658 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "Truncate"), |
659 | 53.5k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
660 | 53.5k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate)].metrics); |
661 | 53.5k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::TruncateRequestPB, ::yb::tserver::TruncateResponsePB>>( |
662 | 53.5k | std::move(call), [this](const ::yb::tserver::TruncateRequestPB* req, ::yb::tserver::TruncateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
663 | 53.5k | Truncate(req, resp, std::move(rpc_context)); |
664 | 53.5k | }); |
665 | 53.5k | }, |
666 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
667 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_Truncate.Instantiate(entity), |
668 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_Truncate.Instantiate(entity), |
669 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_Truncate.Instantiate(entity)) |
670 | 11.2k | }; |
671 | | |
672 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)] = { |
673 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetTabletStatus"), |
674 | 1 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
675 | 1 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)].metrics); |
676 | 1 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetTabletStatusRequestPB, ::yb::tserver::GetTabletStatusResponsePB>>( |
677 | 1 | std::move(call), [this](const ::yb::tserver::GetTabletStatusRequestPB* req, ::yb::tserver::GetTabletStatusResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
678 | 1 | GetTabletStatus(req, resp, std::move(rpc_context)); |
679 | 1 | }); |
680 | 1 | }, |
681 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
682 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetTabletStatus.Instantiate(entity), |
683 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetTabletStatus.Instantiate(entity), |
684 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetTabletStatus.Instantiate(entity)) |
685 | 11.2k | }; |
686 | | |
687 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)] = { |
688 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetMasterAddresses"), |
689 | 6 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
690 | 6 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)].metrics); |
691 | 6 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetMasterAddressesRequestPB, ::yb::tserver::GetMasterAddressesResponsePB>>( |
692 | 6 | std::move(call), [this](const ::yb::tserver::GetMasterAddressesRequestPB* req, ::yb::tserver::GetMasterAddressesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
693 | 6 | GetMasterAddresses(req, resp, std::move(rpc_context)); |
694 | 6 | }); |
695 | 6 | }, |
696 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
697 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetMasterAddresses.Instantiate(entity), |
698 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetMasterAddresses.Instantiate(entity), |
699 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetMasterAddresses.Instantiate(entity)) |
700 | 11.2k | }; |
701 | | |
702 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish)] = { |
703 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "Publish"), |
704 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
705 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish)].metrics); |
706 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PublishRequestPB, ::yb::tserver::PublishResponsePB>>( |
707 | 0 | std::move(call), [this](const ::yb::tserver::PublishRequestPB* req, ::yb::tserver::PublishResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
708 | 0 | Publish(req, resp, std::move(rpc_context)); |
709 | 0 | }); |
710 | 0 | }, |
711 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
712 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_Publish.Instantiate(entity), |
713 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_Publish.Instantiate(entity), |
714 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_Publish.Instantiate(entity)) |
715 | 11.2k | }; |
716 | | |
717 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)] = { |
718 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "IsTabletServerReady"), |
719 | 18 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
720 | 18 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)].metrics); |
721 | 18 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::IsTabletServerReadyRequestPB, ::yb::tserver::IsTabletServerReadyResponsePB>>( |
722 | 18 | std::move(call), [this](const ::yb::tserver::IsTabletServerReadyRequestPB* req, ::yb::tserver::IsTabletServerReadyResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
723 | 18 | IsTabletServerReady(req, resp, std::move(rpc_context)); |
724 | 18 | }); |
725 | 18 | }, |
726 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
727 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_IsTabletServerReady.Instantiate(entity), |
728 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_IsTabletServerReady.Instantiate(entity), |
729 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_IsTabletServerReady.Instantiate(entity)) |
730 | 11.2k | }; |
731 | | |
732 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction)] = { |
733 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "TakeTransaction"), |
734 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
735 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction)].metrics); |
736 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::TakeTransactionRequestPB, ::yb::tserver::TakeTransactionResponsePB>>( |
737 | 0 | std::move(call), [this](const ::yb::tserver::TakeTransactionRequestPB* req, ::yb::tserver::TakeTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
738 | 0 | TakeTransaction(req, resp, std::move(rpc_context)); |
739 | 0 | }); |
740 | 0 | }, |
741 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
742 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_TakeTransaction.Instantiate(entity), |
743 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_TakeTransaction.Instantiate(entity), |
744 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_TakeTransaction.Instantiate(entity)) |
745 | 11.2k | }; |
746 | | |
747 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey)] = { |
748 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetSplitKey"), |
749 | 49 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
750 | 49 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey)].metrics); |
751 | 49 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetSplitKeyRequestPB, ::yb::tserver::GetSplitKeyResponsePB>>( |
752 | 49 | std::move(call), [this](const ::yb::tserver::GetSplitKeyRequestPB* req, ::yb::tserver::GetSplitKeyResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
753 | 49 | GetSplitKey(req, resp, std::move(rpc_context)); |
754 | 49 | }); |
755 | 49 | }, |
756 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
757 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetSplitKey.Instantiate(entity), |
758 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetSplitKey.Instantiate(entity), |
759 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetSplitKey.Instantiate(entity)) |
760 | 11.2k | }; |
761 | | |
762 | 11.2k | methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData)] = { |
763 | 11.2k | .method = ::yb::rpc::RemoteMethod("yb.tserver.TabletServerService", "GetSharedData"), |
764 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
765 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData)].metrics); |
766 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::GetSharedDataRequestPB, ::yb::tserver::GetSharedDataResponsePB>>( |
767 | 0 | std::move(call), [this](const ::yb::tserver::GetSharedDataRequestPB* req, ::yb::tserver::GetSharedDataResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
768 | 0 | GetSharedData(req, resp, std::move(rpc_context)); |
769 | 0 | }); |
770 | 0 | }, |
771 | 11.2k | .metrics = ::yb::rpc::RpcMethodMetrics( |
772 | 11.2k | METRIC_service_request_bytes_yb_tserver_TabletServerService_GetSharedData.Instantiate(entity), |
773 | 11.2k | METRIC_service_response_bytes_yb_tserver_TabletServerService_GetSharedData.Instantiate(entity), |
774 | 11.2k | METRIC_handler_latency_yb_tserver_TabletServerService_GetSharedData.Instantiate(entity)) |
775 | 11.2k | }; |
776 | | |
777 | 11.2k | } |
778 | | |
779 | | } // namespace tserver |
780 | | } // namespace yb |