YugabyteDB (2.13.1.0-b60, 21121d69985fbf76aa6958d8f04a9bfa936293b5)

Coverage Report

Created: 2022-03-22 16:43

/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/pg_client.proxy.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.proxy.h"
4
5
#include "yb/tserver/pg_client.service.h"
6
7
#include "yb/rpc/proxy.h"
8
#include "yb/rpc/outbound_call.h"
9
#include "yb/util/metrics.h"
10
#include "yb/util/net/sockaddr.h"
11
12
METRIC_DEFINE_counter(
13
  server, proxy_request_bytes_yb_tserver_PgClientService_Heartbeat,
14
  "Bytes sent by yb.tserver.PgClientService.Heartbeat() RPC requests",
15
  yb::MetricUnit::kBytes,
16
  "Bytes sent by yb.tserver.PgClientService.Heartbeat() RPC requests");
17
18
METRIC_DEFINE_counter(
19
  server, proxy_response_bytes_yb_tserver_PgClientService_Heartbeat,
20
  "Bytes received in response to yb.tserver.PgClientService.Heartbeat() RPC requests",
21
  yb::MetricUnit::kBytes,
22
  "Bytes received in response to yb.tserver.PgClientService.Heartbeat() RPC requests");
23
24
METRIC_DEFINE_counter(
25
  server, proxy_request_bytes_yb_tserver_PgClientService_AlterDatabase,
26
  "Bytes sent by yb.tserver.PgClientService.AlterDatabase() RPC requests",
27
  yb::MetricUnit::kBytes,
28
  "Bytes sent by yb.tserver.PgClientService.AlterDatabase() RPC requests");
29
30
METRIC_DEFINE_counter(
31
  server, proxy_response_bytes_yb_tserver_PgClientService_AlterDatabase,
32
  "Bytes received in response to yb.tserver.PgClientService.AlterDatabase() RPC requests",
33
  yb::MetricUnit::kBytes,
34
  "Bytes received in response to yb.tserver.PgClientService.AlterDatabase() RPC requests");
35
36
METRIC_DEFINE_counter(
37
  server, proxy_request_bytes_yb_tserver_PgClientService_AlterTable,
38
  "Bytes sent by yb.tserver.PgClientService.AlterTable() RPC requests",
39
  yb::MetricUnit::kBytes,
40
  "Bytes sent by yb.tserver.PgClientService.AlterTable() RPC requests");
41
42
METRIC_DEFINE_counter(
43
  server, proxy_response_bytes_yb_tserver_PgClientService_AlterTable,
44
  "Bytes received in response to yb.tserver.PgClientService.AlterTable() RPC requests",
45
  yb::MetricUnit::kBytes,
46
  "Bytes received in response to yb.tserver.PgClientService.AlterTable() RPC requests");
47
48
METRIC_DEFINE_counter(
49
  server, proxy_request_bytes_yb_tserver_PgClientService_BackfillIndex,
50
  "Bytes sent by yb.tserver.PgClientService.BackfillIndex() RPC requests",
51
  yb::MetricUnit::kBytes,
52
  "Bytes sent by yb.tserver.PgClientService.BackfillIndex() RPC requests");
53
54
METRIC_DEFINE_counter(
55
  server, proxy_response_bytes_yb_tserver_PgClientService_BackfillIndex,
56
  "Bytes received in response to yb.tserver.PgClientService.BackfillIndex() RPC requests",
57
  yb::MetricUnit::kBytes,
58
  "Bytes received in response to yb.tserver.PgClientService.BackfillIndex() RPC requests");
59
60
METRIC_DEFINE_counter(
61
  server, proxy_request_bytes_yb_tserver_PgClientService_CreateDatabase,
62
  "Bytes sent by yb.tserver.PgClientService.CreateDatabase() RPC requests",
63
  yb::MetricUnit::kBytes,
64
  "Bytes sent by yb.tserver.PgClientService.CreateDatabase() RPC requests");
65
66
METRIC_DEFINE_counter(
67
  server, proxy_response_bytes_yb_tserver_PgClientService_CreateDatabase,
68
  "Bytes received in response to yb.tserver.PgClientService.CreateDatabase() RPC requests",
69
  yb::MetricUnit::kBytes,
70
  "Bytes received in response to yb.tserver.PgClientService.CreateDatabase() RPC requests");
71
72
METRIC_DEFINE_counter(
73
  server, proxy_request_bytes_yb_tserver_PgClientService_CreateSequencesDataTable,
74
  "Bytes sent by yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
75
  yb::MetricUnit::kBytes,
76
  "Bytes sent by yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests");
77
78
METRIC_DEFINE_counter(
79
  server, proxy_response_bytes_yb_tserver_PgClientService_CreateSequencesDataTable,
80
  "Bytes received in response to yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests",
81
  yb::MetricUnit::kBytes,
82
  "Bytes received in response to yb.tserver.PgClientService.CreateSequencesDataTable() RPC requests");
83
84
METRIC_DEFINE_counter(
85
  server, proxy_request_bytes_yb_tserver_PgClientService_CreateTable,
86
  "Bytes sent by yb.tserver.PgClientService.CreateTable() RPC requests",
87
  yb::MetricUnit::kBytes,
88
  "Bytes sent by yb.tserver.PgClientService.CreateTable() RPC requests");
89
90
METRIC_DEFINE_counter(
91
  server, proxy_response_bytes_yb_tserver_PgClientService_CreateTable,
92
  "Bytes received in response to yb.tserver.PgClientService.CreateTable() RPC requests",
93
  yb::MetricUnit::kBytes,
94
  "Bytes received in response to yb.tserver.PgClientService.CreateTable() RPC requests");
95
96
METRIC_DEFINE_counter(
97
  server, proxy_request_bytes_yb_tserver_PgClientService_CreateTablegroup,
98
  "Bytes sent by yb.tserver.PgClientService.CreateTablegroup() RPC requests",
99
  yb::MetricUnit::kBytes,
100
  "Bytes sent by yb.tserver.PgClientService.CreateTablegroup() RPC requests");
101
102
METRIC_DEFINE_counter(
103
  server, proxy_response_bytes_yb_tserver_PgClientService_CreateTablegroup,
104
  "Bytes received in response to yb.tserver.PgClientService.CreateTablegroup() RPC requests",
105
  yb::MetricUnit::kBytes,
106
  "Bytes received in response to yb.tserver.PgClientService.CreateTablegroup() RPC requests");
107
108
METRIC_DEFINE_counter(
109
  server, proxy_request_bytes_yb_tserver_PgClientService_DropDatabase,
110
  "Bytes sent by yb.tserver.PgClientService.DropDatabase() RPC requests",
111
  yb::MetricUnit::kBytes,
112
  "Bytes sent by yb.tserver.PgClientService.DropDatabase() RPC requests");
113
114
METRIC_DEFINE_counter(
115
  server, proxy_response_bytes_yb_tserver_PgClientService_DropDatabase,
116
  "Bytes received in response to yb.tserver.PgClientService.DropDatabase() RPC requests",
117
  yb::MetricUnit::kBytes,
118
  "Bytes received in response to yb.tserver.PgClientService.DropDatabase() RPC requests");
119
120
METRIC_DEFINE_counter(
121
  server, proxy_request_bytes_yb_tserver_PgClientService_DropTable,
122
  "Bytes sent by yb.tserver.PgClientService.DropTable() RPC requests",
123
  yb::MetricUnit::kBytes,
124
  "Bytes sent by yb.tserver.PgClientService.DropTable() RPC requests");
125
126
METRIC_DEFINE_counter(
127
  server, proxy_response_bytes_yb_tserver_PgClientService_DropTable,
128
  "Bytes received in response to yb.tserver.PgClientService.DropTable() RPC requests",
129
  yb::MetricUnit::kBytes,
130
  "Bytes received in response to yb.tserver.PgClientService.DropTable() RPC requests");
131
132
METRIC_DEFINE_counter(
133
  server, proxy_request_bytes_yb_tserver_PgClientService_DropTablegroup,
134
  "Bytes sent by yb.tserver.PgClientService.DropTablegroup() RPC requests",
135
  yb::MetricUnit::kBytes,
136
  "Bytes sent by yb.tserver.PgClientService.DropTablegroup() RPC requests");
137
138
METRIC_DEFINE_counter(
139
  server, proxy_response_bytes_yb_tserver_PgClientService_DropTablegroup,
140
  "Bytes received in response to yb.tserver.PgClientService.DropTablegroup() RPC requests",
141
  yb::MetricUnit::kBytes,
142
  "Bytes received in response to yb.tserver.PgClientService.DropTablegroup() RPC requests");
143
144
METRIC_DEFINE_counter(
145
  server, proxy_request_bytes_yb_tserver_PgClientService_FinishTransaction,
146
  "Bytes sent by yb.tserver.PgClientService.FinishTransaction() RPC requests",
147
  yb::MetricUnit::kBytes,
148
  "Bytes sent by yb.tserver.PgClientService.FinishTransaction() RPC requests");
149
150
METRIC_DEFINE_counter(
151
  server, proxy_response_bytes_yb_tserver_PgClientService_FinishTransaction,
152
  "Bytes received in response to yb.tserver.PgClientService.FinishTransaction() RPC requests",
153
  yb::MetricUnit::kBytes,
154
  "Bytes received in response to yb.tserver.PgClientService.FinishTransaction() RPC requests");
155
156
METRIC_DEFINE_counter(
157
  server, proxy_request_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion,
158
  "Bytes sent by yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
159
  yb::MetricUnit::kBytes,
160
  "Bytes sent by yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests");
161
162
METRIC_DEFINE_counter(
163
  server, proxy_response_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion,
164
  "Bytes received in response to yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests",
165
  yb::MetricUnit::kBytes,
166
  "Bytes received in response to yb.tserver.PgClientService.GetCatalogMasterVersion() RPC requests");
167
168
METRIC_DEFINE_counter(
169
  server, proxy_request_bytes_yb_tserver_PgClientService_GetDatabaseInfo,
170
  "Bytes sent by yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
171
  yb::MetricUnit::kBytes,
172
  "Bytes sent by yb.tserver.PgClientService.GetDatabaseInfo() RPC requests");
173
174
METRIC_DEFINE_counter(
175
  server, proxy_response_bytes_yb_tserver_PgClientService_GetDatabaseInfo,
176
  "Bytes received in response to yb.tserver.PgClientService.GetDatabaseInfo() RPC requests",
177
  yb::MetricUnit::kBytes,
178
  "Bytes received in response to yb.tserver.PgClientService.GetDatabaseInfo() RPC requests");
179
180
METRIC_DEFINE_counter(
181
  server, proxy_request_bytes_yb_tserver_PgClientService_IsInitDbDone,
182
  "Bytes sent by yb.tserver.PgClientService.IsInitDbDone() RPC requests",
183
  yb::MetricUnit::kBytes,
184
  "Bytes sent by yb.tserver.PgClientService.IsInitDbDone() RPC requests");
185
186
METRIC_DEFINE_counter(
187
  server, proxy_response_bytes_yb_tserver_PgClientService_IsInitDbDone,
188
  "Bytes received in response to yb.tserver.PgClientService.IsInitDbDone() RPC requests",
189
  yb::MetricUnit::kBytes,
190
  "Bytes received in response to yb.tserver.PgClientService.IsInitDbDone() RPC requests");
191
192
METRIC_DEFINE_counter(
193
  server, proxy_request_bytes_yb_tserver_PgClientService_ListLiveTabletServers,
194
  "Bytes sent by yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
195
  yb::MetricUnit::kBytes,
196
  "Bytes sent by yb.tserver.PgClientService.ListLiveTabletServers() RPC requests");
197
198
METRIC_DEFINE_counter(
199
  server, proxy_response_bytes_yb_tserver_PgClientService_ListLiveTabletServers,
200
  "Bytes received in response to yb.tserver.PgClientService.ListLiveTabletServers() RPC requests",
201
  yb::MetricUnit::kBytes,
202
  "Bytes received in response to yb.tserver.PgClientService.ListLiveTabletServers() RPC requests");
203
204
METRIC_DEFINE_counter(
205
  server, proxy_request_bytes_yb_tserver_PgClientService_OpenTable,
206
  "Bytes sent by yb.tserver.PgClientService.OpenTable() RPC requests",
207
  yb::MetricUnit::kBytes,
208
  "Bytes sent by yb.tserver.PgClientService.OpenTable() RPC requests");
209
210
METRIC_DEFINE_counter(
211
  server, proxy_response_bytes_yb_tserver_PgClientService_OpenTable,
212
  "Bytes received in response to yb.tserver.PgClientService.OpenTable() RPC requests",
213
  yb::MetricUnit::kBytes,
214
  "Bytes received in response to yb.tserver.PgClientService.OpenTable() RPC requests");
215
216
METRIC_DEFINE_counter(
217
  server, proxy_request_bytes_yb_tserver_PgClientService_Perform,
218
  "Bytes sent by yb.tserver.PgClientService.Perform() RPC requests",
219
  yb::MetricUnit::kBytes,
220
  "Bytes sent by yb.tserver.PgClientService.Perform() RPC requests");
221
222
METRIC_DEFINE_counter(
223
  server, proxy_response_bytes_yb_tserver_PgClientService_Perform,
224
  "Bytes received in response to yb.tserver.PgClientService.Perform() RPC requests",
225
  yb::MetricUnit::kBytes,
226
  "Bytes received in response to yb.tserver.PgClientService.Perform() RPC requests");
227
228
METRIC_DEFINE_counter(
229
  server, proxy_request_bytes_yb_tserver_PgClientService_ReserveOids,
230
  "Bytes sent by yb.tserver.PgClientService.ReserveOids() RPC requests",
231
  yb::MetricUnit::kBytes,
232
  "Bytes sent by yb.tserver.PgClientService.ReserveOids() RPC requests");
233
234
METRIC_DEFINE_counter(
235
  server, proxy_response_bytes_yb_tserver_PgClientService_ReserveOids,
236
  "Bytes received in response to yb.tserver.PgClientService.ReserveOids() RPC requests",
237
  yb::MetricUnit::kBytes,
238
  "Bytes received in response to yb.tserver.PgClientService.ReserveOids() RPC requests");
239
240
METRIC_DEFINE_counter(
241
  server, proxy_request_bytes_yb_tserver_PgClientService_RollbackSubTransaction,
242
  "Bytes sent by yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
243
  yb::MetricUnit::kBytes,
244
  "Bytes sent by yb.tserver.PgClientService.RollbackSubTransaction() RPC requests");
245
246
METRIC_DEFINE_counter(
247
  server, proxy_response_bytes_yb_tserver_PgClientService_RollbackSubTransaction,
248
  "Bytes received in response to yb.tserver.PgClientService.RollbackSubTransaction() RPC requests",
249
  yb::MetricUnit::kBytes,
250
  "Bytes received in response to yb.tserver.PgClientService.RollbackSubTransaction() RPC requests");
251
252
METRIC_DEFINE_counter(
253
  server, proxy_request_bytes_yb_tserver_PgClientService_SetActiveSubTransaction,
254
  "Bytes sent by yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
255
  yb::MetricUnit::kBytes,
256
  "Bytes sent by yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests");
257
258
METRIC_DEFINE_counter(
259
  server, proxy_response_bytes_yb_tserver_PgClientService_SetActiveSubTransaction,
260
  "Bytes received in response to yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests",
261
  yb::MetricUnit::kBytes,
262
  "Bytes received in response to yb.tserver.PgClientService.SetActiveSubTransaction() RPC requests");
263
264
METRIC_DEFINE_counter(
265
  server, proxy_request_bytes_yb_tserver_PgClientService_TabletServerCount,
266
  "Bytes sent by yb.tserver.PgClientService.TabletServerCount() RPC requests",
267
  yb::MetricUnit::kBytes,
268
  "Bytes sent by yb.tserver.PgClientService.TabletServerCount() RPC requests");
269
270
METRIC_DEFINE_counter(
271
  server, proxy_response_bytes_yb_tserver_PgClientService_TabletServerCount,
272
  "Bytes received in response to yb.tserver.PgClientService.TabletServerCount() RPC requests",
273
  yb::MetricUnit::kBytes,
274
  "Bytes received in response to yb.tserver.PgClientService.TabletServerCount() RPC requests");
275
276
METRIC_DEFINE_counter(
277
  server, proxy_request_bytes_yb_tserver_PgClientService_TruncateTable,
278
  "Bytes sent by yb.tserver.PgClientService.TruncateTable() RPC requests",
279
  yb::MetricUnit::kBytes,
280
  "Bytes sent by yb.tserver.PgClientService.TruncateTable() RPC requests");
281
282
METRIC_DEFINE_counter(
283
  server, proxy_response_bytes_yb_tserver_PgClientService_TruncateTable,
284
  "Bytes received in response to yb.tserver.PgClientService.TruncateTable() RPC requests",
285
  yb::MetricUnit::kBytes,
286
  "Bytes received in response to yb.tserver.PgClientService.TruncateTable() RPC requests");
287
288
METRIC_DEFINE_counter(
289
  server, proxy_request_bytes_yb_tserver_PgClientService_ValidatePlacement,
290
  "Bytes sent by yb.tserver.PgClientService.ValidatePlacement() RPC requests",
291
  yb::MetricUnit::kBytes,
292
  "Bytes sent by yb.tserver.PgClientService.ValidatePlacement() RPC requests");
293
294
METRIC_DEFINE_counter(
295
  server, proxy_response_bytes_yb_tserver_PgClientService_ValidatePlacement,
296
  "Bytes received in response to yb.tserver.PgClientService.ValidatePlacement() RPC requests",
297
  yb::MetricUnit::kBytes,
298
  "Bytes received in response to yb.tserver.PgClientService.ValidatePlacement() RPC requests");
299
300
METRIC_DEFINE_counter(
301
  server, proxy_request_bytes_yb_tserver_PgClientService_InsertSequenceTuple,
302
  "Bytes sent by yb.tserver.PgClientService.InsertSequenceTuple() RPC requests",
303
  yb::MetricUnit::kBytes,
304
  "Bytes sent by yb.tserver.PgClientService.InsertSequenceTuple() RPC requests");
305
306
METRIC_DEFINE_counter(
307
  server, proxy_response_bytes_yb_tserver_PgClientService_InsertSequenceTuple,
308
  "Bytes received in response to yb.tserver.PgClientService.InsertSequenceTuple() RPC requests",
309
  yb::MetricUnit::kBytes,
310
  "Bytes received in response to yb.tserver.PgClientService.InsertSequenceTuple() RPC requests");
311
312
METRIC_DEFINE_counter(
313
  server, proxy_request_bytes_yb_tserver_PgClientService_UpdateSequenceTuple,
314
  "Bytes sent by yb.tserver.PgClientService.UpdateSequenceTuple() RPC requests",
315
  yb::MetricUnit::kBytes,
316
  "Bytes sent by yb.tserver.PgClientService.UpdateSequenceTuple() RPC requests");
317
318
METRIC_DEFINE_counter(
319
  server, proxy_response_bytes_yb_tserver_PgClientService_UpdateSequenceTuple,
320
  "Bytes received in response to yb.tserver.PgClientService.UpdateSequenceTuple() RPC requests",
321
  yb::MetricUnit::kBytes,
322
  "Bytes received in response to yb.tserver.PgClientService.UpdateSequenceTuple() RPC requests");
323
324
METRIC_DEFINE_counter(
325
  server, proxy_request_bytes_yb_tserver_PgClientService_ReadSequenceTuple,
326
  "Bytes sent by yb.tserver.PgClientService.ReadSequenceTuple() RPC requests",
327
  yb::MetricUnit::kBytes,
328
  "Bytes sent by yb.tserver.PgClientService.ReadSequenceTuple() RPC requests");
329
330
METRIC_DEFINE_counter(
331
  server, proxy_response_bytes_yb_tserver_PgClientService_ReadSequenceTuple,
332
  "Bytes received in response to yb.tserver.PgClientService.ReadSequenceTuple() RPC requests",
333
  yb::MetricUnit::kBytes,
334
  "Bytes received in response to yb.tserver.PgClientService.ReadSequenceTuple() RPC requests");
335
336
METRIC_DEFINE_counter(
337
  server, proxy_request_bytes_yb_tserver_PgClientService_DeleteSequenceTuple,
338
  "Bytes sent by yb.tserver.PgClientService.DeleteSequenceTuple() RPC requests",
339
  yb::MetricUnit::kBytes,
340
  "Bytes sent by yb.tserver.PgClientService.DeleteSequenceTuple() RPC requests");
341
342
METRIC_DEFINE_counter(
343
  server, proxy_response_bytes_yb_tserver_PgClientService_DeleteSequenceTuple,
344
  "Bytes received in response to yb.tserver.PgClientService.DeleteSequenceTuple() RPC requests",
345
  yb::MetricUnit::kBytes,
346
  "Bytes received in response to yb.tserver.PgClientService.DeleteSequenceTuple() RPC requests");
347
348
METRIC_DEFINE_counter(
349
  server, proxy_request_bytes_yb_tserver_PgClientService_DeleteDBSequences,
350
  "Bytes sent by yb.tserver.PgClientService.DeleteDBSequences() RPC requests",
351
  yb::MetricUnit::kBytes,
352
  "Bytes sent by yb.tserver.PgClientService.DeleteDBSequences() RPC requests");
353
354
METRIC_DEFINE_counter(
355
  server, proxy_response_bytes_yb_tserver_PgClientService_DeleteDBSequences,
356
  "Bytes received in response to yb.tserver.PgClientService.DeleteDBSequences() RPC requests",
357
  yb::MetricUnit::kBytes,
358
  "Bytes received in response to yb.tserver.PgClientService.DeleteDBSequences() RPC requests");
359
360
namespace yb {
361
namespace tserver {
362
363
364
namespace {
365
366
const std::string kFullPgClientServiceName = "yb.tserver.PgClientService";
367
368
6.09k
::yb::rpc::ProxyMetricsPtr CreatePgClientServiceMetrics(const scoped_refptr<MetricEntity>& entity) {
369
6.09k
  auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<29>>();
370
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kHeartbeat)] = {
371
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_Heartbeat.Instantiate(entity),
372
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_Heartbeat.Instantiate(entity)
373
6.09k
  };
374
375
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kAlterDatabase)] = {
376
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_AlterDatabase.Instantiate(entity),
377
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_AlterDatabase.Instantiate(entity)
378
6.09k
  };
379
380
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kAlterTable)] = {
381
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_AlterTable.Instantiate(entity),
382
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_AlterTable.Instantiate(entity)
383
6.09k
  };
384
385
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kBackfillIndex)] = {
386
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_BackfillIndex.Instantiate(entity),
387
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_BackfillIndex.Instantiate(entity)
388
6.09k
  };
389
390
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kCreateDatabase)] = {
391
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_CreateDatabase.Instantiate(entity),
392
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_CreateDatabase.Instantiate(entity)
393
6.09k
  };
394
395
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)] = {
396
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_CreateSequencesDataTable.Instantiate(entity),
397
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_CreateSequencesDataTable.Instantiate(entity)
398
6.09k
  };
399
400
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kCreateTable)] = {
401
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_CreateTable.Instantiate(entity),
402
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_CreateTable.Instantiate(entity)
403
6.09k
  };
404
405
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kCreateTablegroup)] = {
406
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_CreateTablegroup.Instantiate(entity),
407
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_CreateTablegroup.Instantiate(entity)
408
6.09k
  };
409
410
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kDropDatabase)] = {
411
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_DropDatabase.Instantiate(entity),
412
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_DropDatabase.Instantiate(entity)
413
6.09k
  };
414
415
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kDropTable)] = {
416
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_DropTable.Instantiate(entity),
417
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_DropTable.Instantiate(entity)
418
6.09k
  };
419
420
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kDropTablegroup)] = {
421
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_DropTablegroup.Instantiate(entity),
422
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_DropTablegroup.Instantiate(entity)
423
6.09k
  };
424
425
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kFinishTransaction)] = {
426
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_FinishTransaction.Instantiate(entity),
427
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_FinishTransaction.Instantiate(entity)
428
6.09k
  };
429
430
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)] = {
431
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion.Instantiate(entity),
432
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_GetCatalogMasterVersion.Instantiate(entity)
433
6.09k
  };
434
435
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)] = {
436
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_GetDatabaseInfo.Instantiate(entity),
437
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_GetDatabaseInfo.Instantiate(entity)
438
6.09k
  };
439
440
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kIsInitDbDone)] = {
441
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_IsInitDbDone.Instantiate(entity),
442
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_IsInitDbDone.Instantiate(entity)
443
6.09k
  };
444
445
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)] = {
446
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_ListLiveTabletServers.Instantiate(entity),
447
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_ListLiveTabletServers.Instantiate(entity)
448
6.09k
  };
449
450
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kOpenTable)] = {
451
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_OpenTable.Instantiate(entity),
452
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_OpenTable.Instantiate(entity)
453
6.09k
  };
454
455
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kPerform)] = {
456
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_Perform.Instantiate(entity),
457
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_Perform.Instantiate(entity)
458
6.09k
  };
459
460
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kReserveOids)] = {
461
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_ReserveOids.Instantiate(entity),
462
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_ReserveOids.Instantiate(entity)
463
6.09k
  };
464
465
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)] = {
466
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_RollbackSubTransaction.Instantiate(entity),
467
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_RollbackSubTransaction.Instantiate(entity)
468
6.09k
  };
469
470
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)] = {
471
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_SetActiveSubTransaction.Instantiate(entity),
472
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_SetActiveSubTransaction.Instantiate(entity)
473
6.09k
  };
474
475
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kTabletServerCount)] = {
476
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_TabletServerCount.Instantiate(entity),
477
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_TabletServerCount.Instantiate(entity)
478
6.09k
  };
479
480
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kTruncateTable)] = {
481
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_TruncateTable.Instantiate(entity),
482
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_TruncateTable.Instantiate(entity)
483
6.09k
  };
484
485
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kValidatePlacement)] = {
486
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_ValidatePlacement.Instantiate(entity),
487
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_ValidatePlacement.Instantiate(entity)
488
6.09k
  };
489
490
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kInsertSequenceTuple)] = {
491
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_InsertSequenceTuple.Instantiate(entity),
492
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_InsertSequenceTuple.Instantiate(entity)
493
6.09k
  };
494
495
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kUpdateSequenceTuple)] = {
496
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_UpdateSequenceTuple.Instantiate(entity),
497
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_UpdateSequenceTuple.Instantiate(entity)
498
6.09k
  };
499
500
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kReadSequenceTuple)] = {
501
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_ReadSequenceTuple.Instantiate(entity),
502
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_ReadSequenceTuple.Instantiate(entity)
503
6.09k
  };
504
505
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kDeleteSequenceTuple)] = {
506
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_DeleteSequenceTuple.Instantiate(entity),
507
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_DeleteSequenceTuple.Instantiate(entity)
508
6.09k
  };
509
510
6.09k
  result->value[to_underlying(PgClientServiceRpcMethodIndexes::kDeleteDBSequences)] = {
511
6.09k
      METRIC_proxy_request_bytes_yb_tserver_PgClientService_DeleteDBSequences.Instantiate(entity),
512
6.09k
      METRIC_proxy_response_bytes_yb_tserver_PgClientService_DeleteDBSequences.Instantiate(entity)
513
6.09k
  };
514
515
6.09k
  return result;
516
6.09k
}
517
518
519
} // namespace
520
521
PgClientServiceProxy::PgClientServiceProxy(
522
    ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote,
523
    const ::yb::rpc::Protocol* protocol,
524
    const ::yb::MonoDelta& resolve_cache_timeout)
525
    : ProxyBase(kFullPgClientServiceName, &CreatePgClientServiceMetrics,
526
6.09k
                cache, remote, protocol, resolve_cache_timeout) {}
527
528
::yb::Status PgClientServiceProxy::Heartbeat(
529
0
    const ::yb::tserver::PgHeartbeatRequestPB &req, ::yb::tserver::PgHeartbeatResponsePB *resp, ::yb::rpc::RpcController *controller) const {
530
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "Heartbeat");
531
0
  return proxy().SyncRequest(
532
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)), req, resp, controller);
533
0
}
534
535
void PgClientServiceProxy::HeartbeatAsync(
536
    const ::yb::tserver::PgHeartbeatRequestPB &req, ::yb::tserver::PgHeartbeatResponsePB *resp, ::yb::rpc::RpcController *controller,
537
10.7k
    ::yb::rpc::ResponseCallback callback) const {
538
10.7k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "Heartbeat");
539
10.7k
  proxy().AsyncRequest(
540
10.7k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kHeartbeat)), req, resp, controller, std::move(callback));
541
10.7k
}
542
543
::yb::Status PgClientServiceProxy::AlterDatabase(
544
3
    const ::yb::tserver::PgAlterDatabaseRequestPB &req, ::yb::tserver::PgAlterDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller) const {
545
3
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "AlterDatabase");
546
3
  return proxy().SyncRequest(
547
3
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)), req, resp, controller);
548
3
}
549
550
void PgClientServiceProxy::AlterDatabaseAsync(
551
    const ::yb::tserver::PgAlterDatabaseRequestPB &req, ::yb::tserver::PgAlterDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller,
552
0
    ::yb::rpc::ResponseCallback callback) const {
553
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "AlterDatabase");
554
0
  proxy().AsyncRequest(
555
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterDatabase)), req, resp, controller, std::move(callback));
556
0
}
557
558
::yb::Status PgClientServiceProxy::AlterTable(
559
522
    const ::yb::tserver::PgAlterTableRequestPB &req, ::yb::tserver::PgAlterTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
560
522
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "AlterTable");
561
522
  return proxy().SyncRequest(
562
522
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)), req, resp, controller);
563
522
}
564
565
void PgClientServiceProxy::AlterTableAsync(
566
    const ::yb::tserver::PgAlterTableRequestPB &req, ::yb::tserver::PgAlterTableResponsePB *resp, ::yb::rpc::RpcController *controller,
567
0
    ::yb::rpc::ResponseCallback callback) const {
568
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "AlterTable");
569
0
  proxy().AsyncRequest(
570
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kAlterTable)), req, resp, controller, std::move(callback));
571
0
}
572
573
::yb::Status PgClientServiceProxy::BackfillIndex(
574
540
    const ::yb::tserver::PgBackfillIndexRequestPB &req, ::yb::tserver::PgBackfillIndexResponsePB *resp, ::yb::rpc::RpcController *controller) const {
575
540
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "BackfillIndex");
576
540
  return proxy().SyncRequest(
577
540
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)), req, resp, controller);
578
540
}
579
580
void PgClientServiceProxy::BackfillIndexAsync(
581
    const ::yb::tserver::PgBackfillIndexRequestPB &req, ::yb::tserver::PgBackfillIndexResponsePB *resp, ::yb::rpc::RpcController *controller,
582
0
    ::yb::rpc::ResponseCallback callback) const {
583
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "BackfillIndex");
584
0
  proxy().AsyncRequest(
585
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kBackfillIndex)), req, resp, controller, std::move(callback));
586
0
}
587
588
::yb::Status PgClientServiceProxy::CreateDatabase(
589
134
    const ::yb::tserver::PgCreateDatabaseRequestPB &req, ::yb::tserver::PgCreateDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller) const {
590
134
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateDatabase");
591
134
  return proxy().SyncRequest(
592
134
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)), req, resp, controller);
593
134
}
594
595
void PgClientServiceProxy::CreateDatabaseAsync(
596
    const ::yb::tserver::PgCreateDatabaseRequestPB &req, ::yb::tserver::PgCreateDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller,
597
0
    ::yb::rpc::ResponseCallback callback) const {
598
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateDatabase");
599
0
  proxy().AsyncRequest(
600
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateDatabase)), req, resp, controller, std::move(callback));
601
0
}
602
603
::yb::Status PgClientServiceProxy::CreateSequencesDataTable(
604
0
    const ::yb::tserver::PgCreateSequencesDataTableRequestPB &req, ::yb::tserver::PgCreateSequencesDataTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
605
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateSequencesDataTable");
606
0
  return proxy().SyncRequest(
607
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)), req, resp, controller);
608
0
}
609
610
void PgClientServiceProxy::CreateSequencesDataTableAsync(
611
    const ::yb::tserver::PgCreateSequencesDataTableRequestPB &req, ::yb::tserver::PgCreateSequencesDataTableResponsePB *resp, ::yb::rpc::RpcController *controller,
612
0
    ::yb::rpc::ResponseCallback callback) const {
613
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateSequencesDataTable");
614
0
  proxy().AsyncRequest(
615
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateSequencesDataTable)), req, resp, controller, std::move(callback));
616
0
}
617
618
::yb::Status PgClientServiceProxy::CreateTable(
619
5.05k
    const ::yb::tserver::PgCreateTableRequestPB &req, ::yb::tserver::PgCreateTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
620
5.05k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateTable");
621
5.05k
  return proxy().SyncRequest(
622
5.05k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)), req, resp, controller);
623
5.05k
}
624
625
void PgClientServiceProxy::CreateTableAsync(
626
    const ::yb::tserver::PgCreateTableRequestPB &req, ::yb::tserver::PgCreateTableResponsePB *resp, ::yb::rpc::RpcController *controller,
627
0
    ::yb::rpc::ResponseCallback callback) const {
628
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateTable");
629
0
  proxy().AsyncRequest(
630
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTable)), req, resp, controller, std::move(callback));
631
0
}
632
633
::yb::Status PgClientServiceProxy::CreateTablegroup(
634
54
    const ::yb::tserver::PgCreateTablegroupRequestPB &req, ::yb::tserver::PgCreateTablegroupResponsePB *resp, ::yb::rpc::RpcController *controller) const {
635
54
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateTablegroup");
636
54
  return proxy().SyncRequest(
637
54
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)), req, resp, controller);
638
54
}
639
640
void PgClientServiceProxy::CreateTablegroupAsync(
641
    const ::yb::tserver::PgCreateTablegroupRequestPB &req, ::yb::tserver::PgCreateTablegroupResponsePB *resp, ::yb::rpc::RpcController *controller,
642
0
    ::yb::rpc::ResponseCallback callback) const {
643
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "CreateTablegroup");
644
0
  proxy().AsyncRequest(
645
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kCreateTablegroup)), req, resp, controller, std::move(callback));
646
0
}
647
648
::yb::Status PgClientServiceProxy::DropDatabase(
649
72
    const ::yb::tserver::PgDropDatabaseRequestPB &req, ::yb::tserver::PgDropDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller) const {
650
72
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropDatabase");
651
72
  return proxy().SyncRequest(
652
72
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)), req, resp, controller);
653
72
}
654
655
void PgClientServiceProxy::DropDatabaseAsync(
656
    const ::yb::tserver::PgDropDatabaseRequestPB &req, ::yb::tserver::PgDropDatabaseResponsePB *resp, ::yb::rpc::RpcController *controller,
657
0
    ::yb::rpc::ResponseCallback callback) const {
658
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropDatabase");
659
0
  proxy().AsyncRequest(
660
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropDatabase)), req, resp, controller, std::move(callback));
661
0
}
662
663
::yb::Status PgClientServiceProxy::DropTable(
664
4.14k
    const ::yb::tserver::PgDropTableRequestPB &req, ::yb::tserver::PgDropTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
665
4.14k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropTable");
666
4.14k
  return proxy().SyncRequest(
667
4.14k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)), req, resp, controller);
668
4.14k
}
669
670
void PgClientServiceProxy::DropTableAsync(
671
    const ::yb::tserver::PgDropTableRequestPB &req, ::yb::tserver::PgDropTableResponsePB *resp, ::yb::rpc::RpcController *controller,
672
0
    ::yb::rpc::ResponseCallback callback) const {
673
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropTable");
674
0
  proxy().AsyncRequest(
675
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTable)), req, resp, controller, std::move(callback));
676
0
}
677
678
::yb::Status PgClientServiceProxy::DropTablegroup(
679
39
    const ::yb::tserver::PgDropTablegroupRequestPB &req, ::yb::tserver::PgDropTablegroupResponsePB *resp, ::yb::rpc::RpcController *controller) const {
680
39
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropTablegroup");
681
39
  return proxy().SyncRequest(
682
39
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)), req, resp, controller);
683
39
}
684
685
void PgClientServiceProxy::DropTablegroupAsync(
686
    const ::yb::tserver::PgDropTablegroupRequestPB &req, ::yb::tserver::PgDropTablegroupResponsePB *resp, ::yb::rpc::RpcController *controller,
687
0
    ::yb::rpc::ResponseCallback callback) const {
688
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DropTablegroup");
689
0
  proxy().AsyncRequest(
690
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDropTablegroup)), req, resp, controller, std::move(callback));
691
0
}
692
693
::yb::Status PgClientServiceProxy::FinishTransaction(
694
218k
    const ::yb::tserver::PgFinishTransactionRequestPB &req, ::yb::tserver::PgFinishTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
695
218k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "FinishTransaction");
696
218k
  return proxy().SyncRequest(
697
218k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)), req, resp, controller);
698
218k
}
699
700
void PgClientServiceProxy::FinishTransactionAsync(
701
    const ::yb::tserver::PgFinishTransactionRequestPB &req, ::yb::tserver::PgFinishTransactionResponsePB *resp, ::yb::rpc::RpcController *controller,
702
0
    ::yb::rpc::ResponseCallback callback) const {
703
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "FinishTransaction");
704
0
  proxy().AsyncRequest(
705
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kFinishTransaction)), req, resp, controller, std::move(callback));
706
0
}
707
708
::yb::Status PgClientServiceProxy::GetCatalogMasterVersion(
709
22
    const ::yb::tserver::PgGetCatalogMasterVersionRequestPB &req, ::yb::tserver::PgGetCatalogMasterVersionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
710
22
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "GetCatalogMasterVersion");
711
22
  return proxy().SyncRequest(
712
22
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)), req, resp, controller);
713
22
}
714
715
void PgClientServiceProxy::GetCatalogMasterVersionAsync(
716
    const ::yb::tserver::PgGetCatalogMasterVersionRequestPB &req, ::yb::tserver::PgGetCatalogMasterVersionResponsePB *resp, ::yb::rpc::RpcController *controller,
717
0
    ::yb::rpc::ResponseCallback callback) const {
718
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "GetCatalogMasterVersion");
719
0
  proxy().AsyncRequest(
720
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetCatalogMasterVersion)), req, resp, controller, std::move(callback));
721
0
}
722
723
::yb::Status PgClientServiceProxy::GetDatabaseInfo(
724
5.72k
    const ::yb::tserver::PgGetDatabaseInfoRequestPB &req, ::yb::tserver::PgGetDatabaseInfoResponsePB *resp, ::yb::rpc::RpcController *controller) const {
725
5.72k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "GetDatabaseInfo");
726
5.72k
  return proxy().SyncRequest(
727
5.72k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)), req, resp, controller);
728
5.72k
}
729
730
void PgClientServiceProxy::GetDatabaseInfoAsync(
731
    const ::yb::tserver::PgGetDatabaseInfoRequestPB &req, ::yb::tserver::PgGetDatabaseInfoResponsePB *resp, ::yb::rpc::RpcController *controller,
732
0
    ::yb::rpc::ResponseCallback callback) const {
733
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "GetDatabaseInfo");
734
0
  proxy().AsyncRequest(
735
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kGetDatabaseInfo)), req, resp, controller, std::move(callback));
736
0
}
737
738
::yb::Status PgClientServiceProxy::IsInitDbDone(
739
2
    const ::yb::tserver::PgIsInitDbDoneRequestPB &req, ::yb::tserver::PgIsInitDbDoneResponsePB *resp, ::yb::rpc::RpcController *controller) const {
740
2
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "IsInitDbDone");
741
2
  return proxy().SyncRequest(
742
2
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)), req, resp, controller);
743
2
}
744
745
void PgClientServiceProxy::IsInitDbDoneAsync(
746
    const ::yb::tserver::PgIsInitDbDoneRequestPB &req, ::yb::tserver::PgIsInitDbDoneResponsePB *resp, ::yb::rpc::RpcController *controller,
747
0
    ::yb::rpc::ResponseCallback callback) const {
748
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "IsInitDbDone");
749
0
  proxy().AsyncRequest(
750
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kIsInitDbDone)), req, resp, controller, std::move(callback));
751
0
}
752
753
::yb::Status PgClientServiceProxy::ListLiveTabletServers(
754
4
    const ::yb::tserver::PgListLiveTabletServersRequestPB &req, ::yb::tserver::PgListLiveTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller) const {
755
4
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ListLiveTabletServers");
756
4
  return proxy().SyncRequest(
757
4
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)), req, resp, controller);
758
4
}
759
760
void PgClientServiceProxy::ListLiveTabletServersAsync(
761
    const ::yb::tserver::PgListLiveTabletServersRequestPB &req, ::yb::tserver::PgListLiveTabletServersResponsePB *resp, ::yb::rpc::RpcController *controller,
762
0
    ::yb::rpc::ResponseCallback callback) const {
763
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ListLiveTabletServers");
764
0
  proxy().AsyncRequest(
765
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kListLiveTabletServers)), req, resp, controller, std::move(callback));
766
0
}
767
768
::yb::Status PgClientServiceProxy::OpenTable(
769
191k
    const ::yb::tserver::PgOpenTableRequestPB &req, ::yb::tserver::PgOpenTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
770
191k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "OpenTable");
771
191k
  return proxy().SyncRequest(
772
191k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)), req, resp, controller);
773
191k
}
774
775
void PgClientServiceProxy::OpenTableAsync(
776
    const ::yb::tserver::PgOpenTableRequestPB &req, ::yb::tserver::PgOpenTableResponsePB *resp, ::yb::rpc::RpcController *controller,
777
0
    ::yb::rpc::ResponseCallback callback) const {
778
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "OpenTable");
779
0
  proxy().AsyncRequest(
780
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kOpenTable)), req, resp, controller, std::move(callback));
781
0
}
782
783
::yb::Status PgClientServiceProxy::Perform(
784
0
    const ::yb::tserver::PgPerformRequestPB &req, ::yb::tserver::PgPerformResponsePB *resp, ::yb::rpc::RpcController *controller) const {
785
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "Perform");
786
0
  return proxy().SyncRequest(
787
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)), req, resp, controller);
788
0
}
789
790
void PgClientServiceProxy::PerformAsync(
791
    const ::yb::tserver::PgPerformRequestPB &req, ::yb::tserver::PgPerformResponsePB *resp, ::yb::rpc::RpcController *controller,
792
2.17M
    ::yb::rpc::ResponseCallback callback) const {
793
2.17M
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "Perform");
794
2.17M
  proxy().AsyncRequest(
795
2.17M
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kPerform)), req, resp, controller, std::move(callback));
796
2.17M
}
797
798
::yb::Status PgClientServiceProxy::ReserveOids(
799
805
    const ::yb::tserver::PgReserveOidsRequestPB &req, ::yb::tserver::PgReserveOidsResponsePB *resp, ::yb::rpc::RpcController *controller) const {
800
805
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ReserveOids");
801
805
  return proxy().SyncRequest(
802
805
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)), req, resp, controller);
803
805
}
804
805
void PgClientServiceProxy::ReserveOidsAsync(
806
    const ::yb::tserver::PgReserveOidsRequestPB &req, ::yb::tserver::PgReserveOidsResponsePB *resp, ::yb::rpc::RpcController *controller,
807
0
    ::yb::rpc::ResponseCallback callback) const {
808
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ReserveOids");
809
0
  proxy().AsyncRequest(
810
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReserveOids)), req, resp, controller, std::move(callback));
811
0
}
812
813
::yb::Status PgClientServiceProxy::RollbackSubTransaction(
814
13.5k
    const ::yb::tserver::PgRollbackSubTransactionRequestPB &req, ::yb::tserver::PgRollbackSubTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
815
13.5k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "RollbackSubTransaction");
816
13.5k
  return proxy().SyncRequest(
817
13.5k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)), req, resp, controller);
818
13.5k
}
819
820
void PgClientServiceProxy::RollbackSubTransactionAsync(
821
    const ::yb::tserver::PgRollbackSubTransactionRequestPB &req, ::yb::tserver::PgRollbackSubTransactionResponsePB *resp, ::yb::rpc::RpcController *controller,
822
0
    ::yb::rpc::ResponseCallback callback) const {
823
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "RollbackSubTransaction");
824
0
  proxy().AsyncRequest(
825
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kRollbackSubTransaction)), req, resp, controller, std::move(callback));
826
0
}
827
828
::yb::Status PgClientServiceProxy::SetActiveSubTransaction(
829
61.7k
    const ::yb::tserver::PgSetActiveSubTransactionRequestPB &req, ::yb::tserver::PgSetActiveSubTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const {
830
61.7k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "SetActiveSubTransaction");
831
61.7k
  return proxy().SyncRequest(
832
61.7k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)), req, resp, controller);
833
61.7k
}
834
835
void PgClientServiceProxy::SetActiveSubTransactionAsync(
836
    const ::yb::tserver::PgSetActiveSubTransactionRequestPB &req, ::yb::tserver::PgSetActiveSubTransactionResponsePB *resp, ::yb::rpc::RpcController *controller,
837
0
    ::yb::rpc::ResponseCallback callback) const {
838
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "SetActiveSubTransaction");
839
0
  proxy().AsyncRequest(
840
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kSetActiveSubTransaction)), req, resp, controller, std::move(callback));
841
0
}
842
843
::yb::Status PgClientServiceProxy::TabletServerCount(
844
148
    const ::yb::tserver::PgTabletServerCountRequestPB &req, ::yb::tserver::PgTabletServerCountResponsePB *resp, ::yb::rpc::RpcController *controller) const {
845
148
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "TabletServerCount");
846
148
  return proxy().SyncRequest(
847
148
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)), req, resp, controller);
848
148
}
849
850
void PgClientServiceProxy::TabletServerCountAsync(
851
    const ::yb::tserver::PgTabletServerCountRequestPB &req, ::yb::tserver::PgTabletServerCountResponsePB *resp, ::yb::rpc::RpcController *controller,
852
0
    ::yb::rpc::ResponseCallback callback) const {
853
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "TabletServerCount");
854
0
  proxy().AsyncRequest(
855
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTabletServerCount)), req, resp, controller, std::move(callback));
856
0
}
857
858
::yb::Status PgClientServiceProxy::TruncateTable(
859
624
    const ::yb::tserver::PgTruncateTableRequestPB &req, ::yb::tserver::PgTruncateTableResponsePB *resp, ::yb::rpc::RpcController *controller) const {
860
624
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "TruncateTable");
861
624
  return proxy().SyncRequest(
862
624
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)), req, resp, controller);
863
624
}
864
865
void PgClientServiceProxy::TruncateTableAsync(
866
    const ::yb::tserver::PgTruncateTableRequestPB &req, ::yb::tserver::PgTruncateTableResponsePB *resp, ::yb::rpc::RpcController *controller,
867
0
    ::yb::rpc::ResponseCallback callback) const {
868
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "TruncateTable");
869
0
  proxy().AsyncRequest(
870
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kTruncateTable)), req, resp, controller, std::move(callback));
871
0
}
872
873
::yb::Status PgClientServiceProxy::ValidatePlacement(
874
1
    const ::yb::tserver::PgValidatePlacementRequestPB &req, ::yb::tserver::PgValidatePlacementResponsePB *resp, ::yb::rpc::RpcController *controller) const {
875
1
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ValidatePlacement");
876
1
  return proxy().SyncRequest(
877
1
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)), req, resp, controller);
878
1
}
879
880
void PgClientServiceProxy::ValidatePlacementAsync(
881
    const ::yb::tserver::PgValidatePlacementRequestPB &req, ::yb::tserver::PgValidatePlacementResponsePB *resp, ::yb::rpc::RpcController *controller,
882
0
    ::yb::rpc::ResponseCallback callback) const {
883
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ValidatePlacement");
884
0
  proxy().AsyncRequest(
885
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kValidatePlacement)), req, resp, controller, std::move(callback));
886
0
}
887
888
::yb::Status PgClientServiceProxy::InsertSequenceTuple(
889
295
    const ::yb::tserver::PgInsertSequenceTupleRequestPB &req, ::yb::tserver::PgInsertSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller) const {
890
295
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "InsertSequenceTuple");
891
295
  return proxy().SyncRequest(
892
295
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kInsertSequenceTuple)), req, resp, controller);
893
295
}
894
895
void PgClientServiceProxy::InsertSequenceTupleAsync(
896
    const ::yb::tserver::PgInsertSequenceTupleRequestPB &req, ::yb::tserver::PgInsertSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller,
897
0
    ::yb::rpc::ResponseCallback callback) const {
898
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "InsertSequenceTuple");
899
0
  proxy().AsyncRequest(
900
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kInsertSequenceTuple)), req, resp, controller, std::move(callback));
901
0
}
902
903
::yb::Status PgClientServiceProxy::UpdateSequenceTuple(
904
2.97k
    const ::yb::tserver::PgUpdateSequenceTupleRequestPB &req, ::yb::tserver::PgUpdateSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller) const {
905
2.97k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "UpdateSequenceTuple");
906
2.97k
  return proxy().SyncRequest(
907
2.97k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kUpdateSequenceTuple)), req, resp, controller);
908
2.97k
}
909
910
void PgClientServiceProxy::UpdateSequenceTupleAsync(
911
    const ::yb::tserver::PgUpdateSequenceTupleRequestPB &req, ::yb::tserver::PgUpdateSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller,
912
0
    ::yb::rpc::ResponseCallback callback) const {
913
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "UpdateSequenceTuple");
914
0
  proxy().AsyncRequest(
915
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kUpdateSequenceTuple)), req, resp, controller, std::move(callback));
916
0
}
917
918
::yb::Status PgClientServiceProxy::ReadSequenceTuple(
919
3.23k
    const ::yb::tserver::PgReadSequenceTupleRequestPB &req, ::yb::tserver::PgReadSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller) const {
920
3.23k
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ReadSequenceTuple");
921
3.23k
  return proxy().SyncRequest(
922
3.23k
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReadSequenceTuple)), req, resp, controller);
923
3.23k
}
924
925
void PgClientServiceProxy::ReadSequenceTupleAsync(
926
    const ::yb::tserver::PgReadSequenceTupleRequestPB &req, ::yb::tserver::PgReadSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller,
927
0
    ::yb::rpc::ResponseCallback callback) const {
928
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "ReadSequenceTuple");
929
0
  proxy().AsyncRequest(
930
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kReadSequenceTuple)), req, resp, controller, std::move(callback));
931
0
}
932
933
::yb::Status PgClientServiceProxy::DeleteSequenceTuple(
934
282
    const ::yb::tserver::PgDeleteSequenceTupleRequestPB &req, ::yb::tserver::PgDeleteSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller) const {
935
282
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DeleteSequenceTuple");
936
282
  return proxy().SyncRequest(
937
282
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDeleteSequenceTuple)), req, resp, controller);
938
282
}
939
940
void PgClientServiceProxy::DeleteSequenceTupleAsync(
941
    const ::yb::tserver::PgDeleteSequenceTupleRequestPB &req, ::yb::tserver::PgDeleteSequenceTupleResponsePB *resp, ::yb::rpc::RpcController *controller,
942
0
    ::yb::rpc::ResponseCallback callback) const {
943
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DeleteSequenceTuple");
944
0
  proxy().AsyncRequest(
945
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDeleteSequenceTuple)), req, resp, controller, std::move(callback));
946
0
}
947
948
::yb::Status PgClientServiceProxy::DeleteDBSequences(
949
71
    const ::yb::tserver::PgDeleteDBSequencesRequestPB &req, ::yb::tserver::PgDeleteDBSequencesResponsePB *resp, ::yb::rpc::RpcController *controller) const {
950
71
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DeleteDBSequences");
951
71
  return proxy().SyncRequest(
952
71
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDeleteDBSequences)), req, resp, controller);
953
71
}
954
955
void PgClientServiceProxy::DeleteDBSequencesAsync(
956
    const ::yb::tserver::PgDeleteDBSequencesRequestPB &req, ::yb::tserver::PgDeleteDBSequencesResponsePB *resp, ::yb::rpc::RpcController *controller,
957
0
    ::yb::rpc::ResponseCallback callback) const {
958
0
  static ::yb::rpc::RemoteMethod method("yb.tserver.PgClientService", "DeleteDBSequences");
959
0
  proxy().AsyncRequest(
960
0
      &method, metrics<29>(static_cast<size_t>(PgClientServiceRpcMethodIndexes::kDeleteDBSequences)), req, resp, controller, std::move(callback));
961
0
}
962
963
} // namespace tserver
964
} // namespace yb