/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_admin.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_admin.proto |
2 | | |
3 | | #include "yb/master/master_admin.proxy.h" |
4 | | |
5 | | #include "yb/master/master_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_master_MasterAdmin_FlushTables, |
14 | | "Bytes sent by yb.master.MasterAdmin.FlushTables() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterAdmin.FlushTables() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterAdmin_FlushTables, |
20 | | "Bytes received in response to yb.master.MasterAdmin.FlushTables() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterAdmin.FlushTables() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_master_MasterAdmin_IsFlushTablesDone, |
26 | | "Bytes sent by yb.master.MasterAdmin.IsFlushTablesDone() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.master.MasterAdmin.IsFlushTablesDone() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_master_MasterAdmin_IsFlushTablesDone, |
32 | | "Bytes received in response to yb.master.MasterAdmin.IsFlushTablesDone() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.master.MasterAdmin.IsFlushTablesDone() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_master_MasterAdmin_FlushSysCatalog, |
38 | | "Bytes sent by yb.master.MasterAdmin.FlushSysCatalog() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.master.MasterAdmin.FlushSysCatalog() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_master_MasterAdmin_FlushSysCatalog, |
44 | | "Bytes received in response to yb.master.MasterAdmin.FlushSysCatalog() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.master.MasterAdmin.FlushSysCatalog() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_master_MasterAdmin_CompactSysCatalog, |
50 | | "Bytes sent by yb.master.MasterAdmin.CompactSysCatalog() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.master.MasterAdmin.CompactSysCatalog() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_master_MasterAdmin_CompactSysCatalog, |
56 | | "Bytes received in response to yb.master.MasterAdmin.CompactSysCatalog() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.master.MasterAdmin.CompactSysCatalog() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_master_MasterAdmin_IsInitDbDone, |
62 | | "Bytes sent by yb.master.MasterAdmin.IsInitDbDone() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.master.MasterAdmin.IsInitDbDone() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_master_MasterAdmin_IsInitDbDone, |
68 | | "Bytes received in response to yb.master.MasterAdmin.IsInitDbDone() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.master.MasterAdmin.IsInitDbDone() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_master_MasterAdmin_SplitTablet, |
74 | | "Bytes sent by yb.master.MasterAdmin.SplitTablet() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.master.MasterAdmin.SplitTablet() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_master_MasterAdmin_SplitTablet, |
80 | | "Bytes received in response to yb.master.MasterAdmin.SplitTablet() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.master.MasterAdmin.SplitTablet() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_master_MasterAdmin_CreateTransactionStatusTable, |
86 | | "Bytes sent by yb.master.MasterAdmin.CreateTransactionStatusTable() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.master.MasterAdmin.CreateTransactionStatusTable() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_master_MasterAdmin_CreateTransactionStatusTable, |
92 | | "Bytes received in response to yb.master.MasterAdmin.CreateTransactionStatusTable() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.master.MasterAdmin.CreateTransactionStatusTable() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_master_MasterAdmin_DeleteNotServingTablet, |
98 | | "Bytes sent by yb.master.MasterAdmin.DeleteNotServingTablet() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.master.MasterAdmin.DeleteNotServingTablet() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_master_MasterAdmin_DeleteNotServingTablet, |
104 | | "Bytes received in response to yb.master.MasterAdmin.DeleteNotServingTablet() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.master.MasterAdmin.DeleteNotServingTablet() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_master_MasterAdmin_DisableTabletSplitting, |
110 | | "Bytes sent by yb.master.MasterAdmin.DisableTabletSplitting() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.master.MasterAdmin.DisableTabletSplitting() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_master_MasterAdmin_DisableTabletSplitting, |
116 | | "Bytes received in response to yb.master.MasterAdmin.DisableTabletSplitting() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.master.MasterAdmin.DisableTabletSplitting() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_master_MasterAdmin_IsTabletSplittingComplete, |
122 | | "Bytes sent by yb.master.MasterAdmin.IsTabletSplittingComplete() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.master.MasterAdmin.IsTabletSplittingComplete() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_master_MasterAdmin_IsTabletSplittingComplete, |
128 | | "Bytes received in response to yb.master.MasterAdmin.IsTabletSplittingComplete() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.master.MasterAdmin.IsTabletSplittingComplete() RPC requests"); |
131 | | |
132 | | METRIC_DEFINE_counter( |
133 | | server, proxy_request_bytes_yb_master_MasterAdmin_DdlLog, |
134 | | "Bytes sent by yb.master.MasterAdmin.DdlLog() RPC requests", |
135 | | yb::MetricUnit::kBytes, |
136 | | "Bytes sent by yb.master.MasterAdmin.DdlLog() RPC requests"); |
137 | | |
138 | | METRIC_DEFINE_counter( |
139 | | server, proxy_response_bytes_yb_master_MasterAdmin_DdlLog, |
140 | | "Bytes received in response to yb.master.MasterAdmin.DdlLog() RPC requests", |
141 | | yb::MetricUnit::kBytes, |
142 | | "Bytes received in response to yb.master.MasterAdmin.DdlLog() RPC requests"); |
143 | | |
144 | | namespace yb { |
145 | | namespace master { |
146 | | |
147 | | |
148 | | namespace { |
149 | | |
150 | | const std::string kFullMasterAdminName = "yb.master.MasterAdmin"; |
151 | | |
152 | 30.3k | ::yb::rpc::ProxyMetricsPtr CreateMasterAdminMetrics(const scoped_refptr<MetricEntity>& entity) { |
153 | 30.3k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<11>>(); |
154 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kFlushTables)] = { |
155 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_FlushTables.Instantiate(entity), |
156 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_FlushTables.Instantiate(entity) |
157 | 30.3k | }; |
158 | | |
159 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kIsFlushTablesDone)] = { |
160 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_IsFlushTablesDone.Instantiate(entity), |
161 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_IsFlushTablesDone.Instantiate(entity) |
162 | 30.3k | }; |
163 | | |
164 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kFlushSysCatalog)] = { |
165 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_FlushSysCatalog.Instantiate(entity), |
166 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_FlushSysCatalog.Instantiate(entity) |
167 | 30.3k | }; |
168 | | |
169 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kCompactSysCatalog)] = { |
170 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_CompactSysCatalog.Instantiate(entity), |
171 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_CompactSysCatalog.Instantiate(entity) |
172 | 30.3k | }; |
173 | | |
174 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kIsInitDbDone)] = { |
175 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_IsInitDbDone.Instantiate(entity), |
176 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_IsInitDbDone.Instantiate(entity) |
177 | 30.3k | }; |
178 | | |
179 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kSplitTablet)] = { |
180 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_SplitTablet.Instantiate(entity), |
181 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_SplitTablet.Instantiate(entity) |
182 | 30.3k | }; |
183 | | |
184 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kCreateTransactionStatusTable)] = { |
185 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_CreateTransactionStatusTable.Instantiate(entity), |
186 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_CreateTransactionStatusTable.Instantiate(entity) |
187 | 30.3k | }; |
188 | | |
189 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kDeleteNotServingTablet)] = { |
190 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_DeleteNotServingTablet.Instantiate(entity), |
191 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_DeleteNotServingTablet.Instantiate(entity) |
192 | 30.3k | }; |
193 | | |
194 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kDisableTabletSplitting)] = { |
195 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_DisableTabletSplitting.Instantiate(entity), |
196 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_DisableTabletSplitting.Instantiate(entity) |
197 | 30.3k | }; |
198 | | |
199 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kIsTabletSplittingComplete)] = { |
200 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_IsTabletSplittingComplete.Instantiate(entity), |
201 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_IsTabletSplittingComplete.Instantiate(entity) |
202 | 30.3k | }; |
203 | | |
204 | 30.3k | result->value[to_underlying(MasterAdminRpcMethodIndexes::kDdlLog)] = { |
205 | 30.3k | METRIC_proxy_request_bytes_yb_master_MasterAdmin_DdlLog.Instantiate(entity), |
206 | 30.3k | METRIC_proxy_response_bytes_yb_master_MasterAdmin_DdlLog.Instantiate(entity) |
207 | 30.3k | }; |
208 | | |
209 | 30.3k | return result; |
210 | 30.3k | } |
211 | | |
212 | | |
213 | | } // namespace |
214 | | |
215 | | MasterAdminProxy::MasterAdminProxy( |
216 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
217 | | const ::yb::rpc::Protocol* protocol, |
218 | | const ::yb::MonoDelta& resolve_cache_timeout) |
219 | | : ProxyBase(kFullMasterAdminName, &CreateMasterAdminMetrics, |
220 | 35.3k | cache, remote, protocol, resolve_cache_timeout) {} |
221 | | |
222 | | ::yb::Status MasterAdminProxy::FlushTables( |
223 | 0 | const ::yb::master::FlushTablesRequestPB &req, ::yb::master::FlushTablesResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
224 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "FlushTables"); |
225 | 0 | return proxy().SyncRequest( |
226 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kFlushTables)), req, resp, controller); |
227 | 0 | } |
228 | | |
229 | | void MasterAdminProxy::FlushTablesAsync( |
230 | | const ::yb::master::FlushTablesRequestPB &req, ::yb::master::FlushTablesResponsePB *resp, ::yb::rpc::RpcController *controller, |
231 | 10 | ::yb::rpc::ResponseCallback callback) const { |
232 | 10 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "FlushTables"); |
233 | 10 | proxy().AsyncRequest( |
234 | 10 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kFlushTables)), req, resp, controller, std::move(callback)); |
235 | 10 | } |
236 | | |
237 | | ::yb::Status MasterAdminProxy::IsFlushTablesDone( |
238 | 0 | const ::yb::master::IsFlushTablesDoneRequestPB &req, ::yb::master::IsFlushTablesDoneResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
239 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsFlushTablesDone"); |
240 | 0 | return proxy().SyncRequest( |
241 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsFlushTablesDone)), req, resp, controller); |
242 | 0 | } |
243 | | |
244 | | void MasterAdminProxy::IsFlushTablesDoneAsync( |
245 | | const ::yb::master::IsFlushTablesDoneRequestPB &req, ::yb::master::IsFlushTablesDoneResponsePB *resp, ::yb::rpc::RpcController *controller, |
246 | 21 | ::yb::rpc::ResponseCallback callback) const { |
247 | 21 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsFlushTablesDone"); |
248 | 21 | proxy().AsyncRequest( |
249 | 21 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsFlushTablesDone)), req, resp, controller, std::move(callback)); |
250 | 21 | } |
251 | | |
252 | | ::yb::Status MasterAdminProxy::FlushSysCatalog( |
253 | 0 | const ::yb::master::FlushSysCatalogRequestPB &req, ::yb::master::FlushSysCatalogResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
254 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "FlushSysCatalog"); |
255 | 0 | return proxy().SyncRequest( |
256 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kFlushSysCatalog)), req, resp, controller); |
257 | 0 | } |
258 | | |
259 | | void MasterAdminProxy::FlushSysCatalogAsync( |
260 | | const ::yb::master::FlushSysCatalogRequestPB &req, ::yb::master::FlushSysCatalogResponsePB *resp, ::yb::rpc::RpcController *controller, |
261 | 0 | ::yb::rpc::ResponseCallback callback) const { |
262 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "FlushSysCatalog"); |
263 | 0 | proxy().AsyncRequest( |
264 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kFlushSysCatalog)), req, resp, controller, std::move(callback)); |
265 | 0 | } |
266 | | |
267 | | ::yb::Status MasterAdminProxy::CompactSysCatalog( |
268 | 0 | const ::yb::master::CompactSysCatalogRequestPB &req, ::yb::master::CompactSysCatalogResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
269 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CompactSysCatalog"); |
270 | 0 | return proxy().SyncRequest( |
271 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kCompactSysCatalog)), req, resp, controller); |
272 | 0 | } |
273 | | |
274 | | void MasterAdminProxy::CompactSysCatalogAsync( |
275 | | const ::yb::master::CompactSysCatalogRequestPB &req, ::yb::master::CompactSysCatalogResponsePB *resp, ::yb::rpc::RpcController *controller, |
276 | 0 | ::yb::rpc::ResponseCallback callback) const { |
277 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CompactSysCatalog"); |
278 | 0 | proxy().AsyncRequest( |
279 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kCompactSysCatalog)), req, resp, controller, std::move(callback)); |
280 | 0 | } |
281 | | |
282 | | ::yb::Status MasterAdminProxy::IsInitDbDone( |
283 | 3.89k | const ::yb::master::IsInitDbDoneRequestPB &req, ::yb::master::IsInitDbDoneResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
284 | 3.89k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsInitDbDone"); |
285 | 3.89k | return proxy().SyncRequest( |
286 | 3.89k | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsInitDbDone)), req, resp, controller); |
287 | 3.89k | } |
288 | | |
289 | | void MasterAdminProxy::IsInitDbDoneAsync( |
290 | | const ::yb::master::IsInitDbDoneRequestPB &req, ::yb::master::IsInitDbDoneResponsePB *resp, ::yb::rpc::RpcController *controller, |
291 | 0 | ::yb::rpc::ResponseCallback callback) const { |
292 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsInitDbDone"); |
293 | 0 | proxy().AsyncRequest( |
294 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsInitDbDone)), req, resp, controller, std::move(callback)); |
295 | 0 | } |
296 | | |
297 | | ::yb::Status MasterAdminProxy::SplitTablet( |
298 | 66 | const ::yb::master::SplitTabletRequestPB &req, ::yb::master::SplitTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
299 | 66 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SplitTablet"); |
300 | 66 | return proxy().SyncRequest( |
301 | 66 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kSplitTablet)), req, resp, controller); |
302 | 66 | } |
303 | | |
304 | | void MasterAdminProxy::SplitTabletAsync( |
305 | | const ::yb::master::SplitTabletRequestPB &req, ::yb::master::SplitTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
306 | 0 | ::yb::rpc::ResponseCallback callback) const { |
307 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SplitTablet"); |
308 | 0 | proxy().AsyncRequest( |
309 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kSplitTablet)), req, resp, controller, std::move(callback)); |
310 | 0 | } |
311 | | |
312 | | ::yb::Status MasterAdminProxy::CreateTransactionStatusTable( |
313 | 0 | const ::yb::master::CreateTransactionStatusTableRequestPB &req, ::yb::master::CreateTransactionStatusTableResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
314 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateTransactionStatusTable"); |
315 | 0 | return proxy().SyncRequest( |
316 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kCreateTransactionStatusTable)), req, resp, controller); |
317 | 0 | } |
318 | | |
319 | | void MasterAdminProxy::CreateTransactionStatusTableAsync( |
320 | | const ::yb::master::CreateTransactionStatusTableRequestPB &req, ::yb::master::CreateTransactionStatusTableResponsePB *resp, ::yb::rpc::RpcController *controller, |
321 | 0 | ::yb::rpc::ResponseCallback callback) const { |
322 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateTransactionStatusTable"); |
323 | 0 | proxy().AsyncRequest( |
324 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kCreateTransactionStatusTable)), req, resp, controller, std::move(callback)); |
325 | 0 | } |
326 | | |
327 | | ::yb::Status MasterAdminProxy::DeleteNotServingTablet( |
328 | 0 | const ::yb::master::DeleteNotServingTabletRequestPB &req, ::yb::master::DeleteNotServingTabletResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
329 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteNotServingTablet"); |
330 | 0 | return proxy().SyncRequest( |
331 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDeleteNotServingTablet)), req, resp, controller); |
332 | 0 | } |
333 | | |
334 | | void MasterAdminProxy::DeleteNotServingTabletAsync( |
335 | | const ::yb::master::DeleteNotServingTabletRequestPB &req, ::yb::master::DeleteNotServingTabletResponsePB *resp, ::yb::rpc::RpcController *controller, |
336 | 6 | ::yb::rpc::ResponseCallback callback) const { |
337 | 6 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteNotServingTablet"); |
338 | 6 | proxy().AsyncRequest( |
339 | 6 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDeleteNotServingTablet)), req, resp, controller, std::move(callback)); |
340 | 6 | } |
341 | | |
342 | | ::yb::Status MasterAdminProxy::DisableTabletSplitting( |
343 | 0 | const ::yb::master::DisableTabletSplittingRequestPB &req, ::yb::master::DisableTabletSplittingResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
344 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DisableTabletSplitting"); |
345 | 0 | return proxy().SyncRequest( |
346 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDisableTabletSplitting)), req, resp, controller); |
347 | 0 | } |
348 | | |
349 | | void MasterAdminProxy::DisableTabletSplittingAsync( |
350 | | const ::yb::master::DisableTabletSplittingRequestPB &req, ::yb::master::DisableTabletSplittingResponsePB *resp, ::yb::rpc::RpcController *controller, |
351 | 0 | ::yb::rpc::ResponseCallback callback) const { |
352 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DisableTabletSplitting"); |
353 | 0 | proxy().AsyncRequest( |
354 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDisableTabletSplitting)), req, resp, controller, std::move(callback)); |
355 | 0 | } |
356 | | |
357 | | ::yb::Status MasterAdminProxy::IsTabletSplittingComplete( |
358 | 0 | const ::yb::master::IsTabletSplittingCompleteRequestPB &req, ::yb::master::IsTabletSplittingCompleteResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
359 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsTabletSplittingComplete"); |
360 | 0 | return proxy().SyncRequest( |
361 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsTabletSplittingComplete)), req, resp, controller); |
362 | 0 | } |
363 | | |
364 | | void MasterAdminProxy::IsTabletSplittingCompleteAsync( |
365 | | const ::yb::master::IsTabletSplittingCompleteRequestPB &req, ::yb::master::IsTabletSplittingCompleteResponsePB *resp, ::yb::rpc::RpcController *controller, |
366 | 0 | ::yb::rpc::ResponseCallback callback) const { |
367 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsTabletSplittingComplete"); |
368 | 0 | proxy().AsyncRequest( |
369 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kIsTabletSplittingComplete)), req, resp, controller, std::move(callback)); |
370 | 0 | } |
371 | | |
372 | | ::yb::Status MasterAdminProxy::DdlLog( |
373 | 1 | const ::yb::master::DdlLogRequestPB &req, ::yb::master::DdlLogResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
374 | 1 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DdlLog"); |
375 | 1 | return proxy().SyncRequest( |
376 | 1 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDdlLog)), req, resp, controller); |
377 | 1 | } |
378 | | |
379 | | void MasterAdminProxy::DdlLogAsync( |
380 | | const ::yb::master::DdlLogRequestPB &req, ::yb::master::DdlLogResponsePB *resp, ::yb::rpc::RpcController *controller, |
381 | 0 | ::yb::rpc::ResponseCallback callback) const { |
382 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DdlLog"); |
383 | 0 | proxy().AsyncRequest( |
384 | 0 | &method, metrics<11>(static_cast<size_t>(MasterAdminRpcMethodIndexes::kDdlLog)), req, resp, controller, std::move(callback)); |
385 | 0 | } |
386 | | |
387 | | } // namespace master |
388 | | } // namespace yb |