/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_replication.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_replication.proto |
2 | | |
3 | | #include "yb/master/master_replication.proxy.h" |
4 | | |
5 | | #include "yb/master/master_replication.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_MasterReplication_ValidateReplicationInfo, |
14 | | "Bytes sent by yb.master.MasterReplication.ValidateReplicationInfo() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterReplication.ValidateReplicationInfo() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterReplication_ValidateReplicationInfo, |
20 | | "Bytes received in response to yb.master.MasterReplication.ValidateReplicationInfo() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterReplication.ValidateReplicationInfo() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_master_MasterReplication_CreateCDCStream, |
26 | | "Bytes sent by yb.master.MasterReplication.CreateCDCStream() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.master.MasterReplication.CreateCDCStream() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_master_MasterReplication_CreateCDCStream, |
32 | | "Bytes received in response to yb.master.MasterReplication.CreateCDCStream() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.master.MasterReplication.CreateCDCStream() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_master_MasterReplication_DeleteCDCStream, |
38 | | "Bytes sent by yb.master.MasterReplication.DeleteCDCStream() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.master.MasterReplication.DeleteCDCStream() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_master_MasterReplication_DeleteCDCStream, |
44 | | "Bytes received in response to yb.master.MasterReplication.DeleteCDCStream() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.master.MasterReplication.DeleteCDCStream() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_master_MasterReplication_ListCDCStreams, |
50 | | "Bytes sent by yb.master.MasterReplication.ListCDCStreams() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.master.MasterReplication.ListCDCStreams() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_master_MasterReplication_ListCDCStreams, |
56 | | "Bytes received in response to yb.master.MasterReplication.ListCDCStreams() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.master.MasterReplication.ListCDCStreams() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_master_MasterReplication_GetCDCStream, |
62 | | "Bytes sent by yb.master.MasterReplication.GetCDCStream() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.master.MasterReplication.GetCDCStream() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_master_MasterReplication_GetCDCStream, |
68 | | "Bytes received in response to yb.master.MasterReplication.GetCDCStream() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.master.MasterReplication.GetCDCStream() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_master_MasterReplication_GetCDCDBStreamInfo, |
74 | | "Bytes sent by yb.master.MasterReplication.GetCDCDBStreamInfo() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.master.MasterReplication.GetCDCDBStreamInfo() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_master_MasterReplication_GetCDCDBStreamInfo, |
80 | | "Bytes received in response to yb.master.MasterReplication.GetCDCDBStreamInfo() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.master.MasterReplication.GetCDCDBStreamInfo() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_master_MasterReplication_UpdateCDCStream, |
86 | | "Bytes sent by yb.master.MasterReplication.UpdateCDCStream() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.master.MasterReplication.UpdateCDCStream() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_master_MasterReplication_UpdateCDCStream, |
92 | | "Bytes received in response to yb.master.MasterReplication.UpdateCDCStream() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.master.MasterReplication.UpdateCDCStream() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_master_MasterReplication_SetupUniverseReplication, |
98 | | "Bytes sent by yb.master.MasterReplication.SetupUniverseReplication() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.master.MasterReplication.SetupUniverseReplication() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_master_MasterReplication_SetupUniverseReplication, |
104 | | "Bytes received in response to yb.master.MasterReplication.SetupUniverseReplication() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.master.MasterReplication.SetupUniverseReplication() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_master_MasterReplication_DeleteUniverseReplication, |
110 | | "Bytes sent by yb.master.MasterReplication.DeleteUniverseReplication() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.master.MasterReplication.DeleteUniverseReplication() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_master_MasterReplication_DeleteUniverseReplication, |
116 | | "Bytes received in response to yb.master.MasterReplication.DeleteUniverseReplication() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.master.MasterReplication.DeleteUniverseReplication() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_master_MasterReplication_AlterUniverseReplication, |
122 | | "Bytes sent by yb.master.MasterReplication.AlterUniverseReplication() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.master.MasterReplication.AlterUniverseReplication() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_master_MasterReplication_AlterUniverseReplication, |
128 | | "Bytes received in response to yb.master.MasterReplication.AlterUniverseReplication() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.master.MasterReplication.AlterUniverseReplication() RPC requests"); |
131 | | |
132 | | METRIC_DEFINE_counter( |
133 | | server, proxy_request_bytes_yb_master_MasterReplication_SetUniverseReplicationEnabled, |
134 | | "Bytes sent by yb.master.MasterReplication.SetUniverseReplicationEnabled() RPC requests", |
135 | | yb::MetricUnit::kBytes, |
136 | | "Bytes sent by yb.master.MasterReplication.SetUniverseReplicationEnabled() RPC requests"); |
137 | | |
138 | | METRIC_DEFINE_counter( |
139 | | server, proxy_response_bytes_yb_master_MasterReplication_SetUniverseReplicationEnabled, |
140 | | "Bytes received in response to yb.master.MasterReplication.SetUniverseReplicationEnabled() RPC requests", |
141 | | yb::MetricUnit::kBytes, |
142 | | "Bytes received in response to yb.master.MasterReplication.SetUniverseReplicationEnabled() RPC requests"); |
143 | | |
144 | | METRIC_DEFINE_counter( |
145 | | server, proxy_request_bytes_yb_master_MasterReplication_GetUniverseReplication, |
146 | | "Bytes sent by yb.master.MasterReplication.GetUniverseReplication() RPC requests", |
147 | | yb::MetricUnit::kBytes, |
148 | | "Bytes sent by yb.master.MasterReplication.GetUniverseReplication() RPC requests"); |
149 | | |
150 | | METRIC_DEFINE_counter( |
151 | | server, proxy_response_bytes_yb_master_MasterReplication_GetUniverseReplication, |
152 | | "Bytes received in response to yb.master.MasterReplication.GetUniverseReplication() RPC requests", |
153 | | yb::MetricUnit::kBytes, |
154 | | "Bytes received in response to yb.master.MasterReplication.GetUniverseReplication() RPC requests"); |
155 | | |
156 | | METRIC_DEFINE_counter( |
157 | | server, proxy_request_bytes_yb_master_MasterReplication_IsSetupUniverseReplicationDone, |
158 | | "Bytes sent by yb.master.MasterReplication.IsSetupUniverseReplicationDone() RPC requests", |
159 | | yb::MetricUnit::kBytes, |
160 | | "Bytes sent by yb.master.MasterReplication.IsSetupUniverseReplicationDone() RPC requests"); |
161 | | |
162 | | METRIC_DEFINE_counter( |
163 | | server, proxy_response_bytes_yb_master_MasterReplication_IsSetupUniverseReplicationDone, |
164 | | "Bytes received in response to yb.master.MasterReplication.IsSetupUniverseReplicationDone() RPC requests", |
165 | | yb::MetricUnit::kBytes, |
166 | | "Bytes received in response to yb.master.MasterReplication.IsSetupUniverseReplicationDone() RPC requests"); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, proxy_request_bytes_yb_master_MasterReplication_UpdateConsumerOnProducerSplit, |
170 | | "Bytes sent by yb.master.MasterReplication.UpdateConsumerOnProducerSplit() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes sent by yb.master.MasterReplication.UpdateConsumerOnProducerSplit() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, proxy_response_bytes_yb_master_MasterReplication_UpdateConsumerOnProducerSplit, |
176 | | "Bytes received in response to yb.master.MasterReplication.UpdateConsumerOnProducerSplit() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes received in response to yb.master.MasterReplication.UpdateConsumerOnProducerSplit() RPC requests"); |
179 | | |
180 | | namespace yb { |
181 | | namespace master { |
182 | | |
183 | | |
184 | | namespace { |
185 | | |
186 | | const std::string kFullMasterReplicationName = "yb.master.MasterReplication"; |
187 | | |
188 | 30.2k | ::yb::rpc::ProxyMetricsPtr CreateMasterReplicationMetrics(const scoped_refptr<MetricEntity>& entity) { |
189 | 30.2k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<14>>(); |
190 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kValidateReplicationInfo)] = { |
191 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_ValidateReplicationInfo.Instantiate(entity), |
192 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_ValidateReplicationInfo.Instantiate(entity) |
193 | 30.2k | }; |
194 | | |
195 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kCreateCDCStream)] = { |
196 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_CreateCDCStream.Instantiate(entity), |
197 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_CreateCDCStream.Instantiate(entity) |
198 | 30.2k | }; |
199 | | |
200 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kDeleteCDCStream)] = { |
201 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_DeleteCDCStream.Instantiate(entity), |
202 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_DeleteCDCStream.Instantiate(entity) |
203 | 30.2k | }; |
204 | | |
205 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kListCDCStreams)] = { |
206 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_ListCDCStreams.Instantiate(entity), |
207 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_ListCDCStreams.Instantiate(entity) |
208 | 30.2k | }; |
209 | | |
210 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kGetCDCStream)] = { |
211 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_GetCDCStream.Instantiate(entity), |
212 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_GetCDCStream.Instantiate(entity) |
213 | 30.2k | }; |
214 | | |
215 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kGetCDCDBStreamInfo)] = { |
216 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_GetCDCDBStreamInfo.Instantiate(entity), |
217 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_GetCDCDBStreamInfo.Instantiate(entity) |
218 | 30.2k | }; |
219 | | |
220 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kUpdateCDCStream)] = { |
221 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_UpdateCDCStream.Instantiate(entity), |
222 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_UpdateCDCStream.Instantiate(entity) |
223 | 30.2k | }; |
224 | | |
225 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kSetupUniverseReplication)] = { |
226 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_SetupUniverseReplication.Instantiate(entity), |
227 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_SetupUniverseReplication.Instantiate(entity) |
228 | 30.2k | }; |
229 | | |
230 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kDeleteUniverseReplication)] = { |
231 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_DeleteUniverseReplication.Instantiate(entity), |
232 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_DeleteUniverseReplication.Instantiate(entity) |
233 | 30.2k | }; |
234 | | |
235 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kAlterUniverseReplication)] = { |
236 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_AlterUniverseReplication.Instantiate(entity), |
237 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_AlterUniverseReplication.Instantiate(entity) |
238 | 30.2k | }; |
239 | | |
240 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kSetUniverseReplicationEnabled)] = { |
241 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_SetUniverseReplicationEnabled.Instantiate(entity), |
242 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_SetUniverseReplicationEnabled.Instantiate(entity) |
243 | 30.2k | }; |
244 | | |
245 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kGetUniverseReplication)] = { |
246 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_GetUniverseReplication.Instantiate(entity), |
247 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_GetUniverseReplication.Instantiate(entity) |
248 | 30.2k | }; |
249 | | |
250 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kIsSetupUniverseReplicationDone)] = { |
251 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_IsSetupUniverseReplicationDone.Instantiate(entity), |
252 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_IsSetupUniverseReplicationDone.Instantiate(entity) |
253 | 30.2k | }; |
254 | | |
255 | 30.2k | result->value[to_underlying(MasterReplicationRpcMethodIndexes::kUpdateConsumerOnProducerSplit)] = { |
256 | 30.2k | METRIC_proxy_request_bytes_yb_master_MasterReplication_UpdateConsumerOnProducerSplit.Instantiate(entity), |
257 | 30.2k | METRIC_proxy_response_bytes_yb_master_MasterReplication_UpdateConsumerOnProducerSplit.Instantiate(entity) |
258 | 30.2k | }; |
259 | | |
260 | 30.2k | return result; |
261 | 30.2k | } |
262 | | |
263 | | |
264 | | } // namespace |
265 | | |
266 | | MasterReplicationProxy::MasterReplicationProxy( |
267 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
268 | | const ::yb::rpc::Protocol* protocol, |
269 | | const ::yb::MonoDelta& resolve_cache_timeout) |
270 | | : ProxyBase(kFullMasterReplicationName, &CreateMasterReplicationMetrics, |
271 | 31.5k | cache, remote, protocol, resolve_cache_timeout) {} |
272 | | |
273 | | ::yb::Status MasterReplicationProxy::ValidateReplicationInfo( |
274 | 0 | const ::yb::master::ValidateReplicationInfoRequestPB &req, ::yb::master::ValidateReplicationInfoResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
275 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ValidateReplicationInfo"); |
276 | 0 | return proxy().SyncRequest( |
277 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kValidateReplicationInfo)), req, resp, controller); |
278 | 0 | } |
279 | | |
280 | | void MasterReplicationProxy::ValidateReplicationInfoAsync( |
281 | | const ::yb::master::ValidateReplicationInfoRequestPB &req, ::yb::master::ValidateReplicationInfoResponsePB *resp, ::yb::rpc::RpcController *controller, |
282 | 1 | ::yb::rpc::ResponseCallback callback) const { |
283 | 1 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ValidateReplicationInfo"); |
284 | 1 | proxy().AsyncRequest( |
285 | 1 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kValidateReplicationInfo)), req, resp, controller, std::move(callback)); |
286 | 1 | } |
287 | | |
288 | | ::yb::Status MasterReplicationProxy::CreateCDCStream( |
289 | 5 | const ::yb::master::CreateCDCStreamRequestPB &req, ::yb::master::CreateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
290 | 5 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateCDCStream"); |
291 | 5 | return proxy().SyncRequest( |
292 | 5 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kCreateCDCStream)), req, resp, controller); |
293 | 5 | } |
294 | | |
295 | | void MasterReplicationProxy::CreateCDCStreamAsync( |
296 | | const ::yb::master::CreateCDCStreamRequestPB &req, ::yb::master::CreateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
297 | 5.49k | ::yb::rpc::ResponseCallback callback) const { |
298 | 5.49k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateCDCStream"); |
299 | 5.49k | proxy().AsyncRequest( |
300 | 5.49k | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kCreateCDCStream)), req, resp, controller, std::move(callback)); |
301 | 5.49k | } |
302 | | |
303 | | ::yb::Status MasterReplicationProxy::DeleteCDCStream( |
304 | 1 | const ::yb::master::DeleteCDCStreamRequestPB &req, ::yb::master::DeleteCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
305 | 1 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteCDCStream"); |
306 | 1 | return proxy().SyncRequest( |
307 | 1 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kDeleteCDCStream)), req, resp, controller); |
308 | 1 | } |
309 | | |
310 | | void MasterReplicationProxy::DeleteCDCStreamAsync( |
311 | | const ::yb::master::DeleteCDCStreamRequestPB &req, ::yb::master::DeleteCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
312 | 0 | ::yb::rpc::ResponseCallback callback) const { |
313 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteCDCStream"); |
314 | 0 | proxy().AsyncRequest( |
315 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kDeleteCDCStream)), req, resp, controller, std::move(callback)); |
316 | 0 | } |
317 | | |
318 | | ::yb::Status MasterReplicationProxy::ListCDCStreams( |
319 | 1 | const ::yb::master::ListCDCStreamsRequestPB &req, ::yb::master::ListCDCStreamsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
320 | 1 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListCDCStreams"); |
321 | 1 | return proxy().SyncRequest( |
322 | 1 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kListCDCStreams)), req, resp, controller); |
323 | 1 | } |
324 | | |
325 | | void MasterReplicationProxy::ListCDCStreamsAsync( |
326 | | const ::yb::master::ListCDCStreamsRequestPB &req, ::yb::master::ListCDCStreamsResponsePB *resp, ::yb::rpc::RpcController *controller, |
327 | 0 | ::yb::rpc::ResponseCallback callback) const { |
328 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ListCDCStreams"); |
329 | 0 | proxy().AsyncRequest( |
330 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kListCDCStreams)), req, resp, controller, std::move(callback)); |
331 | 0 | } |
332 | | |
333 | | ::yb::Status MasterReplicationProxy::GetCDCStream( |
334 | 5 | const ::yb::master::GetCDCStreamRequestPB &req, ::yb::master::GetCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
335 | 5 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetCDCStream"); |
336 | 5 | return proxy().SyncRequest( |
337 | 5 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetCDCStream)), req, resp, controller); |
338 | 5 | } |
339 | | |
340 | | void MasterReplicationProxy::GetCDCStreamAsync( |
341 | | const ::yb::master::GetCDCStreamRequestPB &req, ::yb::master::GetCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
342 | 1 | ::yb::rpc::ResponseCallback callback) const { |
343 | 1 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetCDCStream"); |
344 | 1 | proxy().AsyncRequest( |
345 | 1 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetCDCStream)), req, resp, controller, std::move(callback)); |
346 | 1 | } |
347 | | |
348 | | ::yb::Status MasterReplicationProxy::GetCDCDBStreamInfo( |
349 | 0 | const ::yb::master::GetCDCDBStreamInfoRequestPB &req, ::yb::master::GetCDCDBStreamInfoResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
350 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetCDCDBStreamInfo"); |
351 | 0 | return proxy().SyncRequest( |
352 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetCDCDBStreamInfo)), req, resp, controller); |
353 | 0 | } |
354 | | |
355 | | void MasterReplicationProxy::GetCDCDBStreamInfoAsync( |
356 | | const ::yb::master::GetCDCDBStreamInfoRequestPB &req, ::yb::master::GetCDCDBStreamInfoResponsePB *resp, ::yb::rpc::RpcController *controller, |
357 | 0 | ::yb::rpc::ResponseCallback callback) const { |
358 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetCDCDBStreamInfo"); |
359 | 0 | proxy().AsyncRequest( |
360 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetCDCDBStreamInfo)), req, resp, controller, std::move(callback)); |
361 | 0 | } |
362 | | |
363 | | ::yb::Status MasterReplicationProxy::UpdateCDCStream( |
364 | 0 | const ::yb::master::UpdateCDCStreamRequestPB &req, ::yb::master::UpdateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
365 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "UpdateCDCStream"); |
366 | 0 | return proxy().SyncRequest( |
367 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kUpdateCDCStream)), req, resp, controller); |
368 | 0 | } |
369 | | |
370 | | void MasterReplicationProxy::UpdateCDCStreamAsync( |
371 | | const ::yb::master::UpdateCDCStreamRequestPB &req, ::yb::master::UpdateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
372 | 0 | ::yb::rpc::ResponseCallback callback) const { |
373 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "UpdateCDCStream"); |
374 | 0 | proxy().AsyncRequest( |
375 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kUpdateCDCStream)), req, resp, controller, std::move(callback)); |
376 | 0 | } |
377 | | |
378 | | ::yb::Status MasterReplicationProxy::SetupUniverseReplication( |
379 | 2 | const ::yb::master::SetupUniverseReplicationRequestPB &req, ::yb::master::SetupUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
380 | 2 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetupUniverseReplication"); |
381 | 2 | return proxy().SyncRequest( |
382 | 2 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kSetupUniverseReplication)), req, resp, controller); |
383 | 2 | } |
384 | | |
385 | | void MasterReplicationProxy::SetupUniverseReplicationAsync( |
386 | | const ::yb::master::SetupUniverseReplicationRequestPB &req, ::yb::master::SetupUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller, |
387 | 0 | ::yb::rpc::ResponseCallback callback) const { |
388 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetupUniverseReplication"); |
389 | 0 | proxy().AsyncRequest( |
390 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kSetupUniverseReplication)), req, resp, controller, std::move(callback)); |
391 | 0 | } |
392 | | |
393 | | ::yb::Status MasterReplicationProxy::DeleteUniverseReplication( |
394 | 0 | const ::yb::master::DeleteUniverseReplicationRequestPB &req, ::yb::master::DeleteUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
395 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteUniverseReplication"); |
396 | 0 | return proxy().SyncRequest( |
397 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kDeleteUniverseReplication)), req, resp, controller); |
398 | 0 | } |
399 | | |
400 | | void MasterReplicationProxy::DeleteUniverseReplicationAsync( |
401 | | const ::yb::master::DeleteUniverseReplicationRequestPB &req, ::yb::master::DeleteUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller, |
402 | 0 | ::yb::rpc::ResponseCallback callback) const { |
403 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteUniverseReplication"); |
404 | 0 | proxy().AsyncRequest( |
405 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kDeleteUniverseReplication)), req, resp, controller, std::move(callback)); |
406 | 0 | } |
407 | | |
408 | | ::yb::Status MasterReplicationProxy::AlterUniverseReplication( |
409 | 0 | const ::yb::master::AlterUniverseReplicationRequestPB &req, ::yb::master::AlterUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
410 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AlterUniverseReplication"); |
411 | 0 | return proxy().SyncRequest( |
412 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kAlterUniverseReplication)), req, resp, controller); |
413 | 0 | } |
414 | | |
415 | | void MasterReplicationProxy::AlterUniverseReplicationAsync( |
416 | | const ::yb::master::AlterUniverseReplicationRequestPB &req, ::yb::master::AlterUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller, |
417 | 0 | ::yb::rpc::ResponseCallback callback) const { |
418 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AlterUniverseReplication"); |
419 | 0 | proxy().AsyncRequest( |
420 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kAlterUniverseReplication)), req, resp, controller, std::move(callback)); |
421 | 0 | } |
422 | | |
423 | | ::yb::Status MasterReplicationProxy::SetUniverseReplicationEnabled( |
424 | 0 | const ::yb::master::SetUniverseReplicationEnabledRequestPB &req, ::yb::master::SetUniverseReplicationEnabledResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
425 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetUniverseReplicationEnabled"); |
426 | 0 | return proxy().SyncRequest( |
427 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kSetUniverseReplicationEnabled)), req, resp, controller); |
428 | 0 | } |
429 | | |
430 | | void MasterReplicationProxy::SetUniverseReplicationEnabledAsync( |
431 | | const ::yb::master::SetUniverseReplicationEnabledRequestPB &req, ::yb::master::SetUniverseReplicationEnabledResponsePB *resp, ::yb::rpc::RpcController *controller, |
432 | 0 | ::yb::rpc::ResponseCallback callback) const { |
433 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "SetUniverseReplicationEnabled"); |
434 | 0 | proxy().AsyncRequest( |
435 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kSetUniverseReplicationEnabled)), req, resp, controller, std::move(callback)); |
436 | 0 | } |
437 | | |
438 | | ::yb::Status MasterReplicationProxy::GetUniverseReplication( |
439 | 0 | const ::yb::master::GetUniverseReplicationRequestPB &req, ::yb::master::GetUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
440 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetUniverseReplication"); |
441 | 0 | return proxy().SyncRequest( |
442 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetUniverseReplication)), req, resp, controller); |
443 | 0 | } |
444 | | |
445 | | void MasterReplicationProxy::GetUniverseReplicationAsync( |
446 | | const ::yb::master::GetUniverseReplicationRequestPB &req, ::yb::master::GetUniverseReplicationResponsePB *resp, ::yb::rpc::RpcController *controller, |
447 | 0 | ::yb::rpc::ResponseCallback callback) const { |
448 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetUniverseReplication"); |
449 | 0 | proxy().AsyncRequest( |
450 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kGetUniverseReplication)), req, resp, controller, std::move(callback)); |
451 | 0 | } |
452 | | |
453 | | ::yb::Status MasterReplicationProxy::IsSetupUniverseReplicationDone( |
454 | 0 | const ::yb::master::IsSetupUniverseReplicationDoneRequestPB &req, ::yb::master::IsSetupUniverseReplicationDoneResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
455 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsSetupUniverseReplicationDone"); |
456 | 0 | return proxy().SyncRequest( |
457 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kIsSetupUniverseReplicationDone)), req, resp, controller); |
458 | 0 | } |
459 | | |
460 | | void MasterReplicationProxy::IsSetupUniverseReplicationDoneAsync( |
461 | | const ::yb::master::IsSetupUniverseReplicationDoneRequestPB &req, ::yb::master::IsSetupUniverseReplicationDoneResponsePB *resp, ::yb::rpc::RpcController *controller, |
462 | 0 | ::yb::rpc::ResponseCallback callback) const { |
463 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "IsSetupUniverseReplicationDone"); |
464 | 0 | proxy().AsyncRequest( |
465 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kIsSetupUniverseReplicationDone)), req, resp, controller, std::move(callback)); |
466 | 0 | } |
467 | | |
468 | | ::yb::Status MasterReplicationProxy::UpdateConsumerOnProducerSplit( |
469 | 0 | const ::yb::master::UpdateConsumerOnProducerSplitRequestPB &req, ::yb::master::UpdateConsumerOnProducerSplitResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
470 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "UpdateConsumerOnProducerSplit"); |
471 | 0 | return proxy().SyncRequest( |
472 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kUpdateConsumerOnProducerSplit)), req, resp, controller); |
473 | 0 | } |
474 | | |
475 | | void MasterReplicationProxy::UpdateConsumerOnProducerSplitAsync( |
476 | | const ::yb::master::UpdateConsumerOnProducerSplitRequestPB &req, ::yb::master::UpdateConsumerOnProducerSplitResponsePB *resp, ::yb::rpc::RpcController *controller, |
477 | 0 | ::yb::rpc::ResponseCallback callback) const { |
478 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "UpdateConsumerOnProducerSplit"); |
479 | 0 | proxy().AsyncRequest( |
480 | 0 | &method, metrics<14>(static_cast<size_t>(MasterReplicationRpcMethodIndexes::kUpdateConsumerOnProducerSplit)), req, resp, controller, std::move(callback)); |
481 | 0 | } |
482 | | |
483 | | } // namespace master |
484 | | } // namespace yb |