YugabyteDB (2.13.0.0-b42, bfc6a6643e7399ac8a0e81d06a3ee6d6571b33ab)

Coverage Report

Created: 2022-03-09 17:30

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/pg_client.service.cc
Line
Count
Source (jump to first uncovered line)
1
// THIS FILE IS AUTOGENERATED FROM yb/tserver/pg_client.proto
2
3
#include "yb/tserver/pg_client.pb.h"
4
#include "yb/tserver/pg_client.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_PgClientService_Heartbeat,
18
  "Bytes received by yb.tserver.PgClientService.Heartbeat() RPC requests",
19
  yb::MetricUnit::kBytes,
20
  "Bytes received by yb.tserver.PgClientService.Heartbeat() RPC requests");
21
22
METRIC_DEFINE_counter(
23
  server, service_response_bytes_yb_tserver_PgClientService_Heartbeat,
24
  "Bytes sent in response to yb.tserver.PgClientService.Heartbeat() RPC requests",
25
  yb::MetricUnit::kBytes,
26
  "Bytes sent in response to yb.tserver.PgClientService.Heartbeat() RPC requests");
27
28
METRIC_DEFINE_histogram_with_percentiles(
29
  server, handler_latency_yb_tserver_PgClientService_Heartbeat,
30
  "Microseconds spent handling yb.tserver.PgClientService.Heartbeat() RPC requests",
31
  yb::MetricUnit::kMicroseconds,
32
  "Microseconds spent handling yb.tserver.PgClientService.Heartbeat() RPC requests",
33
  60000000LU, 2);
34
35
METRIC_DEFINE_counter(
36
  server, service_request_bytes_yb_tserver_PgClientService_AlterDatabase,
37
  "Bytes received by yb.tserver.PgClientService.AlterDatabase() RPC requests",
38
  yb::MetricUnit::kBytes,
39
  "Bytes received by yb.tserver.PgClientService.AlterDatabase() RPC requests");
40
41
METRIC_DEFINE_counter(
42
  server, service_response_bytes_yb_tserver_PgClientService_AlterDatabase,
43
  "Bytes sent in response to yb.tserver.PgClientService.AlterDatabase() RPC requests",
44
  yb::MetricUnit::kBytes,
45
  "Bytes sent in response to yb.tserver.PgClientService.AlterDatabase() RPC requests");
46
47
METRIC_DEFINE_histogram_with_percentiles(
48
  server, handler_latency_yb_tserver_PgClientService_AlterDatabase,
49
  "Microseconds spent handling yb.tserver.PgClientService.AlterDatabase() RPC requests",
50
  yb::MetricUnit::kMicroseconds,
51
  "Microseconds spent handling yb.tserver.PgClientService.AlterDatabase() RPC requests",
52
  60000000LU, 2);
53
54
METRIC_DEFINE_counter(
55
  server, service_request_bytes_yb_tserver_PgClientService_AlterTable,
56
  "Bytes received by yb.tserver.PgClientService.AlterTable() RPC requests",
57
  yb::MetricUnit::kBytes,
58
  "Bytes received by yb.tserver.PgClientService.AlterTable() RPC requests");
59
60
METRIC_DEFINE_counter(
61
  server, service_response_bytes_yb_tserver_PgClientService_AlterTable,
62
  "Bytes sent in response to yb.tserver.PgClientService.AlterTable() RPC requests",
63
  yb::MetricUnit::kBytes,
64
  "Bytes sent in response to yb.tserver.PgClientService.AlterTable() RPC requests");
65
66
METRIC_DEFINE_histogram_with_percentiles(
67
  server, handler_latency_yb_tserver_PgClientService_AlterTable,
68
  "Microseconds spent handling yb.tserver.PgClientService.AlterTable() RPC requests",
69
  yb::MetricUnit::kMicroseconds,
70
  "Microseconds spent handling yb.tserver.PgClientService.AlterTable() RPC requests",
71
  60000000LU, 2);
72
73
METRIC_DEFINE_counter(
74
  server, service_request_bytes_yb_tserver_PgClientService_BackfillIndex,
75
  "Bytes received by yb.tserver.PgClientService.BackfillIndex() RPC requests",
76
  yb::MetricUnit::kBytes,
77
  "Bytes received by yb.tserver.PgClientService.BackfillIndex() RPC requests");
78
79
METRIC_DEFINE_counter(
80
  server, service_response_bytes_yb_tserver_PgClientService_BackfillIndex,
81
  "Bytes sent in response to yb.tserver.PgClientService.BackfillIndex() RPC requests",
82
  yb::MetricUnit::kBytes,
83
  "Bytes sent in response to yb.tserver.PgClientService.BackfillIndex() RPC requests");
84
85
METRIC_DEFINE_histogram_with_percentiles(
86
  server, handler_latency_yb_tserver_PgClientService_BackfillIndex,
87
  "Microseconds spent handling yb.tserver.PgClientService.BackfillIndex() RPC requests",
88
  yb::MetricUnit::kMicroseconds,
89
  "Microseconds spent handling yb.tserver.PgClientService.BackfillIndex() RPC requests",
90
  60000000LU, 2);
91
92
METRIC_DEFINE_counter(
93
  server, service_request_bytes_yb_tserver_PgClientService_CreateDatabase,
94
  "Bytes received by yb.tserver.PgClientService.CreateDatabase() RPC requests",
95
  yb::MetricUnit::kBytes,
96
  "Bytes received by yb.tserver.PgClientService.CreateDatabase() RPC requests");
97
98
METRIC_DEFINE_counter(
99
  server, service_response_bytes_yb_tserver_PgClientService_CreateDatabase,
100
  "Bytes sent in response to yb.tserver.PgClientService.CreateDatabase() RPC requests",
101
  yb::MetricUnit::kBytes,
102
  "Bytes sent in response to yb.tserver.PgClientService.CreateDatabase() RPC requests");
103
104
METRIC_DEFINE_histogram_with_percentiles(
105
  server, handler_latency_yb_tserver_PgClientService_CreateDatabase,
106
  "Microseconds spent handling yb.tserver.PgClientService.CreateDatabase() RPC requests",
107
  yb::MetricUnit::kMicroseconds,
108
  "Microseconds spent handling yb.tserver.PgClientService.CreateDatabase() RPC requests",
109
  60000000LU, 2);
110
111
METRIC_DEFINE_counter(
112
  server, service_request_bytes_yb_tserver_PgClientService_CreateSequencesDataTable,
113
  "Bytes received by yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
114
  yb::MetricUnit::kBytes,
115
  "Bytes received by yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests");
116
117
METRIC_DEFINE_counter(
118
  server, service_response_bytes_yb_tserver_PgClientService_CreateSequencesDataTable,
119
  "Bytes sent in response to yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
120
  yb::MetricUnit::kBytes,
121
  "Bytes sent in response to yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests");
122
123
METRIC_DEFINE_histogram_with_percentiles(
124
  server, handler_latency_yb_tserver_PgClientService_CreateSequencesDataTable,
125
  "Microseconds spent handling yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
126
  yb::MetricUnit::kMicroseconds,
127
  "Microseconds spent handling yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
128
  60000000LU, 2);
129
130
METRIC_DEFINE_counter(
131
  server, service_request_bytes_yb_tserver_PgClientService_CreateTable,
132
  "Bytes received by yb.tserver.PgClientService.CreateTable() RPC requests",
133
  yb::MetricUnit::kBytes,
134
  "Bytes received by yb.tserver.PgClientService.CreateTable() RPC requests");
135
136
METRIC_DEFINE_counter(
137
  server, service_response_bytes_yb_tserver_PgClientService_CreateTable,
138
  "Bytes sent in response to yb.tserver.PgClientService.CreateTable() RPC requests",
139
  yb::MetricUnit::kBytes,
140
  "Bytes sent in response to yb.tserver.PgClientService.CreateTable() RPC requests");
141
142
METRIC_DEFINE_histogram_with_percentiles(
143
  server, handler_latency_yb_tserver_PgClientService_CreateTable,
144
  "Microseconds spent handling yb.tserver.PgClientService.CreateTable() RPC requests",
145
  yb::MetricUnit::kMicroseconds,
146
  "Microseconds spent handling yb.tserver.PgClientService.CreateTable() RPC requests",
147
  60000000LU, 2);
148
149
METRIC_DEFINE_counter(
150
  server, service_request_bytes_yb_tserver_PgClientService_CreateTablegroup,
151
  "Bytes received by yb.tserver.PgClientService.CreateTablegroup() RPC requests",
152
  yb::MetricUnit::kBytes,
153
  "Bytes received by yb.tserver.PgClientService.CreateTablegroup() RPC requests");
154
155
METRIC_DEFINE_counter(
156
  server, service_response_bytes_yb_tserver_PgClientService_CreateTablegroup,
157
  "Bytes sent in response to yb.tserver.PgClientService.CreateTablegroup() RPC requests",
158
  yb::MetricUnit::kBytes,
159
  "Bytes sent in response to yb.tserver.PgClientService.CreateTablegroup() RPC requests");
160
161
METRIC_DEFINE_histogram_with_percentiles(
162
  server, handler_latency_yb_tserver_PgClientService_CreateTablegroup,
163
  "Microseconds spent handling yb.tserver.PgClientService.CreateTablegroup() RPC requests",
164
  yb::MetricUnit::kMicroseconds,
165
  "Microseconds spent handling yb.tserver.PgClientService.CreateTablegroup() RPC requests",
166
  60000000LU, 2);
167
168
METRIC_DEFINE_counter(
169
  server, service_request_bytes_yb_tserver_PgClientService_DropDatabase,
170
  "Bytes received by yb.tserver.PgClientService.DropDatabase() RPC requests",
171
  yb::MetricUnit::kBytes,
172
  "Bytes received by yb.tserver.PgClientService.DropDatabase() RPC requests");
173
174
METRIC_DEFINE_counter(
175
  server, service_response_bytes_yb_tserver_PgClientService_DropDatabase,
176
  "Bytes sent in response to yb.tserver.PgClientService.DropDatabase() RPC requests",
177
  yb::MetricUnit::kBytes,
178
  "Bytes sent in response to yb.tserver.PgClientService.DropDatabase() RPC requests");
179
180
METRIC_DEFINE_histogram_with_percentiles(
181
  server, handler_latency_yb_tserver_PgClientService_DropDatabase,
182
  "Microseconds spent handling yb.tserver.PgClientService.DropDatabase() RPC requests",
183
  yb::MetricUnit::kMicroseconds,
184
  "Microseconds spent handling yb.tserver.PgClientService.DropDatabase() RPC requests",
185
  60000000LU, 2);
186
187
METRIC_DEFINE_counter(
188
  server, service_request_bytes_yb_tserver_PgClientService_DropTable,
189
  "Bytes received by yb.tserver.PgClientService.DropTable() RPC requests",
190
  yb::MetricUnit::kBytes,
191
  "Bytes received by yb.tserver.PgClientService.DropTable() RPC requests");
192
193
METRIC_DEFINE_counter(
194
  server, service_response_bytes_yb_tserver_PgClientService_DropTable,
195
  "Bytes sent in response to yb.tserver.PgClientService.DropTable() RPC requests",
196
  yb::MetricUnit::kBytes,
197
  "Bytes sent in response to yb.tserver.PgClientService.DropTable() RPC requests");
198
199
METRIC_DEFINE_histogram_with_percentiles(
200
  server, handler_latency_yb_tserver_PgClientService_DropTable,
201
  "Microseconds spent handling yb.tserver.PgClientService.DropTable() RPC requests",
202
  yb::MetricUnit::kMicroseconds,
203
  "Microseconds spent handling yb.tserver.PgClientService.DropTable() RPC requests",
204
  60000000LU, 2);
205
206
METRIC_DEFINE_counter(
207
  server, service_request_bytes_yb_tserver_PgClientService_DropTablegroup,
208
  "Bytes received by yb.tserver.PgClientService.DropTablegroup() RPC requests",
209
  yb::MetricUnit::kBytes,
210
  "Bytes received by yb.tserver.PgClientService.DropTablegroup() RPC requests");
211
212
METRIC_DEFINE_counter(
213
  server, service_response_bytes_yb_tserver_PgClientService_DropTablegroup,
214
  "Bytes sent in response to yb.tserver.PgClientService.DropTablegroup() RPC requests",
215
  yb::MetricUnit::kBytes,
216
  "Bytes sent in response to yb.tserver.PgClientService.DropTablegroup() RPC requests");
217
218
METRIC_DEFINE_histogram_with_percentiles(
219
  server, handler_latency_yb_tserver_PgClientService_DropTablegroup,
220
  "Microseconds spent handling yb.tserver.PgClientService.DropTablegroup() RPC requests",
221
  yb::MetricUnit::kMicroseconds,
222
  "Microseconds spent handling yb.tserver.PgClientService.DropTablegroup() RPC requests",
223
  60000000LU, 2);
224
225
METRIC_DEFINE_counter(
226
  server, service_request_bytes_yb_tserver_PgClientService_FinishTransaction,
227
  "Bytes received by yb.tserver.PgClientService.FinishTransaction() RPC requests",
228
  yb::MetricUnit::kBytes,
229
  "Bytes received by yb.tserver.PgClientService.FinishTransaction() RPC requests");
230
231
METRIC_DEFINE_counter(
232
  server, service_response_bytes_yb_tserver_PgClientService_FinishTransaction,
233
  "Bytes sent in response to yb.tserver.PgClientService.FinishTransaction() RPC requests",
234
  yb::MetricUnit::kBytes,
235
  "Bytes sent in response to yb.tserver.PgClientService.FinishTransaction() RPC requests");
236
237
METRIC_DEFINE_histogram_with_percentiles(
238
  server, handler_latency_yb_tserver_PgClientService_FinishTransaction,
239
  "Microseconds spent handling yb.tserver.PgClientService.FinishTransaction() RPC requests",
240
  yb::MetricUnit::kMicroseconds,
241
  "Microseconds spent handling yb.tserver.PgClientService.FinishTransaction() RPC requests",
242
  60000000LU, 2);
243
244
METRIC_DEFINE_counter(
245
  server, service_request_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion,
246
  "Bytes received by yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
247
  yb::MetricUnit::kBytes,
248
  "Bytes received by yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests");
249
250
METRIC_DEFINE_counter(
251
  server, service_response_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion,
252
  "Bytes sent in response to yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
253
  yb::MetricUnit::kBytes,
254
  "Bytes sent in response to yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests");
255
256
METRIC_DEFINE_histogram_with_percentiles(
257
  server, handler_latency_yb_tserver_PgClientService_GetCatalogMasterVersion,
258
  "Microseconds spent handling yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
259
  yb::MetricUnit::kMicroseconds,
260
  "Microseconds spent handling yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
261
  60000000LU, 2);
262
263
METRIC_DEFINE_counter(
264
  server, service_request_bytes_yb_tserver_PgClientService_GetDatabaseInfo,
265
  "Bytes received by yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
266
  yb::MetricUnit::kBytes,
267
  "Bytes received by yb.tserver.PgClientService.GetDatabaseInfo() RPC requests");
268
269
METRIC_DEFINE_counter(
270
  server, service_response_bytes_yb_tserver_PgClientService_GetDatabaseInfo,
271
  "Bytes sent in response to yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
272
  yb::MetricUnit::kBytes,
273
  "Bytes sent in response to yb.tserver.PgClientService.GetDatabaseInfo() RPC requests");
274
275
METRIC_DEFINE_histogram_with_percentiles(
276
  server, handler_latency_yb_tserver_PgClientService_GetDatabaseInfo,
277
  "Microseconds spent handling yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
278
  yb::MetricUnit::kMicroseconds,
279
  "Microseconds spent handling yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
280
  60000000LU, 2);
281
282
METRIC_DEFINE_counter(
283
  server, service_request_bytes_yb_tserver_PgClientService_IsInitDbDone,
284
  "Bytes received by yb.tserver.PgClientService.IsInitDbDone() RPC requests",
285
  yb::MetricUnit::kBytes,
286
  "Bytes received by yb.tserver.PgClientService.IsInitDbDone() RPC requests");
287
288
METRIC_DEFINE_counter(
289
  server, service_response_bytes_yb_tserver_PgClientService_IsInitDbDone,
290
  "Bytes sent in response to yb.tserver.PgClientService.IsInitDbDone() RPC requests",
291
  yb::MetricUnit::kBytes,
292
  "Bytes sent in response to yb.tserver.PgClientService.IsInitDbDone() RPC requests");
293
294
METRIC_DEFINE_histogram_with_percentiles(
295
  server, handler_latency_yb_tserver_PgClientService_IsInitDbDone,
296
  "Microseconds spent handling yb.tserver.PgClientService.IsInitDbDone() RPC requests",
297
  yb::MetricUnit::kMicroseconds,
298
  "Microseconds spent handling yb.tserver.PgClientService.IsInitDbDone() RPC requests",
299
  60000000LU, 2);
300
301
METRIC_DEFINE_counter(
302
  server, service_request_bytes_yb_tserver_PgClientService_ListLiveTabletServers,
303
  "Bytes received by yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
304
  yb::MetricUnit::kBytes,
305
  "Bytes received by yb.tserver.PgClientService.ListLiveTabletServers() RPC requests");
306
307
METRIC_DEFINE_counter(
308
  server, service_response_bytes_yb_tserver_PgClientService_ListLiveTabletServers,
309
  "Bytes sent in response to yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
310
  yb::MetricUnit::kBytes,
311
  "Bytes sent in response to yb.tserver.PgClientService.ListLiveTabletServers() RPC requests");
312
313
METRIC_DEFINE_histogram_with_percentiles(
314
  server, handler_latency_yb_tserver_PgClientService_ListLiveTabletServers,
315
  "Microseconds spent handling yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
316
  yb::MetricUnit::kMicroseconds,
317
  "Microseconds spent handling yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
318
  60000000LU, 2);
319
320
METRIC_DEFINE_counter(
321
  server, service_request_bytes_yb_tserver_PgClientService_OpenTable,
322
  "Bytes received by yb.tserver.PgClientService.OpenTable() RPC requests",
323
  yb::MetricUnit::kBytes,
324
  "Bytes received by yb.tserver.PgClientService.OpenTable() RPC requests");
325
326
METRIC_DEFINE_counter(
327
  server, service_response_bytes_yb_tserver_PgClientService_OpenTable,
328
  "Bytes sent in response to yb.tserver.PgClientService.OpenTable() RPC requests",
329
  yb::MetricUnit::kBytes,
330
  "Bytes sent in response to yb.tserver.PgClientService.OpenTable() RPC requests");
331
332
METRIC_DEFINE_histogram_with_percentiles(
333
  server, handler_latency_yb_tserver_PgClientService_OpenTable,
334
  "Microseconds spent handling yb.tserver.PgClientService.OpenTable() RPC requests",
335
  yb::MetricUnit::kMicroseconds,
336
  "Microseconds spent handling yb.tserver.PgClientService.OpenTable() RPC requests",
337
  60000000LU, 2);
338
339
METRIC_DEFINE_counter(
340
  server, service_request_bytes_yb_tserver_PgClientService_Perform,
341
  "Bytes received by yb.tserver.PgClientService.Perform() RPC requests",
342
  yb::MetricUnit::kBytes,
343
  "Bytes received by yb.tserver.PgClientService.Perform() RPC requests");
344
345
METRIC_DEFINE_counter(
346
  server, service_response_bytes_yb_tserver_PgClientService_Perform,
347
  "Bytes sent in response to yb.tserver.PgClientService.Perform() RPC requests",
348
  yb::MetricUnit::kBytes,
349
  "Bytes sent in response to yb.tserver.PgClientService.Perform() RPC requests");
350
351
METRIC_DEFINE_histogram_with_percentiles(
352
  server, handler_latency_yb_tserver_PgClientService_Perform,
353
  "Microseconds spent handling yb.tserver.PgClientService.Perform() RPC requests",
354
  yb::MetricUnit::kMicroseconds,
355
  "Microseconds spent handling yb.tserver.PgClientService.Perform() RPC requests",
356
  60000000LU, 2);
357
358
METRIC_DEFINE_counter(
359
  server, service_request_bytes_yb_tserver_PgClientService_ReserveOids,
360
  "Bytes received by yb.tserver.PgClientService.ReserveOids() RPC requests",
361
  yb::MetricUnit::kBytes,
362
  "Bytes received by yb.tserver.PgClientService.ReserveOids() RPC requests");
363
364
METRIC_DEFINE_counter(
365
  server, service_response_bytes_yb_tserver_PgClientService_ReserveOids,
366
  "Bytes sent in response to yb.tserver.PgClientService.ReserveOids() RPC requests",
367
  yb::MetricUnit::kBytes,
368
  "Bytes sent in response to yb.tserver.PgClientService.ReserveOids() RPC requests");
369
370
METRIC_DEFINE_histogram_with_percentiles(
371
  server, handler_latency_yb_tserver_PgClientService_ReserveOids,
372
  "Microseconds spent handling yb.tserver.PgClientService.ReserveOids() RPC requests",
373
  yb::MetricUnit::kMicroseconds,
374
  "Microseconds spent handling yb.tserver.PgClientService.ReserveOids() RPC requests",
375
  60000000LU, 2);
376
377
METRIC_DEFINE_counter(
378
  server, service_request_bytes_yb_tserver_PgClientService_RollbackSubTransaction,
379
  "Bytes received by yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
380
  yb::MetricUnit::kBytes,
381
  "Bytes received by yb.tserver.PgClientService.RollbackSubTransaction() RPC requests");
382
383
METRIC_DEFINE_counter(
384
  server, service_response_bytes_yb_tserver_PgClientService_RollbackSubTransaction,
385
  "Bytes sent in response to yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
386
  yb::MetricUnit::kBytes,
387
  "Bytes sent in response to yb.tserver.PgClientService.RollbackSubTransaction() RPC requests");
388
389
METRIC_DEFINE_histogram_with_percentiles(
390
  server, handler_latency_yb_tserver_PgClientService_RollbackSubTransaction,
391
  "Microseconds spent handling yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
392
  yb::MetricUnit::kMicroseconds,
393
  "Microseconds spent handling yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
394
  60000000LU, 2);
395
396
METRIC_DEFINE_counter(
397
  server, service_request_bytes_yb_tserver_PgClientService_SetActiveSubTransaction,
398
  "Bytes received by yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
399
  yb::MetricUnit::kBytes,
400
  "Bytes received by yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests");
401
402
METRIC_DEFINE_counter(
403
  server, service_response_bytes_yb_tserver_PgClientService_SetActiveSubTransaction,
404
  "Bytes sent in response to yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
405
  yb::MetricUnit::kBytes,
406
  "Bytes sent in response to yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests");
407
408
METRIC_DEFINE_histogram_with_percentiles(
409
  server, handler_latency_yb_tserver_PgClientService_SetActiveSubTransaction,
410
  "Microseconds spent handling yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
411
  yb::MetricUnit::kMicroseconds,
412
  "Microseconds spent handling yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
413
  60000000LU, 2);
414
415
METRIC_DEFINE_counter(
416
  server, service_request_bytes_yb_tserver_PgClientService_TabletServerCount,
417
  "Bytes received by yb.tserver.PgClientService.TabletServerCount() RPC requests",
418
  yb::MetricUnit::kBytes,
419
  "Bytes received by yb.tserver.PgClientService.TabletServerCount() RPC requests");
420
421
METRIC_DEFINE_counter(
422
  server, service_response_bytes_yb_tserver_PgClientService_TabletServerCount,
423
  "Bytes sent in response to yb.tserver.PgClientService.TabletServerCount() RPC requests",
424
  yb::MetricUnit::kBytes,
425
  "Bytes sent in response to yb.tserver.PgClientService.TabletServerCount() RPC requests");
426
427
METRIC_DEFINE_histogram_with_percentiles(
428
  server, handler_latency_yb_tserver_PgClientService_TabletServerCount,
429
  "Microseconds spent handling yb.tserver.PgClientService.TabletServerCount() RPC requests",
430
  yb::MetricUnit::kMicroseconds,
431
  "Microseconds spent handling yb.tserver.PgClientService.TabletServerCount() RPC requests",
432
  60000000LU, 2);
433
434
METRIC_DEFINE_counter(
435
  server, service_request_bytes_yb_tserver_PgClientService_TruncateTable,
436
  "Bytes received by yb.tserver.PgClientService.TruncateTable() RPC requests",
437
  yb::MetricUnit::kBytes,
438
  "Bytes received by yb.tserver.PgClientService.TruncateTable() RPC requests");
439
440
METRIC_DEFINE_counter(
441
  server, service_response_bytes_yb_tserver_PgClientService_TruncateTable,
442
  "Bytes sent in response to yb.tserver.PgClientService.TruncateTable() RPC requests",
443
  yb::MetricUnit::kBytes,
444
  "Bytes sent in response to yb.tserver.PgClientService.TruncateTable() RPC requests");
445
446
METRIC_DEFINE_histogram_with_percentiles(
447
  server, handler_latency_yb_tserver_PgClientService_TruncateTable,
448
  "Microseconds spent handling yb.tserver.PgClientService.TruncateTable() RPC requests",
449
  yb::MetricUnit::kMicroseconds,
450
  "Microseconds spent handling yb.tserver.PgClientService.TruncateTable() RPC requests",
451
  60000000LU, 2);
452
453
METRIC_DEFINE_counter(
454
  server, service_request_bytes_yb_tserver_PgClientService_ValidatePlacement,
455
  "Bytes received by yb.tserver.PgClientService.ValidatePlacement() RPC requests",
456
  yb::MetricUnit::kBytes,
457
  "Bytes received by yb.tserver.PgClientService.ValidatePlacement() RPC requests");
458
459
METRIC_DEFINE_counter(
460
  server, service_response_bytes_yb_tserver_PgClientService_ValidatePlacement,
461
  "Bytes sent in response to yb.tserver.PgClientService.ValidatePlacement() RPC requests",
462
  yb::MetricUnit::kBytes,
463
  "Bytes sent in response to yb.tserver.PgClientService.ValidatePlacement() RPC requests");
464
465
METRIC_DEFINE_histogram_with_percentiles(
466
  server, handler_latency_yb_tserver_PgClientService_ValidatePlacement,
467
  "Microseconds spent handling yb.tserver.PgClientService.ValidatePlacement() RPC requests",
468
  yb::MetricUnit::kMicroseconds,
469
  "Microseconds spent handling yb.tserver.PgClientService.ValidatePlacement() RPC requests",
470
  60000000LU, 2);
471
472
namespace yb {
473
namespace tserver {
474
475
11.2k
PgClientServiceIf::PgClientServiceIf(const scoped_refptr<MetricEntity>& entity) {
476
11.2k
  InitMethods(entity);
477
11.2k
}
478
479
160
PgClientServiceIf::~PgClientServiceIf() {
480
160
}
481
482
11.2k
void PgClientServiceIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) {
483
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)));
484
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)));
485
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)));
486
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)));
487
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)));
488
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)));
489
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)));
490
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)));
491
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)));
492
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)));
493
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)));
494
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)));
495
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)));
496
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)));
497
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)));
498
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)));
499
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)));
500
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)));
501
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)));
502
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)));
503
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)));
504
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)));
505
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)));
506
11.2k
  map->emplace(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)));
507
11.2k
}
508
509
1.00M
void PgClientServiceIf::Handle(::yb::rpc::InboundCallPtr call) {
510
1.00M
  auto index = call->method_index();
511
1.00M
  methods_[index].handler(std::move(call));
512
1.00M
}
513
514
33.7k
std::string PgClientServiceIf::service_name() const {
515
33.7k
  return "yb.tserver.PgClientService";
516
33.7k
}
517
0
std::string PgClientServiceIf::static_service_name() {
518
0
  return "yb.tserver.PgClientService";
519
0
}
520
521
11.2k
void PgClientServiceIf::InitMethods(const scoped_refptr<MetricEntity>& entity) {
522
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)] = {
523
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "Heartbeat"),
524
2.74k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
525
2.74k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)].metrics);
526
2.74k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgHeartbeatRequestPB, ::yb::tserver::PgHeartbeatResponsePB>>(
527
2.74k
          std::move(call), [this](const ::yb::tserver::PgHeartbeatRequestPB* req, ::yb::tserver::PgHeartbeatResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
528
2.74k
        Heartbeat(req, resp, std::move(rpc_context));
529
2.74k
      });
530
2.74k
    },
531
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
532
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_Heartbeat.Instantiate(entity),
533
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_Heartbeat.Instantiate(entity),
534
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_Heartbeat.Instantiate(entity))
535
11.2k
  };
536
537
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)] = {
538
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "AlterDatabase"),
539
0
    .handler = [this](::yb::rpc::InboundCallPtr call) {
540
0
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)].metrics);
541
0
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgAlterDatabaseRequestPB, ::yb::tserver::PgAlterDatabaseResponsePB>>(
542
0
          std::move(call), [this](const ::yb::tserver::PgAlterDatabaseRequestPB* req, ::yb::tserver::PgAlterDatabaseResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
543
0
        AlterDatabase(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_PgClientService_AlterDatabase.Instantiate(entity),
548
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_AlterDatabase.Instantiate(entity),
549
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_AlterDatabase.Instantiate(entity))
550
11.2k
  };
551
552
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)] = {
553
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "AlterTable"),
554
155
    .handler = [this](::yb::rpc::InboundCallPtr call) {
555
155
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)].metrics);
556
155
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgAlterTableRequestPB, ::yb::tserver::PgAlterTableResponsePB>>(
557
155
          std::move(call), [this](const ::yb::tserver::PgAlterTableRequestPB* req, ::yb::tserver::PgAlterTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
558
155
        AlterTable(req, resp, std::move(rpc_context));
559
155
      });
560
155
    },
561
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
562
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_AlterTable.Instantiate(entity),
563
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_AlterTable.Instantiate(entity),
564
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_AlterTable.Instantiate(entity))
565
11.2k
  };
566
567
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)] = {
568
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "BackfillIndex"),
569
89
    .handler = [this](::yb::rpc::InboundCallPtr call) {
570
89
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)].metrics);
571
89
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgBackfillIndexRequestPB, ::yb::tserver::PgBackfillIndexResponsePB>>(
572
89
          std::move(call), [this](const ::yb::tserver::PgBackfillIndexRequestPB* req, ::yb::tserver::PgBackfillIndexResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
573
89
        BackfillIndex(req, resp, std::move(rpc_context));
574
89
      });
575
89
    },
576
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
577
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_BackfillIndex.Instantiate(entity),
578
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_BackfillIndex.Instantiate(entity),
579
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_BackfillIndex.Instantiate(entity))
580
11.2k
  };
581
582
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)] = {
583
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "CreateDatabase"),
584
22
    .handler = [this](::yb::rpc::InboundCallPtr call) {
585
22
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)].metrics);
586
22
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgCreateDatabaseRequestPB, ::yb::tserver::PgCreateDatabaseResponsePB>>(
587
22
          std::move(call), [this](const ::yb::tserver::PgCreateDatabaseRequestPB* req, ::yb::tserver::PgCreateDatabaseResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
588
22
        CreateDatabase(req, resp, std::move(rpc_context));
589
22
      });
590
22
    },
591
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
592
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_CreateDatabase.Instantiate(entity),
593
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_CreateDatabase.Instantiate(entity),
594
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_CreateDatabase.Instantiate(entity))
595
11.2k
  };
596
597
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)] = {
598
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "CreateSequencesDataTable"),
599
21
    .handler = [this](::yb::rpc::InboundCallPtr call) {
600
21
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)].metrics);
601
21
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgCreateSequencesDataTableRequestPB, ::yb::tserver::PgCreateSequencesDataTableResponsePB>>(
602
21
          std::move(call), [this](const ::yb::tserver::PgCreateSequencesDataTableRequestPB* req, ::yb::tserver::PgCreateSequencesDataTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
603
21
        CreateSequencesDataTable(req, resp, std::move(rpc_context));
604
21
      });
605
21
    },
606
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
607
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_CreateSequencesDataTable.Instantiate(entity),
608
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_CreateSequencesDataTable.Instantiate(entity),
609
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_CreateSequencesDataTable.Instantiate(entity))
610
11.2k
  };
611
612
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)] = {
613
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "CreateTable"),
614
1.41k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
615
1.41k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)].metrics);
616
1.41k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgCreateTableRequestPB, ::yb::tserver::PgCreateTableResponsePB>>(
617
1.41k
          std::move(call), [this](const ::yb::tserver::PgCreateTableRequestPB* req, ::yb::tserver::PgCreateTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
618
1.41k
        CreateTable(req, resp, std::move(rpc_context));
619
1.41k
      });
620
1.41k
    },
621
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
622
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_CreateTable.Instantiate(entity),
623
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_CreateTable.Instantiate(entity),
624
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_CreateTable.Instantiate(entity))
625
11.2k
  };
626
627
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)] = {
628
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "CreateTablegroup"),
629
1
    .handler = [this](::yb::rpc::InboundCallPtr call) {
630
1
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)].metrics);
631
1
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgCreateTablegroupRequestPB, ::yb::tserver::PgCreateTablegroupResponsePB>>(
632
1
          std::move(call), [this](const ::yb::tserver::PgCreateTablegroupRequestPB* req, ::yb::tserver::PgCreateTablegroupResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
633
1
        CreateTablegroup(req, resp, std::move(rpc_context));
634
1
      });
635
1
    },
636
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
637
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_CreateTablegroup.Instantiate(entity),
638
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_CreateTablegroup.Instantiate(entity),
639
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_CreateTablegroup.Instantiate(entity))
640
11.2k
  };
641
642
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)] = {
643
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "DropDatabase"),
644
21
    .handler = [this](::yb::rpc::InboundCallPtr call) {
645
21
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)].metrics);
646
21
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgDropDatabaseRequestPB, ::yb::tserver::PgDropDatabaseResponsePB>>(
647
21
          std::move(call), [this](const ::yb::tserver::PgDropDatabaseRequestPB* req, ::yb::tserver::PgDropDatabaseResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
648
21
        DropDatabase(req, resp, std::move(rpc_context));
649
21
      });
650
21
    },
651
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
652
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_DropDatabase.Instantiate(entity),
653
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_DropDatabase.Instantiate(entity),
654
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_DropDatabase.Instantiate(entity))
655
11.2k
  };
656
657
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)] = {
658
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "DropTable"),
659
1.17k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
660
1.17k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)].metrics);
661
1.17k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgDropTableRequestPB, ::yb::tserver::PgDropTableResponsePB>>(
662
1.17k
          std::move(call), [this](const ::yb::tserver::PgDropTableRequestPB* req, ::yb::tserver::PgDropTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
663
1.17k
        DropTable(req, resp, std::move(rpc_context));
664
1.17k
      });
665
1.17k
    },
666
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
667
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_DropTable.Instantiate(entity),
668
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_DropTable.Instantiate(entity),
669
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_DropTable.Instantiate(entity))
670
11.2k
  };
671
672
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)] = {
673
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "DropTablegroup"),
674
1
    .handler = [this](::yb::rpc::InboundCallPtr call) {
675
1
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)].metrics);
676
1
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgDropTablegroupRequestPB, ::yb::tserver::PgDropTablegroupResponsePB>>(
677
1
          std::move(call), [this](const ::yb::tserver::PgDropTablegroupRequestPB* req, ::yb::tserver::PgDropTablegroupResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
678
1
        DropTablegroup(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_PgClientService_DropTablegroup.Instantiate(entity),
683
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_DropTablegroup.Instantiate(entity),
684
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_DropTablegroup.Instantiate(entity))
685
11.2k
  };
686
687
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)] = {
688
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "FinishTransaction"),
689
82.4k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
690
82.4k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)].metrics);
691
82.4k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgFinishTransactionRequestPB, ::yb::tserver::PgFinishTransactionResponsePB>>(
692
82.4k
          std::move(call), [this](const ::yb::tserver::PgFinishTransactionRequestPB* req, ::yb::tserver::PgFinishTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
693
82.4k
        FinishTransaction(req, resp, std::move(rpc_context));
694
82.4k
      });
695
82.4k
    },
696
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
697
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_FinishTransaction.Instantiate(entity),
698
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_FinishTransaction.Instantiate(entity),
699
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_FinishTransaction.Instantiate(entity))
700
11.2k
  };
701
702
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)] = {
703
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "GetCatalogMasterVersion"),
704
0
    .handler = [this](::yb::rpc::InboundCallPtr call) {
705
0
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)].metrics);
706
0
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgGetCatalogMasterVersionRequestPB, ::yb::tserver::PgGetCatalogMasterVersionResponsePB>>(
707
0
          std::move(call), [this](const ::yb::tserver::PgGetCatalogMasterVersionRequestPB* req, ::yb::tserver::PgGetCatalogMasterVersionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
708
0
        GetCatalogMasterVersion(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_PgClientService_GetCatalogMasterVersion.Instantiate(entity),
713
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion.Instantiate(entity),
714
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_GetCatalogMasterVersion.Instantiate(entity))
715
11.2k
  };
716
717
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)] = {
718
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "GetDatabaseInfo"),
719
1.61k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
720
1.61k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)].metrics);
721
1.61k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgGetDatabaseInfoRequestPB, ::yb::tserver::PgGetDatabaseInfoResponsePB>>(
722
1.61k
          std::move(call), [this](const ::yb::tserver::PgGetDatabaseInfoRequestPB* req, ::yb::tserver::PgGetDatabaseInfoResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
723
1.61k
        GetDatabaseInfo(req, resp, std::move(rpc_context));
724
1.61k
      });
725
1.61k
    },
726
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
727
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_GetDatabaseInfo.Instantiate(entity),
728
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_GetDatabaseInfo.Instantiate(entity),
729
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_GetDatabaseInfo.Instantiate(entity))
730
11.2k
  };
731
732
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)] = {
733
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "IsInitDbDone"),
734
0
    .handler = [this](::yb::rpc::InboundCallPtr call) {
735
0
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)].metrics);
736
0
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgIsInitDbDoneRequestPB, ::yb::tserver::PgIsInitDbDoneResponsePB>>(
737
0
          std::move(call), [this](const ::yb::tserver::PgIsInitDbDoneRequestPB* req, ::yb::tserver::PgIsInitDbDoneResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
738
0
        IsInitDbDone(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_PgClientService_IsInitDbDone.Instantiate(entity),
743
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_IsInitDbDone.Instantiate(entity),
744
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_IsInitDbDone.Instantiate(entity))
745
11.2k
  };
746
747
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)] = {
748
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "ListLiveTabletServers"),
749
2
    .handler = [this](::yb::rpc::InboundCallPtr call) {
750
2
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)].metrics);
751
2
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgListLiveTabletServersRequestPB, ::yb::tserver::PgListLiveTabletServersResponsePB>>(
752
2
          std::move(call), [this](const ::yb::tserver::PgListLiveTabletServersRequestPB* req, ::yb::tserver::PgListLiveTabletServersResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
753
2
        ListLiveTabletServers(req, resp, std::move(rpc_context));
754
2
      });
755
2
    },
756
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
757
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_ListLiveTabletServers.Instantiate(entity),
758
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_ListLiveTabletServers.Instantiate(entity),
759
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_ListLiveTabletServers.Instantiate(entity))
760
11.2k
  };
761
762
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)] = {
763
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "OpenTable"),
764
64.6k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
765
64.6k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)].metrics);
766
64.6k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgOpenTableRequestPB, ::yb::tserver::PgOpenTableResponsePB>>(
767
64.6k
          std::move(call), [this](const ::yb::tserver::PgOpenTableRequestPB* req, ::yb::tserver::PgOpenTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
768
64.6k
        OpenTable(req, resp, std::move(rpc_context));
769
64.6k
      });
770
64.6k
    },
771
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
772
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_OpenTable.Instantiate(entity),
773
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_OpenTable.Instantiate(entity),
774
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_OpenTable.Instantiate(entity))
775
11.2k
  };
776
777
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)] = {
778
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "Perform"),
779
775k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
780
775k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)].metrics);
781
775k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgPerformRequestPB, ::yb::tserver::PgPerformResponsePB>>(
782
775k
          std::move(call), [this](const ::yb::tserver::PgPerformRequestPB* req, ::yb::tserver::PgPerformResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
783
775k
        Perform(req, resp, std::move(rpc_context));
784
775k
      });
785
775k
    },
786
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
787
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_Perform.Instantiate(entity),
788
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_Perform.Instantiate(entity),
789
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_Perform.Instantiate(entity))
790
11.2k
  };
791
792
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)] = {
793
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "ReserveOids"),
794
380
    .handler = [this](::yb::rpc::InboundCallPtr call) {
795
380
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)].metrics);
796
380
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgReserveOidsRequestPB, ::yb::tserver::PgReserveOidsResponsePB>>(
797
380
          std::move(call), [this](const ::yb::tserver::PgReserveOidsRequestPB* req, ::yb::tserver::PgReserveOidsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
798
380
        ReserveOids(req, resp, std::move(rpc_context));
799
380
      });
800
380
    },
801
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
802
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_ReserveOids.Instantiate(entity),
803
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_ReserveOids.Instantiate(entity),
804
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_ReserveOids.Instantiate(entity))
805
11.2k
  };
806
807
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)] = {
808
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "RollbackSubTransaction"),
809
23.5k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
810
23.5k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)].metrics);
811
23.5k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgRollbackSubTransactionRequestPB, ::yb::tserver::PgRollbackSubTransactionResponsePB>>(
812
23.5k
          std::move(call), [this](const ::yb::tserver::PgRollbackSubTransactionRequestPB* req, ::yb::tserver::PgRollbackSubTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
813
23.5k
        RollbackSubTransaction(req, resp, std::move(rpc_context));
814
23.5k
      });
815
23.5k
    },
816
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
817
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_RollbackSubTransaction.Instantiate(entity),
818
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_RollbackSubTransaction.Instantiate(entity),
819
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_RollbackSubTransaction.Instantiate(entity))
820
11.2k
  };
821
822
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)] = {
823
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "SetActiveSubTransaction"),
824
48.8k
    .handler = [this](::yb::rpc::InboundCallPtr call) {
825
48.8k
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)].metrics);
826
48.8k
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgSetActiveSubTransactionRequestPB, ::yb::tserver::PgSetActiveSubTransactionResponsePB>>(
827
48.8k
          std::move(call), [this](const ::yb::tserver::PgSetActiveSubTransactionRequestPB* req, ::yb::tserver::PgSetActiveSubTransactionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
828
48.8k
        SetActiveSubTransaction(req, resp, std::move(rpc_context));
829
48.8k
      });
830
48.8k
    },
831
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
832
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_SetActiveSubTransaction.Instantiate(entity),
833
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_SetActiveSubTransaction.Instantiate(entity),
834
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_SetActiveSubTransaction.Instantiate(entity))
835
11.2k
  };
836
837
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)] = {
838
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "TabletServerCount"),
839
57
    .handler = [this](::yb::rpc::InboundCallPtr call) {
840
57
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)].metrics);
841
57
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgTabletServerCountRequestPB, ::yb::tserver::PgTabletServerCountResponsePB>>(
842
57
          std::move(call), [this](const ::yb::tserver::PgTabletServerCountRequestPB* req, ::yb::tserver::PgTabletServerCountResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
843
57
        TabletServerCount(req, resp, std::move(rpc_context));
844
57
      });
845
57
    },
846
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
847
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_TabletServerCount.Instantiate(entity),
848
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_TabletServerCount.Instantiate(entity),
849
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_TabletServerCount.Instantiate(entity))
850
11.2k
  };
851
852
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)] = {
853
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "TruncateTable"),
854
31
    .handler = [this](::yb::rpc::InboundCallPtr call) {
855
31
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)].metrics);
856
31
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgTruncateTableRequestPB, ::yb::tserver::PgTruncateTableResponsePB>>(
857
31
          std::move(call), [this](const ::yb::tserver::PgTruncateTableRequestPB* req, ::yb::tserver::PgTruncateTableResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
858
31
        TruncateTable(req, resp, std::move(rpc_context));
859
31
      });
860
31
    },
861
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
862
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_TruncateTable.Instantiate(entity),
863
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_TruncateTable.Instantiate(entity),
864
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_TruncateTable.Instantiate(entity))
865
11.2k
  };
866
867
11.2k
  methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)] = {
868
11.2k
    .method = ::yb::rpc::RemoteMethod("yb.tserver.PgClientService", "ValidatePlacement"),
869
0
    .handler = [this](::yb::rpc::InboundCallPtr call) {
870
0
      call->SetRpcMethodMetrics(methods_[static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)].metrics);
871
0
      ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::tserver::PgValidatePlacementRequestPB, ::yb::tserver::PgValidatePlacementResponsePB>>(
872
0
          std::move(call), [this](const ::yb::tserver::PgValidatePlacementRequestPB* req, ::yb::tserver::PgValidatePlacementResponsePB* resp, ::yb::rpc::RpcContext rpc_context) {
873
0
        ValidatePlacement(req, resp, std::move(rpc_context));
874
0
      });
875
0
    },
876
11.2k
    .metrics = ::yb::rpc::RpcMethodMetrics(
877
11.2k
        METRIC_service_request_bytes_yb_tserver_PgClientService_ValidatePlacement.Instantiate(entity),
878
11.2k
        METRIC_service_response_bytes_yb_tserver_PgClientService_ValidatePlacement.Instantiate(entity),
879
11.2k
        METRIC_handler_latency_yb_tserver_PgClientService_ValidatePlacement.Instantiate(entity))
880
11.2k
  };
881
882
11.2k
}
883
884
} // namespace tserver
885
} // namespace yb