/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/tserver/remote_bootstrap.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/tserver/remote_bootstrap.proto |
2 | | |
3 | | #include "yb/tserver/remote_bootstrap.proxy.h" |
4 | | |
5 | | #include "yb/tserver/remote_bootstrap.service.h" |
6 | | |
7 | | #include "yb/rpc/proxy.h" |
8 | | #include "yb/rpc/outbound_call.h" |
9 | | #include "yb/util/metrics.h" |
10 | | #include "yb/util/net/sockaddr.h" |
11 | | |
12 | | METRIC_DEFINE_counter( |
13 | | server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession, |
14 | | "Bytes sent by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession, |
20 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.BeginRemoteBootstrapSession() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive, |
26 | | "Bytes sent by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive, |
32 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.CheckSessionActive() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_FetchData, |
38 | | "Bytes sent by yb.tserver.RemoteBootstrapService.FetchData() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.tserver.RemoteBootstrapService.FetchData() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_FetchData, |
44 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.FetchData() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession, |
50 | | "Bytes sent by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession, |
56 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.EndRemoteBootstrapSession() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession, |
62 | | "Bytes sent by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession, |
68 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.tserver.RemoteBootstrapService.RemoveSession() RPC requests"); |
71 | | |
72 | | namespace yb { |
73 | | namespace tserver { |
74 | | |
75 | | |
76 | | namespace { |
77 | | |
78 | | const std::string kFullRemoteBootstrapServiceName = "yb.tserver.RemoteBootstrapService"; |
79 | | |
80 | 182 | ::yb::rpc::ProxyMetricsPtr CreateRemoteBootstrapServiceMetrics(const scoped_refptr<MetricEntity>& entity) { |
81 | 182 | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<5>>(); |
82 | 182 | result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)] = { |
83 | 182 | METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity), |
84 | 182 | METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_BeginRemoteBootstrapSession.Instantiate(entity) |
85 | 182 | }; |
86 | | |
87 | 182 | result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)] = { |
88 | 182 | METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity), |
89 | 182 | METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_CheckSessionActive.Instantiate(entity) |
90 | 182 | }; |
91 | | |
92 | 182 | result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)] = { |
93 | 182 | METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity), |
94 | 182 | METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_FetchData.Instantiate(entity) |
95 | 182 | }; |
96 | | |
97 | 182 | result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)] = { |
98 | 182 | METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity), |
99 | 182 | METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_EndRemoteBootstrapSession.Instantiate(entity) |
100 | 182 | }; |
101 | | |
102 | 182 | result->value[to_underlying(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)] = { |
103 | 182 | METRIC_proxy_request_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity), |
104 | 182 | METRIC_proxy_response_bytes_yb_tserver_RemoteBootstrapService_RemoveSession.Instantiate(entity) |
105 | 182 | }; |
106 | | |
107 | 182 | return result; |
108 | 182 | } |
109 | | |
110 | | |
111 | | } // namespace |
112 | | |
113 | | RemoteBootstrapServiceProxy::RemoteBootstrapServiceProxy( |
114 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
115 | | const ::yb::rpc::Protocol* protocol, |
116 | | const ::yb::MonoDelta& resolve_cache_timeout) |
117 | | : ProxyBase(kFullRemoteBootstrapServiceName, &CreateRemoteBootstrapServiceMetrics, |
118 | 1.45k | cache, remote, protocol, resolve_cache_timeout) {} |
119 | | |
120 | | ::yb::Status RemoteBootstrapServiceProxy::BeginRemoteBootstrapSession( |
121 | 1.45k | const ::yb::tserver::BeginRemoteBootstrapSessionRequestPB &req, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
122 | 1.45k | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "BeginRemoteBootstrapSession"); |
123 | 1.45k | return proxy().SyncRequest( |
124 | 1.45k | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)), req, resp, controller); |
125 | 1.45k | } |
126 | | |
127 | | void RemoteBootstrapServiceProxy::BeginRemoteBootstrapSessionAsync( |
128 | | const ::yb::tserver::BeginRemoteBootstrapSessionRequestPB &req, ::yb::tserver::BeginRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller, |
129 | 0 | ::yb::rpc::ResponseCallback callback) const { |
130 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "BeginRemoteBootstrapSession"); |
131 | 0 | proxy().AsyncRequest( |
132 | 0 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kBeginRemoteBootstrapSession)), req, resp, controller, std::move(callback)); |
133 | 0 | } |
134 | | |
135 | | ::yb::Status RemoteBootstrapServiceProxy::CheckSessionActive( |
136 | 2 | const ::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB &req, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
137 | 2 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "CheckSessionActive"); |
138 | 2 | return proxy().SyncRequest( |
139 | 2 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)), req, resp, controller); |
140 | 2 | } |
141 | | |
142 | | void RemoteBootstrapServiceProxy::CheckSessionActiveAsync( |
143 | | const ::yb::tserver::CheckRemoteBootstrapSessionActiveRequestPB &req, ::yb::tserver::CheckRemoteBootstrapSessionActiveResponsePB *resp, ::yb::rpc::RpcController *controller, |
144 | 0 | ::yb::rpc::ResponseCallback callback) const { |
145 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "CheckSessionActive"); |
146 | 0 | proxy().AsyncRequest( |
147 | 0 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kCheckSessionActive)), req, resp, controller, std::move(callback)); |
148 | 0 | } |
149 | | |
150 | | ::yb::Status RemoteBootstrapServiceProxy::FetchData( |
151 | 5.83k | const ::yb::tserver::FetchDataRequestPB &req, ::yb::tserver::FetchDataResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
152 | 5.83k | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "FetchData"); |
153 | 5.83k | return proxy().SyncRequest( |
154 | 5.83k | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)), req, resp, controller); |
155 | 5.83k | } |
156 | | |
157 | | void RemoteBootstrapServiceProxy::FetchDataAsync( |
158 | | const ::yb::tserver::FetchDataRequestPB &req, ::yb::tserver::FetchDataResponsePB *resp, ::yb::rpc::RpcController *controller, |
159 | 0 | ::yb::rpc::ResponseCallback callback) const { |
160 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "FetchData"); |
161 | 0 | proxy().AsyncRequest( |
162 | 0 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kFetchData)), req, resp, controller, std::move(callback)); |
163 | 0 | } |
164 | | |
165 | | ::yb::Status RemoteBootstrapServiceProxy::EndRemoteBootstrapSession( |
166 | 1.00k | const ::yb::tserver::EndRemoteBootstrapSessionRequestPB &req, ::yb::tserver::EndRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
167 | 1.00k | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "EndRemoteBootstrapSession"); |
168 | 1.00k | return proxy().SyncRequest( |
169 | 1.00k | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)), req, resp, controller); |
170 | 1.00k | } |
171 | | |
172 | | void RemoteBootstrapServiceProxy::EndRemoteBootstrapSessionAsync( |
173 | | const ::yb::tserver::EndRemoteBootstrapSessionRequestPB &req, ::yb::tserver::EndRemoteBootstrapSessionResponsePB *resp, ::yb::rpc::RpcController *controller, |
174 | 0 | ::yb::rpc::ResponseCallback callback) const { |
175 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "EndRemoteBootstrapSession"); |
176 | 0 | proxy().AsyncRequest( |
177 | 0 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kEndRemoteBootstrapSession)), req, resp, controller, std::move(callback)); |
178 | 0 | } |
179 | | |
180 | | ::yb::Status RemoteBootstrapServiceProxy::RemoveSession( |
181 | 941 | const ::yb::tserver::RemoveSessionRequestPB &req, ::yb::tserver::RemoveSessionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
182 | 941 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "RemoveSession"); |
183 | 941 | return proxy().SyncRequest( |
184 | 941 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)), req, resp, controller); |
185 | 941 | } |
186 | | |
187 | | void RemoteBootstrapServiceProxy::RemoveSessionAsync( |
188 | | const ::yb::tserver::RemoveSessionRequestPB &req, ::yb::tserver::RemoveSessionResponsePB *resp, ::yb::rpc::RpcController *controller, |
189 | 0 | ::yb::rpc::ResponseCallback callback) const { |
190 | 0 | static ::yb::rpc::RemoteMethod method("yb.tserver.RemoteBootstrapService", "RemoveSession"); |
191 | 0 | proxy().AsyncRequest( |
192 | 0 | &method, metrics<5>(static_cast<size_t>(RemoteBootstrapServiceRpcMethodIndexes::kRemoveSession)), req, resp, controller, std::move(callback)); |
193 | 0 | } |
194 | | |
195 | | } // namespace tserver |
196 | | } // namespace yb |