/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_dcl.proxy.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_dcl.proto |
2 | | |
3 | | #include "yb/master/master_dcl.proxy.h" |
4 | | |
5 | | #include "yb/master/master_dcl.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_MasterDcl_CreateRole, |
14 | | "Bytes sent by yb.master.MasterDcl.CreateRole() RPC requests", |
15 | | yb::MetricUnit::kBytes, |
16 | | "Bytes sent by yb.master.MasterDcl.CreateRole() RPC requests"); |
17 | | |
18 | | METRIC_DEFINE_counter( |
19 | | server, proxy_response_bytes_yb_master_MasterDcl_CreateRole, |
20 | | "Bytes received in response to yb.master.MasterDcl.CreateRole() RPC requests", |
21 | | yb::MetricUnit::kBytes, |
22 | | "Bytes received in response to yb.master.MasterDcl.CreateRole() RPC requests"); |
23 | | |
24 | | METRIC_DEFINE_counter( |
25 | | server, proxy_request_bytes_yb_master_MasterDcl_AlterRole, |
26 | | "Bytes sent by yb.master.MasterDcl.AlterRole() RPC requests", |
27 | | yb::MetricUnit::kBytes, |
28 | | "Bytes sent by yb.master.MasterDcl.AlterRole() RPC requests"); |
29 | | |
30 | | METRIC_DEFINE_counter( |
31 | | server, proxy_response_bytes_yb_master_MasterDcl_AlterRole, |
32 | | "Bytes received in response to yb.master.MasterDcl.AlterRole() RPC requests", |
33 | | yb::MetricUnit::kBytes, |
34 | | "Bytes received in response to yb.master.MasterDcl.AlterRole() RPC requests"); |
35 | | |
36 | | METRIC_DEFINE_counter( |
37 | | server, proxy_request_bytes_yb_master_MasterDcl_DeleteRole, |
38 | | "Bytes sent by yb.master.MasterDcl.DeleteRole() RPC requests", |
39 | | yb::MetricUnit::kBytes, |
40 | | "Bytes sent by yb.master.MasterDcl.DeleteRole() RPC requests"); |
41 | | |
42 | | METRIC_DEFINE_counter( |
43 | | server, proxy_response_bytes_yb_master_MasterDcl_DeleteRole, |
44 | | "Bytes received in response to yb.master.MasterDcl.DeleteRole() RPC requests", |
45 | | yb::MetricUnit::kBytes, |
46 | | "Bytes received in response to yb.master.MasterDcl.DeleteRole() RPC requests"); |
47 | | |
48 | | METRIC_DEFINE_counter( |
49 | | server, proxy_request_bytes_yb_master_MasterDcl_GrantRevokeRole, |
50 | | "Bytes sent by yb.master.MasterDcl.GrantRevokeRole() RPC requests", |
51 | | yb::MetricUnit::kBytes, |
52 | | "Bytes sent by yb.master.MasterDcl.GrantRevokeRole() RPC requests"); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, proxy_response_bytes_yb_master_MasterDcl_GrantRevokeRole, |
56 | | "Bytes received in response to yb.master.MasterDcl.GrantRevokeRole() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received in response to yb.master.MasterDcl.GrantRevokeRole() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, proxy_request_bytes_yb_master_MasterDcl_GrantRevokePermission, |
62 | | "Bytes sent by yb.master.MasterDcl.GrantRevokePermission() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent by yb.master.MasterDcl.GrantRevokePermission() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_counter( |
67 | | server, proxy_response_bytes_yb_master_MasterDcl_GrantRevokePermission, |
68 | | "Bytes received in response to yb.master.MasterDcl.GrantRevokePermission() RPC requests", |
69 | | yb::MetricUnit::kBytes, |
70 | | "Bytes received in response to yb.master.MasterDcl.GrantRevokePermission() RPC requests"); |
71 | | |
72 | | METRIC_DEFINE_counter( |
73 | | server, proxy_request_bytes_yb_master_MasterDcl_GetPermissions, |
74 | | "Bytes sent by yb.master.MasterDcl.GetPermissions() RPC requests", |
75 | | yb::MetricUnit::kBytes, |
76 | | "Bytes sent by yb.master.MasterDcl.GetPermissions() RPC requests"); |
77 | | |
78 | | METRIC_DEFINE_counter( |
79 | | server, proxy_response_bytes_yb_master_MasterDcl_GetPermissions, |
80 | | "Bytes received in response to yb.master.MasterDcl.GetPermissions() RPC requests", |
81 | | yb::MetricUnit::kBytes, |
82 | | "Bytes received in response to yb.master.MasterDcl.GetPermissions() RPC requests"); |
83 | | |
84 | | namespace yb { |
85 | | namespace master { |
86 | | |
87 | | |
88 | | namespace { |
89 | | |
90 | | const std::string kFullMasterDclName = "yb.master.MasterDcl"; |
91 | | |
92 | 22.6k | ::yb::rpc::ProxyMetricsPtr CreateMasterDclMetrics(const scoped_refptr<MetricEntity>& entity) { |
93 | 22.6k | auto result = std::make_shared<::yb::rpc::ProxyMetricsImpl<6>>(); |
94 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kCreateRole)] = { |
95 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_CreateRole.Instantiate(entity), |
96 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_CreateRole.Instantiate(entity) |
97 | 22.6k | }; |
98 | | |
99 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kAlterRole)] = { |
100 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_AlterRole.Instantiate(entity), |
101 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_AlterRole.Instantiate(entity) |
102 | 22.6k | }; |
103 | | |
104 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kDeleteRole)] = { |
105 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_DeleteRole.Instantiate(entity), |
106 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_DeleteRole.Instantiate(entity) |
107 | 22.6k | }; |
108 | | |
109 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kGrantRevokeRole)] = { |
110 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_GrantRevokeRole.Instantiate(entity), |
111 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_GrantRevokeRole.Instantiate(entity) |
112 | 22.6k | }; |
113 | | |
114 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kGrantRevokePermission)] = { |
115 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_GrantRevokePermission.Instantiate(entity), |
116 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_GrantRevokePermission.Instantiate(entity) |
117 | 22.6k | }; |
118 | | |
119 | 22.6k | result->value[to_underlying(MasterDclRpcMethodIndexes::kGetPermissions)] = { |
120 | 22.6k | METRIC_proxy_request_bytes_yb_master_MasterDcl_GetPermissions.Instantiate(entity), |
121 | 22.6k | METRIC_proxy_response_bytes_yb_master_MasterDcl_GetPermissions.Instantiate(entity) |
122 | 22.6k | }; |
123 | | |
124 | 22.6k | return result; |
125 | 22.6k | } |
126 | | |
127 | | |
128 | | } // namespace |
129 | | |
130 | | MasterDclProxy::MasterDclProxy( |
131 | | ::yb::rpc::ProxyCache* cache, const ::yb::HostPort& remote, |
132 | | const ::yb::rpc::Protocol* protocol, |
133 | | const ::yb::MonoDelta& resolve_cache_timeout) |
134 | | : ProxyBase(kFullMasterDclName, &CreateMasterDclMetrics, |
135 | 23.3k | cache, remote, protocol, resolve_cache_timeout) {} |
136 | | |
137 | | ::yb::Status MasterDclProxy::CreateRole( |
138 | 0 | const ::yb::master::CreateRoleRequestPB &req, ::yb::master::CreateRoleResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
139 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateRole"); |
140 | 0 | return proxy().SyncRequest( |
141 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kCreateRole)), req, resp, controller); |
142 | 0 | } |
143 | | |
144 | | void MasterDclProxy::CreateRoleAsync( |
145 | | const ::yb::master::CreateRoleRequestPB &req, ::yb::master::CreateRoleResponsePB *resp, ::yb::rpc::RpcController *controller, |
146 | 757 | ::yb::rpc::ResponseCallback callback) const { |
147 | 757 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "CreateRole"); |
148 | 757 | proxy().AsyncRequest( |
149 | 757 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kCreateRole)), req, resp, controller, std::move(callback)); |
150 | 757 | } |
151 | | |
152 | | ::yb::Status MasterDclProxy::AlterRole( |
153 | 0 | const ::yb::master::AlterRoleRequestPB &req, ::yb::master::AlterRoleResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
154 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AlterRole"); |
155 | 0 | return proxy().SyncRequest( |
156 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kAlterRole)), req, resp, controller); |
157 | 0 | } |
158 | | |
159 | | void MasterDclProxy::AlterRoleAsync( |
160 | | const ::yb::master::AlterRoleRequestPB &req, ::yb::master::AlterRoleResponsePB *resp, ::yb::rpc::RpcController *controller, |
161 | 58 | ::yb::rpc::ResponseCallback callback) const { |
162 | 58 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "AlterRole"); |
163 | 58 | proxy().AsyncRequest( |
164 | 58 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kAlterRole)), req, resp, controller, std::move(callback)); |
165 | 58 | } |
166 | | |
167 | | ::yb::Status MasterDclProxy::DeleteRole( |
168 | 0 | const ::yb::master::DeleteRoleRequestPB &req, ::yb::master::DeleteRoleResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
169 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteRole"); |
170 | 0 | return proxy().SyncRequest( |
171 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kDeleteRole)), req, resp, controller); |
172 | 0 | } |
173 | | |
174 | | void MasterDclProxy::DeleteRoleAsync( |
175 | | const ::yb::master::DeleteRoleRequestPB &req, ::yb::master::DeleteRoleResponsePB *resp, ::yb::rpc::RpcController *controller, |
176 | 730 | ::yb::rpc::ResponseCallback callback) const { |
177 | 730 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "DeleteRole"); |
178 | 730 | proxy().AsyncRequest( |
179 | 730 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kDeleteRole)), req, resp, controller, std::move(callback)); |
180 | 730 | } |
181 | | |
182 | | ::yb::Status MasterDclProxy::GrantRevokeRole( |
183 | 0 | const ::yb::master::GrantRevokeRoleRequestPB &req, ::yb::master::GrantRevokeRoleResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
184 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GrantRevokeRole"); |
185 | 0 | return proxy().SyncRequest( |
186 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokeRole)), req, resp, controller); |
187 | 0 | } |
188 | | |
189 | | void MasterDclProxy::GrantRevokeRoleAsync( |
190 | | const ::yb::master::GrantRevokeRoleRequestPB &req, ::yb::master::GrantRevokeRoleResponsePB *resp, ::yb::rpc::RpcController *controller, |
191 | 52 | ::yb::rpc::ResponseCallback callback) const { |
192 | 52 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GrantRevokeRole"); |
193 | 52 | proxy().AsyncRequest( |
194 | 52 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokeRole)), req, resp, controller, std::move(callback)); |
195 | 52 | } |
196 | | |
197 | | ::yb::Status MasterDclProxy::GrantRevokePermission( |
198 | 0 | const ::yb::master::GrantRevokePermissionRequestPB &req, ::yb::master::GrantRevokePermissionResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
199 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GrantRevokePermission"); |
200 | 0 | return proxy().SyncRequest( |
201 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokePermission)), req, resp, controller); |
202 | 0 | } |
203 | | |
204 | | void MasterDclProxy::GrantRevokePermissionAsync( |
205 | | const ::yb::master::GrantRevokePermissionRequestPB &req, ::yb::master::GrantRevokePermissionResponsePB *resp, ::yb::rpc::RpcController *controller, |
206 | 721 | ::yb::rpc::ResponseCallback callback) const { |
207 | 721 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GrantRevokePermission"); |
208 | 721 | proxy().AsyncRequest( |
209 | 721 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGrantRevokePermission)), req, resp, controller, std::move(callback)); |
210 | 721 | } |
211 | | |
212 | | ::yb::Status MasterDclProxy::GetPermissions( |
213 | 0 | const ::yb::master::GetPermissionsRequestPB &req, ::yb::master::GetPermissionsResponsePB *resp, ::yb::rpc::RpcController *controller) const { |
214 | 0 | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetPermissions"); |
215 | 0 | return proxy().SyncRequest( |
216 | 0 | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGetPermissions)), req, resp, controller); |
217 | 0 | } |
218 | | |
219 | | void MasterDclProxy::GetPermissionsAsync( |
220 | | const ::yb::master::GetPermissionsRequestPB &req, ::yb::master::GetPermissionsResponsePB *resp, ::yb::rpc::RpcController *controller, |
221 | 118k | ::yb::rpc::ResponseCallback callback) const { |
222 | 118k | static ::yb::rpc::RemoteMethod method("yb.master.MasterService", "GetPermissions"); |
223 | 118k | proxy().AsyncRequest( |
224 | 118k | &method, metrics<6>(static_cast<size_t>(MasterDclRpcMethodIndexes::kGetPermissions)), req, resp, controller, std::move(callback)); |
225 | 118k | } |
226 | | |
227 | | } // namespace master |
228 | | } // namespace yb |