/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/tserver_admin.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/tserver_admin.proto |
2 | | |
3 | | #include "yb/tserver/tserver_admin.proxy.h" |
4 | | |
5 | | #include "yb/tserver/tserver_admin.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_TabletServerAdminService_CreateTablet, |
14 | | "Bytes sent by yb.tserver.TabletServerAdminService.CreateTablet() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.tserver.TabletServerAdminService.CreateTablet() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_CreateTablet, |
20 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CreateTablet() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CreateTablet() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_DeleteTablet, |
26 | | "Bytes sent by yb.tserver.TabletServerAdminService.DeleteTablet() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.tserver.TabletServerAdminService.DeleteTablet() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_DeleteTablet, |
32 | | "Bytes received in response to yb.tserver.TabletServerAdminService.DeleteTablet() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.tserver.TabletServerAdminService.DeleteTablet() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_AlterSchema, |
38 | | "Bytes sent by yb.tserver.TabletServerAdminService.AlterSchema() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.tserver.TabletServerAdminService.AlterSchema() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_AlterSchema, |
44 | | "Bytes received in response to yb.tserver.TabletServerAdminService.AlterSchema() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.tserver.TabletServerAdminService.AlterSchema() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_GetSafeTime, |
50 | | "Bytes sent by yb.tserver.TabletServerAdminService.GetSafeTime() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.tserver.TabletServerAdminService.GetSafeTime() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_GetSafeTime, |
56 | | "Bytes received in response to yb.tserver.TabletServerAdminService.GetSafeTime() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.tserver.TabletServerAdminService.GetSafeTime() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_BackfillIndex, |
62 | | "Bytes sent by yb.tserver.TabletServerAdminService.BackfillIndex() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.tserver.TabletServerAdminService.BackfillIndex() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_BackfillIndex, |
68 | | "Bytes received in response to yb.tserver.TabletServerAdminService.BackfillIndex() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.tserver.TabletServerAdminService.BackfillIndex() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_BackfillDone, |
74 | | "Bytes sent by yb.tserver.TabletServerAdminService.BackfillDone() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.tserver.TabletServerAdminService.BackfillDone() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_BackfillDone, |
80 | | "Bytes received in response to yb.tserver.TabletServerAdminService.BackfillDone() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.tserver.TabletServerAdminService.BackfillDone() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_CopartitionTable, |
86 | | "Bytes sent by yb.tserver.TabletServerAdminService.CopartitionTable() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.tserver.TabletServerAdminService.CopartitionTable() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_CopartitionTable, |
92 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CopartitionTable() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CopartitionTable() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_FlushTablets, |
98 | | "Bytes sent by yb.tserver.TabletServerAdminService.FlushTablets() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.tserver.TabletServerAdminService.FlushTablets() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_FlushTablets, |
104 | | "Bytes received in response to yb.tserver.TabletServerAdminService.FlushTablets() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.tserver.TabletServerAdminService.FlushTablets() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_CountIntents, |
110 | | "Bytes sent by yb.tserver.TabletServerAdminService.CountIntents() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.tserver.TabletServerAdminService.CountIntents() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_CountIntents, |
116 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CountIntents() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.tserver.TabletServerAdminService.CountIntents() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_AddTableToTablet, |
122 | | "Bytes sent by yb.tserver.TabletServerAdminService.AddTableToTablet() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.tserver.TabletServerAdminService.AddTableToTablet() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_AddTableToTablet, |
128 | | "Bytes received in response to yb.tserver.TabletServerAdminService.AddTableToTablet() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.tserver.TabletServerAdminService.AddTableToTablet() RPC requests"); |
131 | | |
132 | | METRIC_DEFINE_counter( |
133 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_RemoveTableFromTablet, |
134 | | "Bytes sent by yb.tserver.TabletServerAdminService.RemoveTableFromTablet() RPC requests", |
135 | | yb::MetricUnit::kBytes, |
136 | | "Bytes sent by yb.tserver.TabletServerAdminService.RemoveTableFromTablet() RPC requests"); |
137 | | |
138 | | METRIC_DEFINE_counter( |
139 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_RemoveTableFromTablet, |
140 | | "Bytes received in response to yb.tserver.TabletServerAdminService.RemoveTableFromTablet() RPC requests", |
141 | | yb::MetricUnit::kBytes, |
142 | | "Bytes received in response to yb.tserver.TabletServerAdminService.RemoveTableFromTablet() RPC requests"); |
143 | | |
144 | | METRIC_DEFINE_counter( |
145 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_SplitTablet, |
146 | | "Bytes sent by yb.tserver.TabletServerAdminService.SplitTablet() RPC requests", |
147 | | yb::MetricUnit::kBytes, |
148 | | "Bytes sent by yb.tserver.TabletServerAdminService.SplitTablet() RPC requests"); |
149 | | |
150 | | METRIC_DEFINE_counter( |
151 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_SplitTablet, |
152 | | "Bytes received in response to yb.tserver.TabletServerAdminService.SplitTablet() RPC requests", |
153 | | yb::MetricUnit::kBytes, |
154 | | "Bytes received in response to yb.tserver.TabletServerAdminService.SplitTablet() RPC requests"); |
155 | | |
156 | | METRIC_DEFINE_counter( |
157 | | server, proxy_request_bytes_yb_tserver_TabletServerAdminService_UpgradeYsql, |
158 | | "Bytes sent by yb.tserver.TabletServerAdminService.UpgradeYsql() RPC requests", |
159 | | yb::MetricUnit::kBytes, |
160 | | "Bytes sent by yb.tserver.TabletServerAdminService.UpgradeYsql() RPC requests"); |
161 | | |
162 | | METRIC_DEFINE_counter( |
163 | | server, proxy_response_bytes_yb_tserver_TabletServerAdminService_UpgradeYsql, |
164 | | "Bytes received in response to yb.tserver.TabletServerAdminService.UpgradeYsql() RPC requests", |
165 | | yb::MetricUnit::kBytes, |
166 | | "Bytes received in response to yb.tserver.TabletServerAdminService.UpgradeYsql() RPC requests"); |
167 | | |
168 | | namespace yb { |
169 | | namespace tserver { |
170 | | |
171 | | |
172 | | namespace { |
173 | | |
174 | | const std::string kFullTabletServerAdminServiceName = "yb.tserver.TabletServerAdminService"; |
175 | | |
176 | 1.42k | ::yb::rpc::ProxyMetricsPtr CreateTabletServerAdminServiceMetrics(const scoped_refptr<MetricEntity>& entity) { |
177 | 1.42k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<13>>(); |
178 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kCreateTablet)] = { |
179 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_CreateTablet.Instantiate(entity), |
180 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_CreateTablet.Instantiate(entity) |
181 | 1.42k | }; |
182 | | |
183 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kDeleteTablet)] = { |
184 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_DeleteTablet.Instantiate(entity), |
185 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_DeleteTablet.Instantiate(entity) |
186 | 1.42k | }; |
187 | | |
188 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kAlterSchema)] = { |
189 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_AlterSchema.Instantiate(entity), |
190 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_AlterSchema.Instantiate(entity) |
191 | 1.42k | }; |
192 | | |
193 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kGetSafeTime)] = { |
194 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_GetSafeTime.Instantiate(entity), |
195 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_GetSafeTime.Instantiate(entity) |
196 | 1.42k | }; |
197 | | |
198 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kBackfillIndex)] = { |
199 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_BackfillIndex.Instantiate(entity), |
200 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_BackfillIndex.Instantiate(entity) |
201 | 1.42k | }; |
202 | | |
203 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kBackfillDone)] = { |
204 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_BackfillDone.Instantiate(entity), |
205 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_BackfillDone.Instantiate(entity) |
206 | 1.42k | }; |
207 | | |
208 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kCopartitionTable)] = { |
209 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_CopartitionTable.Instantiate(entity), |
210 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_CopartitionTable.Instantiate(entity) |
211 | 1.42k | }; |
212 | | |
213 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kFlushTablets)] = { |
214 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_FlushTablets.Instantiate(entity), |
215 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_FlushTablets.Instantiate(entity) |
216 | 1.42k | }; |
217 | | |
218 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kCountIntents)] = { |
219 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_CountIntents.Instantiate(entity), |
220 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_CountIntents.Instantiate(entity) |
221 | 1.42k | }; |
222 | | |
223 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kAddTableToTablet)] = { |
224 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_AddTableToTablet.Instantiate(entity), |
225 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_AddTableToTablet.Instantiate(entity) |
226 | 1.42k | }; |
227 | | |
228 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kRemoveTableFromTablet)] = { |
229 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_RemoveTableFromTablet.Instantiate(entity), |
230 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_RemoveTableFromTablet.Instantiate(entity) |
231 | 1.42k | }; |
232 | | |
233 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kSplitTablet)] = { |
234 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_SplitTablet.Instantiate(entity), |
235 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_SplitTablet.Instantiate(entity) |
236 | 1.42k | }; |
237 | | |
238 | 1.42k | result->value[to_underlying(TabletServerAdminServiceRpcMethodIndexes::kUpgradeYsql)] = { |
239 | 1.42k | METRIC_proxy_request_bytes_yb_tserver_TabletServerAdminService_UpgradeYsql.Instantiate(entity), |
240 | 1.42k | METRIC_proxy_response_bytes_yb_tserver_TabletServerAdminService_UpgradeYsql.Instantiate(entity) |
241 | 1.42k | }; |
242 | | |
243 | 1.42k | return result; |
244 | 1.42k | } |
245 | | |
246 | | |
247 | | } // namespace |
248 | | |
249 | | TabletServerAdminServiceProxy::TabletServerAdminServiceProxy( |
250 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
251 | | const ::yb::rpc::Protocol* protocol, |
252 | | const ::yb::MonoDelta& resolve_cache_timeout) |
253 | | : ProxyBase(kFullTabletServerAdminServiceName, &CreateTabletServerAdminServiceMetrics, |
254 | 4.30k | cache, remote, protocol, resolve_cache_timeout) {} |
255 | | |
256 | | ::yb::Status TabletServerAdminServiceProxy::CreateTablet( |
257 | 1 | const ::yb::tserver::CreateTabletRequestPB &req, ::yb::tserver::CreateTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
258 | 1 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CreateTablet"); |
259 | 1 | return proxy().SyncRequest( |
260 | 1 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCreateTablet)), req, resp, controller); |
261 | 1 | } |
262 | | |
263 | | void TabletServerAdminServiceProxy::CreateTabletAsync( |
264 | | const ::yb::tserver::CreateTabletRequestPB &req, ::yb::tserver::CreateTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
265 | 81.5k | ::yb::rpc::ResponseCallback callback) const { |
266 | 81.5k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CreateTablet"); |
267 | 81.5k | proxy().AsyncRequest( |
268 | 81.5k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCreateTablet)), req, resp, controller, std::move(callback)); |
269 | 81.5k | } |
270 | | |
271 | | ::yb::Status TabletServerAdminServiceProxy::DeleteTablet( |
272 | 14 | const ::yb::tserver::DeleteTabletRequestPB &req, ::yb::tserver::DeleteTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
273 | 14 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "DeleteTablet"); |
274 | 14 | return proxy().SyncRequest( |
275 | 14 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kDeleteTablet)), req, resp, controller); |
276 | 14 | } |
277 | | |
278 | | void TabletServerAdminServiceProxy::DeleteTabletAsync( |
279 | | const ::yb::tserver::DeleteTabletRequestPB &req, ::yb::tserver::DeleteTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
280 | 50.1k | ::yb::rpc::ResponseCallback callback) const { |
281 | 50.1k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "DeleteTablet"); |
282 | 50.1k | proxy().AsyncRequest( |
283 | 50.1k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kDeleteTablet)), req, resp, controller, std::move(callback)); |
284 | 50.1k | } |
285 | | |
286 | | ::yb::Status TabletServerAdminServiceProxy::AlterSchema( |
287 | 0 | const ::yb::tablet::ChangeMetadataRequestPB &req, ::yb::tserver::ChangeMetadataResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
288 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "AlterSchema"); |
289 | 0 | return proxy().SyncRequest( |
290 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kAlterSchema)), req, resp, controller); |
291 | 0 | } |
292 | | |
293 | | void TabletServerAdminServiceProxy::AlterSchemaAsync( |
294 | | const ::yb::tablet::ChangeMetadataRequestPB &req, ::yb::tserver::ChangeMetadataResponsePB *resp, ::yb::rpc::RpcController *controller, |
295 | 18.2k | ::yb::rpc::ResponseCallback callback) const { |
296 | 18.2k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "AlterSchema"); |
297 | 18.2k | proxy().AsyncRequest( |
298 | 18.2k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kAlterSchema)), req, resp, controller, std::move(callback)); |
299 | 18.2k | } |
300 | | |
301 | | ::yb::Status TabletServerAdminServiceProxy::GetSafeTime( |
302 | 0 | const ::yb::tserver::GetSafeTimeRequestPB &req, ::yb::tserver::GetSafeTimeResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
303 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "GetSafeTime"); |
304 | 0 | return proxy().SyncRequest( |
305 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kGetSafeTime)), req, resp, controller); |
306 | 0 | } |
307 | | |
308 | | void TabletServerAdminServiceProxy::GetSafeTimeAsync( |
309 | | const ::yb::tserver::GetSafeTimeRequestPB &req, ::yb::tserver::GetSafeTimeResponsePB *resp, ::yb::rpc::RpcController *controller, |
310 | 2.66k | ::yb::rpc::ResponseCallback callback) const { |
311 | 2.66k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "GetSafeTime"); |
312 | 2.66k | proxy().AsyncRequest( |
313 | 2.66k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kGetSafeTime)), req, resp, controller, std::move(callback)); |
314 | 2.66k | } |
315 | | |
316 | | ::yb::Status TabletServerAdminServiceProxy::BackfillIndex( |
317 | 0 | const ::yb::tserver::BackfillIndexRequestPB &req, ::yb::tserver::BackfillIndexResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
318 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "BackfillIndex"); |
319 | 0 | return proxy().SyncRequest( |
320 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kBackfillIndex)), req, resp, controller); |
321 | 0 | } |
322 | | |
323 | | void TabletServerAdminServiceProxy::BackfillIndexAsync( |
324 | | const ::yb::tserver::BackfillIndexRequestPB &req, ::yb::tserver::BackfillIndexResponsePB *resp, ::yb::rpc::RpcController *controller, |
325 | 2.72k | ::yb::rpc::ResponseCallback callback) const { |
326 | 2.72k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "BackfillIndex"); |
327 | 2.72k | proxy().AsyncRequest( |
328 | 2.72k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kBackfillIndex)), req, resp, controller, std::move(callback)); |
329 | 2.72k | } |
330 | | |
331 | | ::yb::Status TabletServerAdminServiceProxy::BackfillDone( |
332 | 0 | const ::yb::tablet::ChangeMetadataRequestPB &req, ::yb::tserver::ChangeMetadataResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
333 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "BackfillDone"); |
334 | 0 | return proxy().SyncRequest( |
335 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kBackfillDone)), req, resp, controller); |
336 | 0 | } |
337 | | |
338 | | void TabletServerAdminServiceProxy::BackfillDoneAsync( |
339 | | const ::yb::tablet::ChangeMetadataRequestPB &req, ::yb::tserver::ChangeMetadataResponsePB *resp, ::yb::rpc::RpcController *controller, |
340 | 2.46k | ::yb::rpc::ResponseCallback callback) const { |
341 | 2.46k | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "BackfillDone"); |
342 | 2.46k | proxy().AsyncRequest( |
343 | 2.46k | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kBackfillDone)), req, resp, controller, std::move(callback)); |
344 | 2.46k | } |
345 | | |
346 | | ::yb::Status TabletServerAdminServiceProxy::CopartitionTable( |
347 | 0 | const ::yb::tserver::CopartitionTableRequestPB &req, ::yb::tserver::CopartitionTableResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
348 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CopartitionTable"); |
349 | 0 | return proxy().SyncRequest( |
350 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCopartitionTable)), req, resp, controller); |
351 | 0 | } |
352 | | |
353 | | void TabletServerAdminServiceProxy::CopartitionTableAsync( |
354 | | const ::yb::tserver::CopartitionTableRequestPB &req, ::yb::tserver::CopartitionTableResponsePB *resp, ::yb::rpc::RpcController *controller, |
355 | 0 | ::yb::rpc::ResponseCallback callback) const { |
356 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CopartitionTable"); |
357 | 0 | proxy().AsyncRequest( |
358 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCopartitionTable)), req, resp, controller, std::move(callback)); |
359 | 0 | } |
360 | | |
361 | | ::yb::Status TabletServerAdminServiceProxy::FlushTablets( |
362 | 12 | const ::yb::tserver::FlushTabletsRequestPB &req, ::yb::tserver::FlushTabletsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
363 | 12 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "FlushTablets"); |
364 | 12 | return proxy().SyncRequest( |
365 | 12 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kFlushTablets)), req, resp, controller); |
366 | 12 | } |
367 | | |
368 | | void TabletServerAdminServiceProxy::FlushTabletsAsync( |
369 | | const ::yb::tserver::FlushTabletsRequestPB &req, ::yb::tserver::FlushTabletsResponsePB *resp, ::yb::rpc::RpcController *controller, |
370 | 21 | ::yb::rpc::ResponseCallback callback) const { |
371 | 21 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "FlushTablets"); |
372 | 21 | proxy().AsyncRequest( |
373 | 21 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kFlushTablets)), req, resp, controller, std::move(callback)); |
374 | 21 | } |
375 | | |
376 | | ::yb::Status TabletServerAdminServiceProxy::CountIntents( |
377 | 0 | const ::yb::tserver::CountIntentsRequestPB &req, ::yb::tserver::CountIntentsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
378 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CountIntents"); |
379 | 0 | return proxy().SyncRequest( |
380 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCountIntents)), req, resp, controller); |
381 | 0 | } |
382 | | |
383 | | void TabletServerAdminServiceProxy::CountIntentsAsync( |
384 | | const ::yb::tserver::CountIntentsRequestPB &req, ::yb::tserver::CountIntentsResponsePB *resp, ::yb::rpc::RpcController *controller, |
385 | 0 | ::yb::rpc::ResponseCallback callback) const { |
386 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "CountIntents"); |
387 | 0 | proxy().AsyncRequest( |
388 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kCountIntents)), req, resp, controller, std::move(callback)); |
389 | 0 | } |
390 | | |
391 | | ::yb::Status TabletServerAdminServiceProxy::AddTableToTablet( |
392 | 0 | const ::yb::tserver::AddTableToTabletRequestPB &req, ::yb::tserver::AddTableToTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
393 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "AddTableToTablet"); |
394 | 0 | return proxy().SyncRequest( |
395 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kAddTableToTablet)), req, resp, controller); |
396 | 0 | } |
397 | | |
398 | | void TabletServerAdminServiceProxy::AddTableToTabletAsync( |
399 | | const ::yb::tserver::AddTableToTabletRequestPB &req, ::yb::tserver::AddTableToTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
400 | 27 | ::yb::rpc::ResponseCallback callback) const { |
401 | 27 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "AddTableToTablet"); |
402 | 27 | proxy().AsyncRequest( |
403 | 27 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kAddTableToTablet)), req, resp, controller, std::move(callback)); |
404 | 27 | } |
405 | | |
406 | | ::yb::Status TabletServerAdminServiceProxy::RemoveTableFromTablet( |
407 | 0 | const ::yb::tserver::RemoveTableFromTabletRequestPB &req, ::yb::tserver::RemoveTableFromTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
408 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "RemoveTableFromTablet"); |
409 | 0 | return proxy().SyncRequest( |
410 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kRemoveTableFromTablet)), req, resp, controller); |
411 | 0 | } |
412 | | |
413 | | void TabletServerAdminServiceProxy::RemoveTableFromTabletAsync( |
414 | | const ::yb::tserver::RemoveTableFromTabletRequestPB &req, ::yb::tserver::RemoveTableFromTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
415 | 15 | ::yb::rpc::ResponseCallback callback) const { |
416 | 15 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "RemoveTableFromTablet"); |
417 | 15 | proxy().AsyncRequest( |
418 | 15 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kRemoveTableFromTablet)), req, resp, controller, std::move(callback)); |
419 | 15 | } |
420 | | |
421 | | ::yb::Status TabletServerAdminServiceProxy::SplitTablet( |
422 | 0 | const ::yb::tablet::SplitTabletRequestPB &req, ::yb::tserver::SplitTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
423 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "SplitTablet"); |
424 | 0 | return proxy().SyncRequest( |
425 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kSplitTablet)), req, resp, controller); |
426 | 0 | } |
427 | | |
428 | | void TabletServerAdminServiceProxy::SplitTabletAsync( |
429 | | const ::yb::tablet::SplitTabletRequestPB &req, ::yb::tserver::SplitTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
430 | 44 | ::yb::rpc::ResponseCallback callback) const { |
431 | 44 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "SplitTablet"); |
432 | 44 | proxy().AsyncRequest( |
433 | 44 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kSplitTablet)), req, resp, controller, std::move(callback)); |
434 | 44 | } |
435 | | |
436 | | ::yb::Status TabletServerAdminServiceProxy::UpgradeYsql( |
437 | 0 | const ::yb::tserver::UpgradeYsqlRequestPB &req, ::yb::tserver::UpgradeYsqlResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
438 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "UpgradeYsql"); |
439 | 0 | return proxy().SyncRequest( |
440 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kUpgradeYsql)), req, resp, controller); |
441 | 0 | } |
442 | | |
443 | | void TabletServerAdminServiceProxy::UpgradeYsqlAsync( |
444 | | const ::yb::tserver::UpgradeYsqlRequestPB &req, ::yb::tserver::UpgradeYsqlResponsePB *resp, ::yb::rpc::RpcController *controller, |
445 | 0 | ::yb::rpc::ResponseCallback callback) const { |
446 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.TabletServerAdminService", "UpgradeYsql"); |
447 | 0 | proxy().AsyncRequest( |
448 | 0 | &method, metrics<13>(static_cast<size_t>(TabletServerAdminServiceRpcMethodIndexes::kUpgradeYsql)), req, resp, controller, std::move(callback)); |
449 | 0 | } |
450 | | |
451 | | } // namespace tserver |
452 | | } // namespace yb |