/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/cdc/cdc_service.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/cdc/cdc_service.proto |
2 | | |
3 | | #include "yb/cdc/cdc_service.proxy.h" |
4 | | |
5 | | #include "yb/cdc/cdc_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_cdc_CDCService_CreateCDCStream, |
14 | | "Bytes sent by yb.cdc.CDCService.CreateCDCStream() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.cdc.CDCService.CreateCDCStream() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_cdc_CDCService_CreateCDCStream, |
20 | | "Bytes received in response to yb.cdc.CDCService.CreateCDCStream() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.cdc.CDCService.CreateCDCStream() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_cdc_CDCService_DeleteCDCStream, |
26 | | "Bytes sent by yb.cdc.CDCService.DeleteCDCStream() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.cdc.CDCService.DeleteCDCStream() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_cdc_CDCService_DeleteCDCStream, |
32 | | "Bytes received in response to yb.cdc.CDCService.DeleteCDCStream() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.cdc.CDCService.DeleteCDCStream() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_cdc_CDCService_ListTablets, |
38 | | "Bytes sent by yb.cdc.CDCService.ListTablets() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.cdc.CDCService.ListTablets() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_cdc_CDCService_ListTablets, |
44 | | "Bytes received in response to yb.cdc.CDCService.ListTablets() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.cdc.CDCService.ListTablets() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_cdc_CDCService_GetChanges, |
50 | | "Bytes sent by yb.cdc.CDCService.GetChanges() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.cdc.CDCService.GetChanges() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_cdc_CDCService_GetChanges, |
56 | | "Bytes received in response to yb.cdc.CDCService.GetChanges() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.cdc.CDCService.GetChanges() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_cdc_CDCService_GetCheckpoint, |
62 | | "Bytes sent by yb.cdc.CDCService.GetCheckpoint() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.cdc.CDCService.GetCheckpoint() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_cdc_CDCService_GetCheckpoint, |
68 | | "Bytes received in response to yb.cdc.CDCService.GetCheckpoint() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.cdc.CDCService.GetCheckpoint() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_cdc_CDCService_UpdateCdcReplicatedIndex, |
74 | | "Bytes sent by yb.cdc.CDCService.UpdateCdcReplicatedIndex() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.cdc.CDCService.UpdateCdcReplicatedIndex() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_cdc_CDCService_UpdateCdcReplicatedIndex, |
80 | | "Bytes received in response to yb.cdc.CDCService.UpdateCdcReplicatedIndex() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.cdc.CDCService.UpdateCdcReplicatedIndex() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_cdc_CDCService_BootstrapProducer, |
86 | | "Bytes sent by yb.cdc.CDCService.BootstrapProducer() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.cdc.CDCService.BootstrapProducer() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_cdc_CDCService_BootstrapProducer, |
92 | | "Bytes received in response to yb.cdc.CDCService.BootstrapProducer() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.cdc.CDCService.BootstrapProducer() RPC requests"); |
95 | | |
96 | | METRIC_DEFINE_counter( |
97 | | server, proxy_request_bytes_yb_cdc_CDCService_GetLatestEntryOpId, |
98 | | "Bytes sent by yb.cdc.CDCService.GetLatestEntryOpId() RPC requests", |
99 | | yb::MetricUnit::kBytes, |
100 | | "Bytes sent by yb.cdc.CDCService.GetLatestEntryOpId() RPC requests"); |
101 | | |
102 | | METRIC_DEFINE_counter( |
103 | | server, proxy_response_bytes_yb_cdc_CDCService_GetLatestEntryOpId, |
104 | | "Bytes received in response to yb.cdc.CDCService.GetLatestEntryOpId() RPC requests", |
105 | | yb::MetricUnit::kBytes, |
106 | | "Bytes received in response to yb.cdc.CDCService.GetLatestEntryOpId() RPC requests"); |
107 | | |
108 | | METRIC_DEFINE_counter( |
109 | | server, proxy_request_bytes_yb_cdc_CDCService_GetCDCDBStreamInfo, |
110 | | "Bytes sent by yb.cdc.CDCService.GetCDCDBStreamInfo() RPC requests", |
111 | | yb::MetricUnit::kBytes, |
112 | | "Bytes sent by yb.cdc.CDCService.GetCDCDBStreamInfo() RPC requests"); |
113 | | |
114 | | METRIC_DEFINE_counter( |
115 | | server, proxy_response_bytes_yb_cdc_CDCService_GetCDCDBStreamInfo, |
116 | | "Bytes received in response to yb.cdc.CDCService.GetCDCDBStreamInfo() RPC requests", |
117 | | yb::MetricUnit::kBytes, |
118 | | "Bytes received in response to yb.cdc.CDCService.GetCDCDBStreamInfo() RPC requests"); |
119 | | |
120 | | METRIC_DEFINE_counter( |
121 | | server, proxy_request_bytes_yb_cdc_CDCService_SetCDCCheckpoint, |
122 | | "Bytes sent by yb.cdc.CDCService.SetCDCCheckpoint() RPC requests", |
123 | | yb::MetricUnit::kBytes, |
124 | | "Bytes sent by yb.cdc.CDCService.SetCDCCheckpoint() RPC requests"); |
125 | | |
126 | | METRIC_DEFINE_counter( |
127 | | server, proxy_response_bytes_yb_cdc_CDCService_SetCDCCheckpoint, |
128 | | "Bytes received in response to yb.cdc.CDCService.SetCDCCheckpoint() RPC requests", |
129 | | yb::MetricUnit::kBytes, |
130 | | "Bytes received in response to yb.cdc.CDCService.SetCDCCheckpoint() RPC requests"); |
131 | | |
132 | | namespace yb { |
133 | | namespace cdc { |
134 | | |
135 | | |
136 | | namespace { |
137 | | |
138 | | const std::string kFullCDCServiceName = "yb.cdc.CDCService"; |
139 | | |
140 | 80 | ::yb::rpc::ProxyMetricsPtr CreateCDCServiceMetrics(const scoped_refptr<MetricEntity>& entity) { |
141 | 80 | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<10>>(); |
142 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kCreateCDCStream)] = { |
143 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_CreateCDCStream.Instantiate(entity), |
144 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_CreateCDCStream.Instantiate(entity) |
145 | 80 | }; |
146 | | |
147 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kDeleteCDCStream)] = { |
148 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_DeleteCDCStream.Instantiate(entity), |
149 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_DeleteCDCStream.Instantiate(entity) |
150 | 80 | }; |
151 | | |
152 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kListTablets)] = { |
153 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_ListTablets.Instantiate(entity), |
154 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_ListTablets.Instantiate(entity) |
155 | 80 | }; |
156 | | |
157 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kGetChanges)] = { |
158 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_GetChanges.Instantiate(entity), |
159 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_GetChanges.Instantiate(entity) |
160 | 80 | }; |
161 | | |
162 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kGetCheckpoint)] = { |
163 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_GetCheckpoint.Instantiate(entity), |
164 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_GetCheckpoint.Instantiate(entity) |
165 | 80 | }; |
166 | | |
167 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kUpdateCdcReplicatedIndex)] = { |
168 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_UpdateCdcReplicatedIndex.Instantiate(entity), |
169 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_UpdateCdcReplicatedIndex.Instantiate(entity) |
170 | 80 | }; |
171 | | |
172 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kBootstrapProducer)] = { |
173 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_BootstrapProducer.Instantiate(entity), |
174 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_BootstrapProducer.Instantiate(entity) |
175 | 80 | }; |
176 | | |
177 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kGetLatestEntryOpId)] = { |
178 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_GetLatestEntryOpId.Instantiate(entity), |
179 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_GetLatestEntryOpId.Instantiate(entity) |
180 | 80 | }; |
181 | | |
182 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kGetCDCDBStreamInfo)] = { |
183 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_GetCDCDBStreamInfo.Instantiate(entity), |
184 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_GetCDCDBStreamInfo.Instantiate(entity) |
185 | 80 | }; |
186 | | |
187 | 80 | result->value[to_underlying(CDCServiceRpcMethodIndexes::kSetCDCCheckpoint)] = { |
188 | 80 | METRIC_proxy_request_bytes_yb_cdc_CDCService_SetCDCCheckpoint.Instantiate(entity), |
189 | 80 | METRIC_proxy_response_bytes_yb_cdc_CDCService_SetCDCCheckpoint.Instantiate(entity) |
190 | 80 | }; |
191 | | |
192 | 80 | return result; |
193 | 80 | } |
194 | | |
195 | | |
196 | | } // namespace |
197 | | |
198 | | CDCServiceProxy::CDCServiceProxy( |
199 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
200 | | const ::yb::rpc::Protocol* protocol, |
201 | | const ::yb::MonoDelta& resolve_cache_timeout) |
202 | | : ProxyBase(kFullCDCServiceName, &CreateCDCServiceMetrics, |
203 | 80 | cache, remote, protocol, resolve_cache_timeout) {} |
204 | | |
205 | | ::yb::Status CDCServiceProxy::CreateCDCStream( |
206 | 0 | const ::yb::cdc::CreateCDCStreamRequestPB &req, ::yb::cdc::CreateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
207 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "CreateCDCStream"); |
208 | 0 | return proxy().SyncRequest( |
209 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kCreateCDCStream)), req, resp, controller); |
210 | 0 | } |
211 | | |
212 | | void CDCServiceProxy::CreateCDCStreamAsync( |
213 | | const ::yb::cdc::CreateCDCStreamRequestPB &req, ::yb::cdc::CreateCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
214 | 0 | ::yb::rpc::ResponseCallback callback) const { |
215 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "CreateCDCStream"); |
216 | 0 | proxy().AsyncRequest( |
217 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kCreateCDCStream)), req, resp, controller, std::move(callback)); |
218 | 0 | } |
219 | | |
220 | | ::yb::Status CDCServiceProxy::DeleteCDCStream( |
221 | 0 | const ::yb::cdc::DeleteCDCStreamRequestPB &req, ::yb::cdc::DeleteCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
222 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "DeleteCDCStream"); |
223 | 0 | return proxy().SyncRequest( |
224 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kDeleteCDCStream)), req, resp, controller); |
225 | 0 | } |
226 | | |
227 | | void CDCServiceProxy::DeleteCDCStreamAsync( |
228 | | const ::yb::cdc::DeleteCDCStreamRequestPB &req, ::yb::cdc::DeleteCDCStreamResponsePB *resp, ::yb::rpc::RpcController *controller, |
229 | 0 | ::yb::rpc::ResponseCallback callback) const { |
230 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "DeleteCDCStream"); |
231 | 0 | proxy().AsyncRequest( |
232 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kDeleteCDCStream)), req, resp, controller, std::move(callback)); |
233 | 0 | } |
234 | | |
235 | | ::yb::Status CDCServiceProxy::ListTablets( |
236 | 0 | const ::yb::cdc::ListTabletsRequestPB &req, ::yb::cdc::ListTabletsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
237 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "ListTablets"); |
238 | 0 | return proxy().SyncRequest( |
239 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kListTablets)), req, resp, controller); |
240 | 0 | } |
241 | | |
242 | | void CDCServiceProxy::ListTabletsAsync( |
243 | | const ::yb::cdc::ListTabletsRequestPB &req, ::yb::cdc::ListTabletsResponsePB *resp, ::yb::rpc::RpcController *controller, |
244 | 0 | ::yb::rpc::ResponseCallback callback) const { |
245 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "ListTablets"); |
246 | 0 | proxy().AsyncRequest( |
247 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kListTablets)), req, resp, controller, std::move(callback)); |
248 | 0 | } |
249 | | |
250 | | ::yb::Status CDCServiceProxy::GetChanges( |
251 | 0 | const ::yb::cdc::GetChangesRequestPB &req, ::yb::cdc::GetChangesResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
252 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetChanges"); |
253 | 0 | return proxy().SyncRequest( |
254 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetChanges)), req, resp, controller); |
255 | 0 | } |
256 | | |
257 | | void CDCServiceProxy::GetChangesAsync( |
258 | | const ::yb::cdc::GetChangesRequestPB &req, ::yb::cdc::GetChangesResponsePB *resp, ::yb::rpc::RpcController *controller, |
259 | 0 | ::yb::rpc::ResponseCallback callback) const { |
260 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetChanges"); |
261 | 0 | proxy().AsyncRequest( |
262 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetChanges)), req, resp, controller, std::move(callback)); |
263 | 0 | } |
264 | | |
265 | | ::yb::Status CDCServiceProxy::GetCheckpoint( |
266 | 0 | const ::yb::cdc::GetCheckpointRequestPB &req, ::yb::cdc::GetCheckpointResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
267 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetCheckpoint"); |
268 | 0 | return proxy().SyncRequest( |
269 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetCheckpoint)), req, resp, controller); |
270 | 0 | } |
271 | | |
272 | | void CDCServiceProxy::GetCheckpointAsync( |
273 | | const ::yb::cdc::GetCheckpointRequestPB &req, ::yb::cdc::GetCheckpointResponsePB *resp, ::yb::rpc::RpcController *controller, |
274 | 0 | ::yb::rpc::ResponseCallback callback) const { |
275 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetCheckpoint"); |
276 | 0 | proxy().AsyncRequest( |
277 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetCheckpoint)), req, resp, controller, std::move(callback)); |
278 | 0 | } |
279 | | |
280 | | ::yb::Status CDCServiceProxy::UpdateCdcReplicatedIndex( |
281 | 159 | const ::yb::cdc::UpdateCdcReplicatedIndexRequestPB &req, ::yb::cdc::UpdateCdcReplicatedIndexResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
282 | 159 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "UpdateCdcReplicatedIndex"); |
283 | 159 | return proxy().SyncRequest( |
284 | 159 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kUpdateCdcReplicatedIndex)), req, resp, controller); |
285 | 159 | } |
286 | | |
287 | | void CDCServiceProxy::UpdateCdcReplicatedIndexAsync( |
288 | | const ::yb::cdc::UpdateCdcReplicatedIndexRequestPB &req, ::yb::cdc::UpdateCdcReplicatedIndexResponsePB *resp, ::yb::rpc::RpcController *controller, |
289 | 0 | ::yb::rpc::ResponseCallback callback) const { |
290 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "UpdateCdcReplicatedIndex"); |
291 | 0 | proxy().AsyncRequest( |
292 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kUpdateCdcReplicatedIndex)), req, resp, controller, std::move(callback)); |
293 | 0 | } |
294 | | |
295 | | ::yb::Status CDCServiceProxy::BootstrapProducer( |
296 | 0 | const ::yb::cdc::BootstrapProducerRequestPB &req, ::yb::cdc::BootstrapProducerResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
297 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "BootstrapProducer"); |
298 | 0 | return proxy().SyncRequest( |
299 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kBootstrapProducer)), req, resp, controller); |
300 | 0 | } |
301 | | |
302 | | void CDCServiceProxy::BootstrapProducerAsync( |
303 | | const ::yb::cdc::BootstrapProducerRequestPB &req, ::yb::cdc::BootstrapProducerResponsePB *resp, ::yb::rpc::RpcController *controller, |
304 | 0 | ::yb::rpc::ResponseCallback callback) const { |
305 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "BootstrapProducer"); |
306 | 0 | proxy().AsyncRequest( |
307 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kBootstrapProducer)), req, resp, controller, std::move(callback)); |
308 | 0 | } |
309 | | |
310 | | ::yb::Status CDCServiceProxy::GetLatestEntryOpId( |
311 | 0 | const ::yb::cdc::GetLatestEntryOpIdRequestPB &req, ::yb::cdc::GetLatestEntryOpIdResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
312 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetLatestEntryOpId"); |
313 | 0 | return proxy().SyncRequest( |
314 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetLatestEntryOpId)), req, resp, controller); |
315 | 0 | } |
316 | | |
317 | | void CDCServiceProxy::GetLatestEntryOpIdAsync( |
318 | | const ::yb::cdc::GetLatestEntryOpIdRequestPB &req, ::yb::cdc::GetLatestEntryOpIdResponsePB *resp, ::yb::rpc::RpcController *controller, |
319 | 0 | ::yb::rpc::ResponseCallback callback) const { |
320 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetLatestEntryOpId"); |
321 | 0 | proxy().AsyncRequest( |
322 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetLatestEntryOpId)), req, resp, controller, std::move(callback)); |
323 | 0 | } |
324 | | |
325 | | ::yb::Status CDCServiceProxy::GetCDCDBStreamInfo( |
326 | 0 | const ::yb::cdc::GetCDCDBStreamInfoRequestPB &req, ::yb::cdc::GetCDCDBStreamInfoResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
327 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetCDCDBStreamInfo"); |
328 | 0 | return proxy().SyncRequest( |
329 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetCDCDBStreamInfo)), req, resp, controller); |
330 | 0 | } |
331 | | |
332 | | void CDCServiceProxy::GetCDCDBStreamInfoAsync( |
333 | | const ::yb::cdc::GetCDCDBStreamInfoRequestPB &req, ::yb::cdc::GetCDCDBStreamInfoResponsePB *resp, ::yb::rpc::RpcController *controller, |
334 | 0 | ::yb::rpc::ResponseCallback callback) const { |
335 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "GetCDCDBStreamInfo"); |
336 | 0 | proxy().AsyncRequest( |
337 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kGetCDCDBStreamInfo)), req, resp, controller, std::move(callback)); |
338 | 0 | } |
339 | | |
340 | | ::yb::Status CDCServiceProxy::SetCDCCheckpoint( |
341 | 0 | const ::yb::cdc::SetCDCCheckpointRequestPB &req, ::yb::cdc::SetCDCCheckpointResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
342 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "SetCDCCheckpoint"); |
343 | 0 | return proxy().SyncRequest( |
344 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kSetCDCCheckpoint)), req, resp, controller); |
345 | 0 | } |
346 | | |
347 | | void CDCServiceProxy::SetCDCCheckpointAsync( |
348 | | const ::yb::cdc::SetCDCCheckpointRequestPB &req, ::yb::cdc::SetCDCCheckpointResponsePB *resp, ::yb::rpc::RpcController *controller, |
349 | 0 | ::yb::rpc::ResponseCallback callback) const { |
350 | 0 | static ::yb::rpc::RemoteMethod method("yb.cdc.CDCService", "SetCDCCheckpoint"); |
351 | 0 | proxy().AsyncRequest( |
352 | 0 | &method, metrics<10>(static_cast<size_t>(CDCServiceRpcMethodIndexes::kSetCDCCheckpoint)), req, resp, controller, std::move(callback)); |
353 | 0 | } |
354 | | |
355 | | } // namespace cdc |
356 | | } // namespace yb |