/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_client.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_client.proto |
2 | | |
3 | | #include "yb/master/master_client.proxy.h" |
4 | | |
5 | | #include "yb/master/master_client.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_MasterClient_GetTabletLocations, |
14 | | "Bytes sent by yb.master.MasterClient.GetTabletLocations() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterClient.GetTabletLocations() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterClient_GetTabletLocations, |
20 | | "Bytes received in response to yb.master.MasterClient.GetTabletLocations() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterClient.GetTabletLocations() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_master_MasterClient_GetTableLocations, |
26 | | "Bytes sent by yb.master.MasterClient.GetTableLocations() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.master.MasterClient.GetTableLocations() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_master_MasterClient_GetTableLocations, |
32 | | "Bytes received in response to yb.master.MasterClient.GetTableLocations() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.master.MasterClient.GetTableLocations() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets, |
38 | | "Bytes sent by yb.master.MasterClient.GetTransactionStatusTablets() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.master.MasterClient.GetTransactionStatusTablets() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets, |
44 | | "Bytes received in response to yb.master.MasterClient.GetTransactionStatusTablets() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.master.MasterClient.GetTransactionStatusTablets() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_master_MasterClient_ReservePgsqlOids, |
50 | | "Bytes sent by yb.master.MasterClient.ReservePgsqlOids() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.master.MasterClient.ReservePgsqlOids() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_master_MasterClient_ReservePgsqlOids, |
56 | | "Bytes received in response to yb.master.MasterClient.ReservePgsqlOids() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.master.MasterClient.ReservePgsqlOids() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig, |
62 | | "Bytes sent by yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig, |
68 | | "Bytes received in response to yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.master.MasterClient.GetYsqlCatalogConfig() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_master_MasterClient_RedisConfigSet, |
74 | | "Bytes sent by yb.master.MasterClient.RedisConfigSet() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.master.MasterClient.RedisConfigSet() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_master_MasterClient_RedisConfigSet, |
80 | | "Bytes received in response to yb.master.MasterClient.RedisConfigSet() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.master.MasterClient.RedisConfigSet() RPC requests"); |
83 | | |
84 | | METRIC_DEFINE_counter( |
85 | | server, proxy_request_bytes_yb_master_MasterClient_RedisConfigGet, |
86 | | "Bytes sent by yb.master.MasterClient.RedisConfigGet() RPC requests", |
87 | | yb::MetricUnit::kBytes, |
88 | | "Bytes sent by yb.master.MasterClient.RedisConfigGet() RPC requests"); |
89 | | |
90 | | METRIC_DEFINE_counter( |
91 | | server, proxy_response_bytes_yb_master_MasterClient_RedisConfigGet, |
92 | | "Bytes received in response to yb.master.MasterClient.RedisConfigGet() RPC requests", |
93 | | yb::MetricUnit::kBytes, |
94 | | "Bytes received in response to yb.master.MasterClient.RedisConfigGet() RPC requests"); |
95 | | |
96 | | namespace yb { |
97 | | namespace master { |
98 | | |
99 | | |
100 | | namespace { |
101 | | |
102 | | const std::string kFullMasterClientName = "yb.master.MasterClient"; |
103 | | |
104 | 22.6k | ::yb::rpc::ProxyMetricsPtr CreateMasterClientMetrics(const scoped_refptr<MetricEntity>& entity) { |
105 | 22.6k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<7>>(); |
106 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTabletLocations)] = { |
107 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity), |
108 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_GetTabletLocations.Instantiate(entity) |
109 | 22.6k | }; |
110 | | |
111 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTableLocations)] = { |
112 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity), |
113 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_GetTableLocations.Instantiate(entity) |
114 | 22.6k | }; |
115 | | |
116 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)] = { |
117 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity), |
118 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_GetTransactionStatusTablets.Instantiate(entity) |
119 | 22.6k | }; |
120 | | |
121 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kReservePgsqlOids)] = { |
122 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity), |
123 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_ReservePgsqlOids.Instantiate(entity) |
124 | 22.6k | }; |
125 | | |
126 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)] = { |
127 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity), |
128 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_GetYsqlCatalogConfig.Instantiate(entity) |
129 | 22.6k | }; |
130 | | |
131 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kRedisConfigSet)] = { |
132 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity), |
133 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_RedisConfigSet.Instantiate(entity) |
134 | 22.6k | }; |
135 | | |
136 | 22.6k | result->value[to_underlying(MasterClientRpcMethodIndexes::kRedisConfigGet)] = { |
137 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity), |
138 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterClient_RedisConfigGet.Instantiate(entity) |
139 | 22.6k | }; |
140 | | |
141 | 22.6k | return result; |
142 | 22.6k | } |
143 | | |
144 | | |
145 | | } // namespace |
146 | | |
147 | | MasterClientProxy::MasterClientProxy( |
148 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
149 | | const ::yb::rpc::Protocol* protocol, |
150 | | const ::yb::MonoDelta& resolve_cache_timeout) |
151 | | : ProxyBase(kFullMasterClientName, &CreateMasterClientMetrics, |
152 | 24.9k | cache, remote, protocol, resolve_cache_timeout) {} |
153 | | |
154 | | ::yb::Status MasterClientProxy::GetTabletLocations( |
155 | 89 | const ::yb::master::GetTabletLocationsRequestPB &req, ::yb::master::GetTabletLocationsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
156 | 89 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTabletLocations"); |
157 | 89 | return proxy().SyncRequest( |
158 | 89 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)), req, resp, controller); |
159 | 89 | } |
160 | | |
161 | | void MasterClientProxy::GetTabletLocationsAsync( |
162 | | const ::yb::master::GetTabletLocationsRequestPB &req, ::yb::master::GetTabletLocationsResponsePB *resp, ::yb::rpc::RpcController *controller, |
163 | 9.10k | ::yb::rpc::ResponseCallback callback) const { |
164 | 9.10k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTabletLocations"); |
165 | 9.10k | proxy().AsyncRequest( |
166 | 9.10k | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTabletLocations)), req, resp, controller, std::move(callback)); |
167 | 9.10k | } |
168 | | |
169 | | ::yb::Status MasterClientProxy::GetTableLocations( |
170 | 17.7k | const ::yb::master::GetTableLocationsRequestPB &req, ::yb::master::GetTableLocationsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
171 | 17.7k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTableLocations"); |
172 | 17.7k | return proxy().SyncRequest( |
173 | 17.7k | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)), req, resp, controller); |
174 | 17.7k | } |
175 | | |
176 | | void MasterClientProxy::GetTableLocationsAsync( |
177 | | const ::yb::master::GetTableLocationsRequestPB &req, ::yb::master::GetTableLocationsResponsePB *resp, ::yb::rpc::RpcController *controller, |
178 | 144k | ::yb::rpc::ResponseCallback callback) const { |
179 | 144k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTableLocations"); |
180 | 144k | proxy().AsyncRequest( |
181 | 144k | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTableLocations)), req, resp, controller, std::move(callback)); |
182 | 144k | } |
183 | | |
184 | | ::yb::Status MasterClientProxy::GetTransactionStatusTablets( |
185 | 0 | const ::yb::master::GetTransactionStatusTabletsRequestPB &req, ::yb::master::GetTransactionStatusTabletsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
186 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTransactionStatusTablets"); |
187 | 0 | return proxy().SyncRequest( |
188 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)), req, resp, controller); |
189 | 0 | } |
190 | | |
191 | | void MasterClientProxy::GetTransactionStatusTabletsAsync( |
192 | | const ::yb::master::GetTransactionStatusTabletsRequestPB &req, ::yb::master::GetTransactionStatusTabletsResponsePB *resp, ::yb::rpc::RpcController *controller, |
193 | 2.01k | ::yb::rpc::ResponseCallback callback) const { |
194 | 2.01k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetTransactionStatusTablets"); |
195 | 2.01k | proxy().AsyncRequest( |
196 | 2.01k | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetTransactionStatusTablets)), req, resp, controller, std::move(callback)); |
197 | 2.01k | } |
198 | | |
199 | | ::yb::Status MasterClientProxy::ReservePgsqlOids( |
200 | 0 | const ::yb::master::ReservePgsqlOidsRequestPB &req, ::yb::master::ReservePgsqlOidsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
201 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ReservePgsqlOids"); |
202 | 0 | return proxy().SyncRequest( |
203 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)), req, resp, controller); |
204 | 0 | } |
205 | | |
206 | | void MasterClientProxy::ReservePgsqlOidsAsync( |
207 | | const ::yb::master::ReservePgsqlOidsRequestPB &req, ::yb::master::ReservePgsqlOidsResponsePB *resp, ::yb::rpc::RpcController *controller, |
208 | 380 | ::yb::rpc::ResponseCallback callback) const { |
209 | 380 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "ReservePgsqlOids"); |
210 | 380 | proxy().AsyncRequest( |
211 | 380 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kReservePgsqlOids)), req, resp, controller, std::move(callback)); |
212 | 380 | } |
213 | | |
214 | | ::yb::Status MasterClientProxy::GetYsqlCatalogConfig( |
215 | 0 | const ::yb::master::GetYsqlCatalogConfigRequestPB &req, ::yb::master::GetYsqlCatalogConfigResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
216 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetYsqlCatalogConfig"); |
217 | 0 | return proxy().SyncRequest( |
218 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)), req, resp, controller); |
219 | 0 | } |
220 | | |
221 | | void MasterClientProxy::GetYsqlCatalogConfigAsync( |
222 | | const ::yb::master::GetYsqlCatalogConfigRequestPB &req, ::yb::master::GetYsqlCatalogConfigResponsePB *resp, ::yb::rpc::RpcController *controller, |
223 | 0 | ::yb::rpc::ResponseCallback callback) const { |
224 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetYsqlCatalogConfig"); |
225 | 0 | proxy().AsyncRequest( |
226 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kGetYsqlCatalogConfig)), req, resp, controller, std::move(callback)); |
227 | 0 | } |
228 | | |
229 | | ::yb::Status MasterClientProxy::RedisConfigSet( |
230 | 0 | const ::yb::master::RedisConfigSetRequestPB &req, ::yb::master::RedisConfigSetResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
231 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigSet"); |
232 | 0 | return proxy().SyncRequest( |
233 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)), req, resp, controller); |
234 | 0 | } |
235 | | |
236 | | void MasterClientProxy::RedisConfigSetAsync( |
237 | | const ::yb::master::RedisConfigSetRequestPB &req, ::yb::master::RedisConfigSetResponsePB *resp, ::yb::rpc::RpcController *controller, |
238 | 0 | ::yb::rpc::ResponseCallback callback) const { |
239 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigSet"); |
240 | 0 | proxy().AsyncRequest( |
241 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigSet)), req, resp, controller, std::move(callback)); |
242 | 0 | } |
243 | | |
244 | | ::yb::Status MasterClientProxy::RedisConfigGet( |
245 | 0 | const ::yb::master::RedisConfigGetRequestPB &req, ::yb::master::RedisConfigGetResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
246 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigGet"); |
247 | 0 | return proxy().SyncRequest( |
248 | 0 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)), req, resp, controller); |
249 | 0 | } |
250 | | |
251 | | void MasterClientProxy::RedisConfigGetAsync( |
252 | | const ::yb::master::RedisConfigGetRequestPB &req, ::yb::master::RedisConfigGetResponsePB *resp, ::yb::rpc::RpcController *controller, |
253 | 291 | ::yb::rpc::ResponseCallback callback) const { |
254 | 291 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "RedisConfigGet"); |
255 | 291 | proxy().AsyncRequest( |
256 | 291 | &method, metrics<7>(static_cast<size_t>(MasterClientRpcMethodIndexes::kRedisConfigGet)), req, resp, controller, std::move(callback)); |
257 | 291 | } |
258 | | |
259 | | } // namespace master |
260 | | } // namespace yb |