/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/tserver_service.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/tserver_service.proto |
2 | | |
3 | | #include "yb/tserver/tserver_service.proxy.h" |
4 | | |
5 | | #include "yb/tserver/tserver_service.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_TabletServerService_Write, |
14 | | "Bytes sent by yb.tserver.TabletServerService.Write() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.tserver.TabletServerService.Write() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_tserver_TabletServerService_Write, |
20 | | "Bytes received in response to yb.tserver.TabletServerService.Write() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.tserver.TabletServerService.Write() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_tserver_TabletServerService_Read, |
26 | | "Bytes sent by yb.tserver.TabletServerService.Read() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.tserver.TabletServerService.Read() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_tserver_TabletServerService_Read, |
32 | | "Bytes received in response to yb.tserver.TabletServerService.Read() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.tserver.TabletServerService.Read() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_tserver_TabletServerService_VerifyTableRowRange, |
38 | | "Bytes sent by yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_tserver_TabletServerService_VerifyTableRowRange, |
44 | | "Bytes received in response to yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.tserver.TabletServerService.VerifyTableRowRange() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_tserver_TabletServerService_NoOp, |
50 | | "Bytes sent by yb.tserver.TabletServerService.NoOp() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.tserver.TabletServerService.NoOp() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_tserver_TabletServerService_NoOp, |
56 | | "Bytes received in response to yb.tserver.TabletServerService.NoOp() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.tserver.TabletServerService.NoOp() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_tserver_TabletServerService_ListTablets, |
62 | | "Bytes sent by yb.tserver.TabletServerService.ListTablets() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.tserver.TabletServerService.ListTablets() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_tserver_TabletServerService_ListTablets, |
68 | | "Bytes received in response to yb.tserver.TabletServerService.ListTablets() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.tserver.TabletServerService.ListTablets() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetLogLocation, |
74 | | "Bytes sent by yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.tserver.TabletServerService.GetLogLocation() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetLogLocation, |
80 | | "Bytes received in response to yb.tserver.TabletServerService.GetLogLocation() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.tserver.TabletServerService.GetLogLocation() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_tserver_TabletServerService_Checksum, |
86 | | "Bytes sent by yb.tserver.TabletServerService.Checksum() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.tserver.TabletServerService.Checksum() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_tserver_TabletServerService_Checksum, |
92 | | "Bytes received in response to yb.tserver.TabletServerService.Checksum() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.tserver.TabletServerService.Checksum() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer, |
98 | | "Bytes sent by yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer, |
104 | | "Bytes received in response to yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.tserver.TabletServerService.ListTabletsForTabletServer() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_tserver_TabletServerService_ImportData, |
110 | | "Bytes sent by yb.tserver.TabletServerService.ImportData() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.tserver.TabletServerService.ImportData() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_tserver_TabletServerService_ImportData, |
116 | | "Bytes received in response to yb.tserver.TabletServerService.ImportData() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.tserver.TabletServerService.ImportData() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_tserver_TabletServerService_UpdateTransaction, |
122 | | "Bytes sent by yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.tserver.TabletServerService.UpdateTransaction() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_tserver_TabletServerService_UpdateTransaction, |
128 | | "Bytes received in response to yb.tserver.TabletServerService.UpdateTransaction() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.tserver.TabletServerService.UpdateTransaction() RPC requests"); |
131 | | |
132 | | METRIC_DEFINE_counter( |
133 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetTransactionStatus, |
134 | | "Bytes sent by yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
135 | | yb::MetricUnit::kBytes, |
136 | | "Bytes sent by yb.tserver.TabletServerService.GetTransactionStatus() RPC requests"); |
137 | | |
138 | | METRIC_DEFINE_counter( |
139 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetTransactionStatus, |
140 | | "Bytes received in response to yb.tserver.TabletServerService.GetTransactionStatus() RPC requests", |
141 | | yb::MetricUnit::kBytes, |
142 | | "Bytes received in response to yb.tserver.TabletServerService.GetTransactionStatus() RPC requests"); |
143 | | |
144 | | METRIC_DEFINE_counter( |
145 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant, |
146 | | "Bytes sent by yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
147 | | yb::MetricUnit::kBytes, |
148 | | "Bytes sent by yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests"); |
149 | | |
150 | | METRIC_DEFINE_counter( |
151 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant, |
152 | | "Bytes received in response to yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests", |
153 | | yb::MetricUnit::kBytes, |
154 | | "Bytes received in response to yb.tserver.TabletServerService.GetTransactionStatusAtParticipant() RPC requests"); |
155 | | |
156 | | METRIC_DEFINE_counter( |
157 | | server, proxy_request_bytes_yb_tserver_TabletServerService_AbortTransaction, |
158 | | "Bytes sent by yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
159 | | yb::MetricUnit::kBytes, |
160 | | "Bytes sent by yb.tserver.TabletServerService.AbortTransaction() RPC requests"); |
161 | | |
162 | | METRIC_DEFINE_counter( |
163 | | server, proxy_response_bytes_yb_tserver_TabletServerService_AbortTransaction, |
164 | | "Bytes received in response to yb.tserver.TabletServerService.AbortTransaction() RPC requests", |
165 | | yb::MetricUnit::kBytes, |
166 | | "Bytes received in response to yb.tserver.TabletServerService.AbortTransaction() RPC requests"); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, proxy_request_bytes_yb_tserver_TabletServerService_Truncate, |
170 | | "Bytes sent by yb.tserver.TabletServerService.Truncate() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes sent by yb.tserver.TabletServerService.Truncate() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, proxy_response_bytes_yb_tserver_TabletServerService_Truncate, |
176 | | "Bytes received in response to yb.tserver.TabletServerService.Truncate() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes received in response to yb.tserver.TabletServerService.Truncate() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_counter( |
181 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetTabletStatus, |
182 | | "Bytes sent by yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
183 | | yb::MetricUnit::kBytes, |
184 | | "Bytes sent by yb.tserver.TabletServerService.GetTabletStatus() RPC requests"); |
185 | | |
186 | | METRIC_DEFINE_counter( |
187 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetTabletStatus, |
188 | | "Bytes received in response to yb.tserver.TabletServerService.GetTabletStatus() RPC requests", |
189 | | yb::MetricUnit::kBytes, |
190 | | "Bytes received in response to yb.tserver.TabletServerService.GetTabletStatus() RPC requests"); |
191 | | |
192 | | METRIC_DEFINE_counter( |
193 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetMasterAddresses, |
194 | | "Bytes sent by yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
195 | | yb::MetricUnit::kBytes, |
196 | | "Bytes sent by yb.tserver.TabletServerService.GetMasterAddresses() RPC requests"); |
197 | | |
198 | | METRIC_DEFINE_counter( |
199 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetMasterAddresses, |
200 | | "Bytes received in response to yb.tserver.TabletServerService.GetMasterAddresses() RPC requests", |
201 | | yb::MetricUnit::kBytes, |
202 | | "Bytes received in response to yb.tserver.TabletServerService.GetMasterAddresses() RPC requests"); |
203 | | |
204 | | METRIC_DEFINE_counter( |
205 | | server, proxy_request_bytes_yb_tserver_TabletServerService_Publish, |
206 | | "Bytes sent by yb.tserver.TabletServerService.Publish() RPC requests", |
207 | | yb::MetricUnit::kBytes, |
208 | | "Bytes sent by yb.tserver.TabletServerService.Publish() RPC requests"); |
209 | | |
210 | | METRIC_DEFINE_counter( |
211 | | server, proxy_response_bytes_yb_tserver_TabletServerService_Publish, |
212 | | "Bytes received in response to yb.tserver.TabletServerService.Publish() RPC requests", |
213 | | yb::MetricUnit::kBytes, |
214 | | "Bytes received in response to yb.tserver.TabletServerService.Publish() RPC requests"); |
215 | | |
216 | | METRIC_DEFINE_counter( |
217 | | server, proxy_request_bytes_yb_tserver_TabletServerService_IsTabletServerReady, |
218 | | "Bytes sent by yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
219 | | yb::MetricUnit::kBytes, |
220 | | "Bytes sent by yb.tserver.TabletServerService.IsTabletServerReady() RPC requests"); |
221 | | |
222 | | METRIC_DEFINE_counter( |
223 | | server, proxy_response_bytes_yb_tserver_TabletServerService_IsTabletServerReady, |
224 | | "Bytes received in response to yb.tserver.TabletServerService.IsTabletServerReady() RPC requests", |
225 | | yb::MetricUnit::kBytes, |
226 | | "Bytes received in response to yb.tserver.TabletServerService.IsTabletServerReady() RPC requests"); |
227 | | |
228 | | METRIC_DEFINE_counter( |
229 | | server, proxy_request_bytes_yb_tserver_TabletServerService_TakeTransaction, |
230 | | "Bytes sent by yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
231 | | yb::MetricUnit::kBytes, |
232 | | "Bytes sent by yb.tserver.TabletServerService.TakeTransaction() RPC requests"); |
233 | | |
234 | | METRIC_DEFINE_counter( |
235 | | server, proxy_response_bytes_yb_tserver_TabletServerService_TakeTransaction, |
236 | | "Bytes received in response to yb.tserver.TabletServerService.TakeTransaction() RPC requests", |
237 | | yb::MetricUnit::kBytes, |
238 | | "Bytes received in response to yb.tserver.TabletServerService.TakeTransaction() RPC requests"); |
239 | | |
240 | | METRIC_DEFINE_counter( |
241 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetSplitKey, |
242 | | "Bytes sent by yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
243 | | yb::MetricUnit::kBytes, |
244 | | "Bytes sent by yb.tserver.TabletServerService.GetSplitKey() RPC requests"); |
245 | | |
246 | | METRIC_DEFINE_counter( |
247 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetSplitKey, |
248 | | "Bytes received in response to yb.tserver.TabletServerService.GetSplitKey() RPC requests", |
249 | | yb::MetricUnit::kBytes, |
250 | | "Bytes received in response to yb.tserver.TabletServerService.GetSplitKey() RPC requests"); |
251 | | |
252 | | METRIC_DEFINE_counter( |
253 | | server, proxy_request_bytes_yb_tserver_TabletServerService_GetSharedData, |
254 | | "Bytes sent by yb.tserver.TabletServerService.GetSharedData() RPC requests", |
255 | | yb::MetricUnit::kBytes, |
256 | | "Bytes sent by yb.tserver.TabletServerService.GetSharedData() RPC requests"); |
257 | | |
258 | | METRIC_DEFINE_counter( |
259 | | server, proxy_response_bytes_yb_tserver_TabletServerService_GetSharedData, |
260 | | "Bytes received in response to yb.tserver.TabletServerService.GetSharedData() RPC requests", |
261 | | yb::MetricUnit::kBytes, |
262 | | "Bytes received in response to yb.tserver.TabletServerService.GetSharedData() RPC requests"); |
263 | | |
264 | | namespace yb { |
265 | | namespace tserver { |
266 | | |
267 | | |
268 | | namespace { |
269 | | |
270 | | const std::string kFullTabletServerServiceName = "yb.tserver.TabletServerService"; |
271 | | |
272 | 17.1k | ::yb::rpc::ProxyMetricsPtr CreateTabletServerServiceMetrics(const scoped_refptr<MetricEntity>& entity) { |
273 | 17.1k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<21>>(); |
274 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kWrite)] = { |
275 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_Write.Instantiate(entity), |
276 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_Write.Instantiate(entity) |
277 | 17.1k | }; |
278 | | |
279 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kRead)] = { |
280 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_Read.Instantiate(entity), |
281 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_Read.Instantiate(entity) |
282 | 17.1k | }; |
283 | | |
284 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)] = { |
285 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_VerifyTableRowRange.Instantiate(entity), |
286 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_VerifyTableRowRange.Instantiate(entity) |
287 | 17.1k | }; |
288 | | |
289 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kNoOp)] = { |
290 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_NoOp.Instantiate(entity), |
291 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_NoOp.Instantiate(entity) |
292 | 17.1k | }; |
293 | | |
294 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kListTablets)] = { |
295 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_ListTablets.Instantiate(entity), |
296 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_ListTablets.Instantiate(entity) |
297 | 17.1k | }; |
298 | | |
299 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetLogLocation)] = { |
300 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetLogLocation.Instantiate(entity), |
301 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetLogLocation.Instantiate(entity) |
302 | 17.1k | }; |
303 | | |
304 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kChecksum)] = { |
305 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_Checksum.Instantiate(entity), |
306 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_Checksum.Instantiate(entity) |
307 | 17.1k | }; |
308 | | |
309 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)] = { |
310 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer.Instantiate(entity), |
311 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_ListTabletsForTabletServer.Instantiate(entity) |
312 | 17.1k | }; |
313 | | |
314 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kImportData)] = { |
315 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_ImportData.Instantiate(entity), |
316 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_ImportData.Instantiate(entity) |
317 | 17.1k | }; |
318 | | |
319 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)] = { |
320 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_UpdateTransaction.Instantiate(entity), |
321 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_UpdateTransaction.Instantiate(entity) |
322 | 17.1k | }; |
323 | | |
324 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)] = { |
325 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetTransactionStatus.Instantiate(entity), |
326 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetTransactionStatus.Instantiate(entity) |
327 | 17.1k | }; |
328 | | |
329 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)] = { |
330 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant.Instantiate(entity), |
331 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetTransactionStatusAtParticipant.Instantiate(entity) |
332 | 17.1k | }; |
333 | | |
334 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kAbortTransaction)] = { |
335 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_AbortTransaction.Instantiate(entity), |
336 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_AbortTransaction.Instantiate(entity) |
337 | 17.1k | }; |
338 | | |
339 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kTruncate)] = { |
340 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_Truncate.Instantiate(entity), |
341 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_Truncate.Instantiate(entity) |
342 | 17.1k | }; |
343 | | |
344 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)] = { |
345 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetTabletStatus.Instantiate(entity), |
346 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetTabletStatus.Instantiate(entity) |
347 | 17.1k | }; |
348 | | |
349 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)] = { |
350 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetMasterAddresses.Instantiate(entity), |
351 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetMasterAddresses.Instantiate(entity) |
352 | 17.1k | }; |
353 | | |
354 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kPublish)] = { |
355 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_Publish.Instantiate(entity), |
356 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_Publish.Instantiate(entity) |
357 | 17.1k | }; |
358 | | |
359 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)] = { |
360 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_IsTabletServerReady.Instantiate(entity), |
361 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_IsTabletServerReady.Instantiate(entity) |
362 | 17.1k | }; |
363 | | |
364 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kTakeTransaction)] = { |
365 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_TakeTransaction.Instantiate(entity), |
366 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_TakeTransaction.Instantiate(entity) |
367 | 17.1k | }; |
368 | | |
369 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetSplitKey)] = { |
370 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetSplitKey.Instantiate(entity), |
371 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetSplitKey.Instantiate(entity) |
372 | 17.1k | }; |
373 | | |
374 | 17.1k | result->value[to_underlying(TabletServerServiceRpcMethodIndexes::kGetSharedData)] = { |
375 | 17.1k | METRIC_proxy_request_bytes_yb_tserver_TabletServerService_GetSharedData.Instantiate(entity), |
376 | 17.1k | METRIC_proxy_response_bytes_yb_tserver_TabletServerService_GetSharedData.Instantiate(entity) |
377 | 17.1k | }; |
378 | | |
379 | 17.1k | return result; |
380 | 17.1k | } |
381 | | |
382 | | |
383 | | } // namespace |
384 | | |
385 | | TabletServerServiceProxy::TabletServerServiceProxy( |
386 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
387 | | const ::yb::rpc::Protocol* protocol, |
388 | | const ::yb::MonoDelta& resolve_cache_timeout) |
389 | | : ProxyBase(kFullTabletServerServiceName, &CreateTabletServerServiceMetrics, |
390 | 30.9k | cache, remote, protocol, resolve_cache_timeout) {} |
391 | | |
392 | | ::yb::Status TabletServerServiceProxy::Write( |
393 | 62.7k | const ::yb::tserver::WriteRequestPB &req, ::yb::tserver::WriteResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
394 | 62.7k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Write"); |
395 | 62.7k | return proxy().SyncRequest( |
396 | 62.7k | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite)), req, resp, controller); |
397 | 62.7k | } |
398 | | |
399 | | void TabletServerServiceProxy::WriteAsync( |
400 | | const ::yb::tserver::WriteRequestPB &req, ::yb::tserver::WriteResponsePB *resp, ::yb::rpc::RpcController *controller, |
401 | 2.55M | ::yb::rpc::ResponseCallback callback) const { |
402 | 2.55M | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Write"); |
403 | 2.55M | proxy().AsyncRequest( |
404 | 2.55M | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kWrite)), req, resp, controller, std::move(callback)); |
405 | 2.55M | } |
406 | | |
407 | | ::yb::Status TabletServerServiceProxy::Read( |
408 | 6 | const ::yb::tserver::ReadRequestPB &req, ::yb::tserver::ReadResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
409 | 6 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Read"); |
410 | 6 | return proxy().SyncRequest( |
411 | 6 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead)), req, resp, controller); |
412 | 6 | } |
413 | | |
414 | | void TabletServerServiceProxy::ReadAsync( |
415 | | const ::yb::tserver::ReadRequestPB &req, ::yb::tserver::ReadResponsePB *resp, ::yb::rpc::RpcController *controller, |
416 | 9.56M | ::yb::rpc::ResponseCallback callback) const { |
417 | 9.56M | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Read"); |
418 | 9.56M | proxy().AsyncRequest( |
419 | 9.56M | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kRead)), req, resp, controller, std::move(callback)); |
420 | 9.56M | } |
421 | | |
422 | | ::yb::Status TabletServerServiceProxy::VerifyTableRowRange( |
423 | 0 | const ::yb::tserver::VerifyTableRowRangeRequestPB &req, ::yb::tserver::VerifyTableRowRangeResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
424 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "VerifyTableRowRange"); |
425 | 0 | return proxy().SyncRequest( |
426 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)), req, resp, controller); |
427 | 0 | } |
428 | | |
429 | | void TabletServerServiceProxy::VerifyTableRowRangeAsync( |
430 | | const ::yb::tserver::VerifyTableRowRangeRequestPB &req, ::yb::tserver::VerifyTableRowRangeResponsePB *resp, ::yb::rpc::RpcController *controller, |
431 | 0 | ::yb::rpc::ResponseCallback callback) const { |
432 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "VerifyTableRowRange"); |
433 | 0 | proxy().AsyncRequest( |
434 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kVerifyTableRowRange)), req, resp, controller, std::move(callback)); |
435 | 0 | } |
436 | | |
437 | | ::yb::Status TabletServerServiceProxy::NoOp( |
438 | 0 | const ::yb::tserver::NoOpRequestPB &req, ::yb::tserver::NoOpResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
439 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "NoOp"); |
440 | 0 | return proxy().SyncRequest( |
441 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp)), req, resp, controller); |
442 | 0 | } |
443 | | |
444 | | void TabletServerServiceProxy::NoOpAsync( |
445 | | const ::yb::tserver::NoOpRequestPB &req, ::yb::tserver::NoOpResponsePB *resp, ::yb::rpc::RpcController *controller, |
446 | 0 | ::yb::rpc::ResponseCallback callback) const { |
447 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "NoOp"); |
448 | 0 | proxy().AsyncRequest( |
449 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kNoOp)), req, resp, controller, std::move(callback)); |
450 | 0 | } |
451 | | |
452 | | ::yb::Status TabletServerServiceProxy::ListTablets( |
453 | 216 | const ::yb::tserver::ListTabletsRequestPB &req, ::yb::tserver::ListTabletsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
454 | 216 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ListTablets"); |
455 | 216 | return proxy().SyncRequest( |
456 | 216 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets)), req, resp, controller); |
457 | 216 | } |
458 | | |
459 | | void TabletServerServiceProxy::ListTabletsAsync( |
460 | | const ::yb::tserver::ListTabletsRequestPB &req, ::yb::tserver::ListTabletsResponsePB *resp, ::yb::rpc::RpcController *controller, |
461 | 0 | ::yb::rpc::ResponseCallback callback) const { |
462 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ListTablets"); |
463 | 0 | proxy().AsyncRequest( |
464 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTablets)), req, resp, controller, std::move(callback)); |
465 | 0 | } |
466 | | |
467 | | ::yb::Status TabletServerServiceProxy::GetLogLocation( |
468 | 0 | const ::yb::tserver::GetLogLocationRequestPB &req, ::yb::tserver::GetLogLocationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
469 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetLogLocation"); |
470 | 0 | return proxy().SyncRequest( |
471 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation)), req, resp, controller); |
472 | 0 | } |
473 | | |
474 | | void TabletServerServiceProxy::GetLogLocationAsync( |
475 | | const ::yb::tserver::GetLogLocationRequestPB &req, ::yb::tserver::GetLogLocationResponsePB *resp, ::yb::rpc::RpcController *controller, |
476 | 0 | ::yb::rpc::ResponseCallback callback) const { |
477 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetLogLocation"); |
478 | 0 | proxy().AsyncRequest( |
479 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetLogLocation)), req, resp, controller, std::move(callback)); |
480 | 0 | } |
481 | | |
482 | | ::yb::Status TabletServerServiceProxy::Checksum( |
483 | 4 | const ::yb::tserver::ChecksumRequestPB &req, ::yb::tserver::ChecksumResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
484 | 4 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Checksum"); |
485 | 4 | return proxy().SyncRequest( |
486 | 4 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum)), req, resp, controller); |
487 | 4 | } |
488 | | |
489 | | void TabletServerServiceProxy::ChecksumAsync( |
490 | | const ::yb::tserver::ChecksumRequestPB &req, ::yb::tserver::ChecksumResponsePB *resp, ::yb::rpc::RpcController *controller, |
491 | 4.37k | ::yb::rpc::ResponseCallback callback) const { |
492 | 4.37k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Checksum"); |
493 | 4.37k | proxy().AsyncRequest( |
494 | 4.37k | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kChecksum)), req, resp, controller, std::move(callback)); |
495 | 4.37k | } |
496 | | |
497 | | ::yb::Status TabletServerServiceProxy::ListTabletsForTabletServer( |
498 | 881 | const ::yb::tserver::ListTabletsForTabletServerRequestPB &req, ::yb::tserver::ListTabletsForTabletServerResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
499 | 881 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ListTabletsForTabletServer"); |
500 | 881 | return proxy().SyncRequest( |
501 | 881 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)), req, resp, controller); |
502 | 881 | } |
503 | | |
504 | | void TabletServerServiceProxy::ListTabletsForTabletServerAsync( |
505 | | const ::yb::tserver::ListTabletsForTabletServerRequestPB &req, ::yb::tserver::ListTabletsForTabletServerResponsePB *resp, ::yb::rpc::RpcController *controller, |
506 | 0 | ::yb::rpc::ResponseCallback callback) const { |
507 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ListTabletsForTabletServer"); |
508 | 0 | proxy().AsyncRequest( |
509 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kListTabletsForTabletServer)), req, resp, controller, std::move(callback)); |
510 | 0 | } |
511 | | |
512 | | ::yb::Status TabletServerServiceProxy::ImportData( |
513 | 0 | const ::yb::tserver::ImportDataRequestPB &req, ::yb::tserver::ImportDataResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
514 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ImportData"); |
515 | 0 | return proxy().SyncRequest( |
516 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData)), req, resp, controller); |
517 | 0 | } |
518 | | |
519 | | void TabletServerServiceProxy::ImportDataAsync( |
520 | | const ::yb::tserver::ImportDataRequestPB &req, ::yb::tserver::ImportDataResponsePB *resp, ::yb::rpc::RpcController *controller, |
521 | 0 | ::yb::rpc::ResponseCallback callback) const { |
522 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "ImportData"); |
523 | 0 | proxy().AsyncRequest( |
524 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kImportData)), req, resp, controller, std::move(callback)); |
525 | 0 | } |
526 | | |
527 | | ::yb::Status TabletServerServiceProxy::UpdateTransaction( |
528 | 0 | const ::yb::tserver::UpdateTransactionRequestPB &req, ::yb::tserver::UpdateTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
529 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "UpdateTransaction"); |
530 | 0 | return proxy().SyncRequest( |
531 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)), req, resp, controller); |
532 | 0 | } |
533 | | |
534 | | void TabletServerServiceProxy::UpdateTransactionAsync( |
535 | | const ::yb::tserver::UpdateTransactionRequestPB &req, ::yb::tserver::UpdateTransactionResponsePB *resp, ::yb::rpc::RpcController *controller, |
536 | 2.53M | ::yb::rpc::ResponseCallback callback) const { |
537 | 2.53M | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "UpdateTransaction"); |
538 | 2.53M | proxy().AsyncRequest( |
539 | 2.53M | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kUpdateTransaction)), req, resp, controller, std::move(callback)); |
540 | 2.53M | } |
541 | | |
542 | | ::yb::Status TabletServerServiceProxy::GetTransactionStatus( |
543 | 0 | const ::yb::tserver::GetTransactionStatusRequestPB &req, ::yb::tserver::GetTransactionStatusResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
544 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTransactionStatus"); |
545 | 0 | return proxy().SyncRequest( |
546 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)), req, resp, controller); |
547 | 0 | } |
548 | | |
549 | | void TabletServerServiceProxy::GetTransactionStatusAsync( |
550 | | const ::yb::tserver::GetTransactionStatusRequestPB &req, ::yb::tserver::GetTransactionStatusResponsePB *resp, ::yb::rpc::RpcController *controller, |
551 | 296k | ::yb::rpc::ResponseCallback callback) const { |
552 | 296k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTransactionStatus"); |
553 | 296k | proxy().AsyncRequest( |
554 | 296k | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatus)), req, resp, controller, std::move(callback)); |
555 | 296k | } |
556 | | |
557 | | ::yb::Status TabletServerServiceProxy::GetTransactionStatusAtParticipant( |
558 | 0 | const ::yb::tserver::GetTransactionStatusAtParticipantRequestPB &req, ::yb::tserver::GetTransactionStatusAtParticipantResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
559 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTransactionStatusAtParticipant"); |
560 | 0 | return proxy().SyncRequest( |
561 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)), req, resp, controller); |
562 | 0 | } |
563 | | |
564 | | void TabletServerServiceProxy::GetTransactionStatusAtParticipantAsync( |
565 | | const ::yb::tserver::GetTransactionStatusAtParticipantRequestPB &req, ::yb::tserver::GetTransactionStatusAtParticipantResponsePB *resp, ::yb::rpc::RpcController *controller, |
566 | 0 | ::yb::rpc::ResponseCallback callback) const { |
567 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTransactionStatusAtParticipant"); |
568 | 0 | proxy().AsyncRequest( |
569 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTransactionStatusAtParticipant)), req, resp, controller, std::move(callback)); |
570 | 0 | } |
571 | | |
572 | | ::yb::Status TabletServerServiceProxy::AbortTransaction( |
573 | 0 | const ::yb::tserver::AbortTransactionRequestPB &req, ::yb::tserver::AbortTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
574 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "AbortTransaction"); |
575 | 0 | return proxy().SyncRequest( |
576 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction)), req, resp, controller); |
577 | 0 | } |
578 | | |
579 | | void TabletServerServiceProxy::AbortTransactionAsync( |
580 | | const ::yb::tserver::AbortTransactionRequestPB &req, ::yb::tserver::AbortTransactionResponsePB *resp, ::yb::rpc::RpcController *controller, |
581 | 193k | ::yb::rpc::ResponseCallback callback) const { |
582 | 193k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "AbortTransaction"); |
583 | 193k | proxy().AsyncRequest( |
584 | 193k | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kAbortTransaction)), req, resp, controller, std::move(callback)); |
585 | 193k | } |
586 | | |
587 | | ::yb::Status TabletServerServiceProxy::Truncate( |
588 | 0 | const ::yb::tserver::TruncateRequestPB &req, ::yb::tserver::TruncateResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
589 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Truncate"); |
590 | 0 | return proxy().SyncRequest( |
591 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate)), req, resp, controller); |
592 | 0 | } |
593 | | |
594 | | void TabletServerServiceProxy::TruncateAsync( |
595 | | const ::yb::tserver::TruncateRequestPB &req, ::yb::tserver::TruncateResponsePB *resp, ::yb::rpc::RpcController *controller, |
596 | 57.1k | ::yb::rpc::ResponseCallback callback) const { |
597 | 57.1k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Truncate"); |
598 | 57.1k | proxy().AsyncRequest( |
599 | 57.1k | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTruncate)), req, resp, controller, std::move(callback)); |
600 | 57.1k | } |
601 | | |
602 | | ::yb::Status TabletServerServiceProxy::GetTabletStatus( |
603 | 1 | const ::yb::tserver::GetTabletStatusRequestPB &req, ::yb::tserver::GetTabletStatusResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
604 | 1 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTabletStatus"); |
605 | 1 | return proxy().SyncRequest( |
606 | 1 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)), req, resp, controller); |
607 | 1 | } |
608 | | |
609 | | void TabletServerServiceProxy::GetTabletStatusAsync( |
610 | | const ::yb::tserver::GetTabletStatusRequestPB &req, ::yb::tserver::GetTabletStatusResponsePB *resp, ::yb::rpc::RpcController *controller, |
611 | 0 | ::yb::rpc::ResponseCallback callback) const { |
612 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetTabletStatus"); |
613 | 0 | proxy().AsyncRequest( |
614 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetTabletStatus)), req, resp, controller, std::move(callback)); |
615 | 0 | } |
616 | | |
617 | | ::yb::Status TabletServerServiceProxy::GetMasterAddresses( |
618 | 0 | const ::yb::tserver::GetMasterAddressesRequestPB &req, ::yb::tserver::GetMasterAddressesResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
619 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetMasterAddresses"); |
620 | 0 | return proxy().SyncRequest( |
621 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)), req, resp, controller); |
622 | 0 | } |
623 | | |
624 | | void TabletServerServiceProxy::GetMasterAddressesAsync( |
625 | | const ::yb::tserver::GetMasterAddressesRequestPB &req, ::yb::tserver::GetMasterAddressesResponsePB *resp, ::yb::rpc::RpcController *controller, |
626 | 0 | ::yb::rpc::ResponseCallback callback) const { |
627 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetMasterAddresses"); |
628 | 0 | proxy().AsyncRequest( |
629 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetMasterAddresses)), req, resp, controller, std::move(callback)); |
630 | 0 | } |
631 | | |
632 | | ::yb::Status TabletServerServiceProxy::Publish( |
633 | 0 | const ::yb::tserver::PublishRequestPB &req, ::yb::tserver::PublishResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
634 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Publish"); |
635 | 0 | return proxy().SyncRequest( |
636 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish)), req, resp, controller); |
637 | 0 | } |
638 | | |
639 | | void TabletServerServiceProxy::PublishAsync( |
640 | | const ::yb::tserver::PublishRequestPB &req, ::yb::tserver::PublishResponsePB *resp, ::yb::rpc::RpcController *controller, |
641 | 684 | ::yb::rpc::ResponseCallback callback) const { |
642 | 684 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "Publish"); |
643 | 684 | proxy().AsyncRequest( |
644 | 684 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kPublish)), req, resp, controller, std::move(callback)); |
645 | 684 | } |
646 | | |
647 | | ::yb::Status TabletServerServiceProxy::IsTabletServerReady( |
648 | 0 | const ::yb::tserver::IsTabletServerReadyRequestPB &req, ::yb::tserver::IsTabletServerReadyResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
649 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "IsTabletServerReady"); |
650 | 0 | return proxy().SyncRequest( |
651 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)), req, resp, controller); |
652 | 0 | } |
653 | | |
654 | | void TabletServerServiceProxy::IsTabletServerReadyAsync( |
655 | | const ::yb::tserver::IsTabletServerReadyRequestPB &req, ::yb::tserver::IsTabletServerReadyResponsePB *resp, ::yb::rpc::RpcController *controller, |
656 | 0 | ::yb::rpc::ResponseCallback callback) const { |
657 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "IsTabletServerReady"); |
658 | 0 | proxy().AsyncRequest( |
659 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kIsTabletServerReady)), req, resp, controller, std::move(callback)); |
660 | 0 | } |
661 | | |
662 | | ::yb::Status TabletServerServiceProxy::TakeTransaction( |
663 | 0 | const ::yb::tserver::TakeTransactionRequestPB &req, ::yb::tserver::TakeTransactionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
664 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "TakeTransaction"); |
665 | 0 | return proxy().SyncRequest( |
666 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction)), req, resp, controller); |
667 | 0 | } |
668 | | |
669 | | void TabletServerServiceProxy::TakeTransactionAsync( |
670 | | const ::yb::tserver::TakeTransactionRequestPB &req, ::yb::tserver::TakeTransactionResponsePB *resp, ::yb::rpc::RpcController *controller, |
671 | 0 | ::yb::rpc::ResponseCallback callback) const { |
672 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "TakeTransaction"); |
673 | 0 | proxy().AsyncRequest( |
674 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kTakeTransaction)), req, resp, controller, std::move(callback)); |
675 | 0 | } |
676 | | |
677 | | ::yb::Status TabletServerServiceProxy::GetSplitKey( |
678 | 1 | const ::yb::tserver::GetSplitKeyRequestPB &req, ::yb::tserver::GetSplitKeyResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
679 | 1 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetSplitKey"); |
680 | 1 | return proxy().SyncRequest( |
681 | 1 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey)), req, resp, controller); |
682 | 1 | } |
683 | | |
684 | | void TabletServerServiceProxy::GetSplitKeyAsync( |
685 | | const ::yb::tserver::GetSplitKeyRequestPB &req, ::yb::tserver::GetSplitKeyResponsePB *resp, ::yb::rpc::RpcController *controller, |
686 | 143 | ::yb::rpc::ResponseCallback callback) const { |
687 | 143 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetSplitKey"); |
688 | 143 | proxy().AsyncRequest( |
689 | 143 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSplitKey)), req, resp, controller, std::move(callback)); |
690 | 143 | } |
691 | | |
692 | | ::yb::Status TabletServerServiceProxy::GetSharedData( |
693 | 8 | const ::yb::tserver::GetSharedDataRequestPB &req, ::yb::tserver::GetSharedDataResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
694 | 8 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetSharedData"); |
695 | 8 | return proxy().SyncRequest( |
696 | 8 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData)), req, resp, controller); |
697 | 8 | } |
698 | | |
699 | | void TabletServerServiceProxy::GetSharedDataAsync( |
700 | | const ::yb::tserver::GetSharedDataRequestPB &req, ::yb::tserver::GetSharedDataResponsePB *resp, ::yb::rpc::RpcController *controller, |
701 | 0 | ::yb::rpc::ResponseCallback callback) const { |
702 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerService", "GetSharedData"); |
703 | 0 | proxy().AsyncRequest( |
704 | 0 | &method, metrics<21>(static_cast<size_t>(TabletServerServiceRpcMethodIndexes::kGetSharedData)), req, resp, controller, std::move(callback)); |
705 | 0 | } |
706 | | |
707 | | } // namespace tserver |
708 | | } // namespace yb |