/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/consensus/consensus.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/consensus/consensus.proto |
2 | | |
3 | | #include "yb/consensus/consensus.pb.h" |
4 | | #include "yb/consensus/consensus.service.h" |
5 | | |
6 | | #include <glog/logging.h> |
7 | | |
8 | | #include "yb/rpc/inbound_call.h" |
9 | | #include "yb/rpc/local_call.h" |
10 | | #include "yb/rpc/remote_method.h" |
11 | | #include "yb/rpc/rpc_context.h" |
12 | | #include "yb/rpc/rpc_service.h" |
13 | | #include "yb/rpc/service_if.h" |
14 | | #include "yb/util/metrics.h" |
15 | | |
16 | | METRIC_DEFINE_counter( |
17 | | server, service_request_bytes_yb_consensus_ConsensusService_UpdateConsensus, |
18 | | "Bytes received by yb.consensus.ConsensusService.UpdateConsensus() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.consensus.ConsensusService.UpdateConsensus() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_consensus_ConsensusService_UpdateConsensus, |
24 | | "Bytes sent in response to yb.consensus.ConsensusService.UpdateConsensus() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.consensus.ConsensusService.UpdateConsensus() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_consensus_ConsensusService_UpdateConsensus, |
30 | | "Microseconds spent handling yb.consensus.ConsensusService.UpdateConsensus() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.consensus.ConsensusService.UpdateConsensus() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_consensus_ConsensusService_MultiRaftUpdateConsensus, |
37 | | "Bytes received by yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_consensus_ConsensusService_MultiRaftUpdateConsensus, |
43 | | "Bytes sent in response to yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_consensus_ConsensusService_MultiRaftUpdateConsensus, |
49 | | "Microseconds spent handling yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.consensus.ConsensusService.MultiRaftUpdateConsensus() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, service_request_bytes_yb_consensus_ConsensusService_RequestConsensusVote, |
56 | | "Bytes received by yb.consensus.ConsensusService.RequestConsensusVote() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received by yb.consensus.ConsensusService.RequestConsensusVote() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, service_response_bytes_yb_consensus_ConsensusService_RequestConsensusVote, |
62 | | "Bytes sent in response to yb.consensus.ConsensusService.RequestConsensusVote() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent in response to yb.consensus.ConsensusService.RequestConsensusVote() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_histogram_with_percentiles( |
67 | | server, handler_latency_yb_consensus_ConsensusService_RequestConsensusVote, |
68 | | "Microseconds spent handling yb.consensus.ConsensusService.RequestConsensusVote() RPC requests", |
69 | | yb::MetricUnit::kMicroseconds, |
70 | | "Microseconds spent handling yb.consensus.ConsensusService.RequestConsensusVote() RPC requests", |
71 | | 60000000LU, 2); |
72 | | |
73 | | METRIC_DEFINE_counter( |
74 | | server, service_request_bytes_yb_consensus_ConsensusService_ChangeConfig, |
75 | | "Bytes received by yb.consensus.ConsensusService.ChangeConfig() RPC requests", |
76 | | yb::MetricUnit::kBytes, |
77 | | "Bytes received by yb.consensus.ConsensusService.ChangeConfig() RPC requests"); |
78 | | |
79 | | METRIC_DEFINE_counter( |
80 | | server, service_response_bytes_yb_consensus_ConsensusService_ChangeConfig, |
81 | | "Bytes sent in response to yb.consensus.ConsensusService.ChangeConfig() RPC requests", |
82 | | yb::MetricUnit::kBytes, |
83 | | "Bytes sent in response to yb.consensus.ConsensusService.ChangeConfig() RPC requests"); |
84 | | |
85 | | METRIC_DEFINE_histogram_with_percentiles( |
86 | | server, handler_latency_yb_consensus_ConsensusService_ChangeConfig, |
87 | | "Microseconds spent handling yb.consensus.ConsensusService.ChangeConfig() RPC requests", |
88 | | yb::MetricUnit::kMicroseconds, |
89 | | "Microseconds spent handling yb.consensus.ConsensusService.ChangeConfig() RPC requests", |
90 | | 60000000LU, 2); |
91 | | |
92 | | METRIC_DEFINE_counter( |
93 | | server, service_request_bytes_yb_consensus_ConsensusService_UnsafeChangeConfig, |
94 | | "Bytes received by yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests", |
95 | | yb::MetricUnit::kBytes, |
96 | | "Bytes received by yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests"); |
97 | | |
98 | | METRIC_DEFINE_counter( |
99 | | server, service_response_bytes_yb_consensus_ConsensusService_UnsafeChangeConfig, |
100 | | "Bytes sent in response to yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests", |
101 | | yb::MetricUnit::kBytes, |
102 | | "Bytes sent in response to yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests"); |
103 | | |
104 | | METRIC_DEFINE_histogram_with_percentiles( |
105 | | server, handler_latency_yb_consensus_ConsensusService_UnsafeChangeConfig, |
106 | | "Microseconds spent handling yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests", |
107 | | yb::MetricUnit::kMicroseconds, |
108 | | "Microseconds spent handling yb.consensus.ConsensusService.UnsafeChangeConfig() RPC requests", |
109 | | 60000000LU, 2); |
110 | | |
111 | | METRIC_DEFINE_counter( |
112 | | server, service_request_bytes_yb_consensus_ConsensusService_GetNodeInstance, |
113 | | "Bytes received by yb.consensus.ConsensusService.GetNodeInstance() RPC requests", |
114 | | yb::MetricUnit::kBytes, |
115 | | "Bytes received by yb.consensus.ConsensusService.GetNodeInstance() RPC requests"); |
116 | | |
117 | | METRIC_DEFINE_counter( |
118 | | server, service_response_bytes_yb_consensus_ConsensusService_GetNodeInstance, |
119 | | "Bytes sent in response to yb.consensus.ConsensusService.GetNodeInstance() RPC requests", |
120 | | yb::MetricUnit::kBytes, |
121 | | "Bytes sent in response to yb.consensus.ConsensusService.GetNodeInstance() RPC requests"); |
122 | | |
123 | | METRIC_DEFINE_histogram_with_percentiles( |
124 | | server, handler_latency_yb_consensus_ConsensusService_GetNodeInstance, |
125 | | "Microseconds spent handling yb.consensus.ConsensusService.GetNodeInstance() RPC requests", |
126 | | yb::MetricUnit::kMicroseconds, |
127 | | "Microseconds spent handling yb.consensus.ConsensusService.GetNodeInstance() RPC requests", |
128 | | 60000000LU, 2); |
129 | | |
130 | | METRIC_DEFINE_counter( |
131 | | server, service_request_bytes_yb_consensus_ConsensusService_RunLeaderElection, |
132 | | "Bytes received by yb.consensus.ConsensusService.RunLeaderElection() RPC requests", |
133 | | yb::MetricUnit::kBytes, |
134 | | "Bytes received by yb.consensus.ConsensusService.RunLeaderElection() RPC requests"); |
135 | | |
136 | | METRIC_DEFINE_counter( |
137 | | server, service_response_bytes_yb_consensus_ConsensusService_RunLeaderElection, |
138 | | "Bytes sent in response to yb.consensus.ConsensusService.RunLeaderElection() RPC requests", |
139 | | yb::MetricUnit::kBytes, |
140 | | "Bytes sent in response to yb.consensus.ConsensusService.RunLeaderElection() RPC requests"); |
141 | | |
142 | | METRIC_DEFINE_histogram_with_percentiles( |
143 | | server, handler_latency_yb_consensus_ConsensusService_RunLeaderElection, |
144 | | "Microseconds spent handling yb.consensus.ConsensusService.RunLeaderElection() RPC requests", |
145 | | yb::MetricUnit::kMicroseconds, |
146 | | "Microseconds spent handling yb.consensus.ConsensusService.RunLeaderElection() RPC requests", |
147 | | 60000000LU, 2); |
148 | | |
149 | | METRIC_DEFINE_counter( |
150 | | server, service_request_bytes_yb_consensus_ConsensusService_LeaderElectionLost, |
151 | | "Bytes received by yb.consensus.ConsensusService.LeaderElectionLost() RPC requests", |
152 | | yb::MetricUnit::kBytes, |
153 | | "Bytes received by yb.consensus.ConsensusService.LeaderElectionLost() RPC requests"); |
154 | | |
155 | | METRIC_DEFINE_counter( |
156 | | server, service_response_bytes_yb_consensus_ConsensusService_LeaderElectionLost, |
157 | | "Bytes sent in response to yb.consensus.ConsensusService.LeaderElectionLost() RPC requests", |
158 | | yb::MetricUnit::kBytes, |
159 | | "Bytes sent in response to yb.consensus.ConsensusService.LeaderElectionLost() RPC requests"); |
160 | | |
161 | | METRIC_DEFINE_histogram_with_percentiles( |
162 | | server, handler_latency_yb_consensus_ConsensusService_LeaderElectionLost, |
163 | | "Microseconds spent handling yb.consensus.ConsensusService.LeaderElectionLost() RPC requests", |
164 | | yb::MetricUnit::kMicroseconds, |
165 | | "Microseconds spent handling yb.consensus.ConsensusService.LeaderElectionLost() RPC requests", |
166 | | 60000000LU, 2); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, service_request_bytes_yb_consensus_ConsensusService_LeaderStepDown, |
170 | | "Bytes received by yb.consensus.ConsensusService.LeaderStepDown() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes received by yb.consensus.ConsensusService.LeaderStepDown() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, service_response_bytes_yb_consensus_ConsensusService_LeaderStepDown, |
176 | | "Bytes sent in response to yb.consensus.ConsensusService.LeaderStepDown() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes sent in response to yb.consensus.ConsensusService.LeaderStepDown() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_histogram_with_percentiles( |
181 | | server, handler_latency_yb_consensus_ConsensusService_LeaderStepDown, |
182 | | "Microseconds spent handling yb.consensus.ConsensusService.LeaderStepDown() RPC requests", |
183 | | yb::MetricUnit::kMicroseconds, |
184 | | "Microseconds spent handling yb.consensus.ConsensusService.LeaderStepDown() RPC requests", |
185 | | 60000000LU, 2); |
186 | | |
187 | | METRIC_DEFINE_counter( |
188 | | server, service_request_bytes_yb_consensus_ConsensusService_GetLastOpId, |
189 | | "Bytes received by yb.consensus.ConsensusService.GetLastOpId() RPC requests", |
190 | | yb::MetricUnit::kBytes, |
191 | | "Bytes received by yb.consensus.ConsensusService.GetLastOpId() RPC requests"); |
192 | | |
193 | | METRIC_DEFINE_counter( |
194 | | server, service_response_bytes_yb_consensus_ConsensusService_GetLastOpId, |
195 | | "Bytes sent in response to yb.consensus.ConsensusService.GetLastOpId() RPC requests", |
196 | | yb::MetricUnit::kBytes, |
197 | | "Bytes sent in response to yb.consensus.ConsensusService.GetLastOpId() RPC requests"); |
198 | | |
199 | | METRIC_DEFINE_histogram_with_percentiles( |
200 | | server, handler_latency_yb_consensus_ConsensusService_GetLastOpId, |
201 | | "Microseconds spent handling yb.consensus.ConsensusService.GetLastOpId() RPC requests", |
202 | | yb::MetricUnit::kMicroseconds, |
203 | | "Microseconds spent handling yb.consensus.ConsensusService.GetLastOpId() RPC requests", |
204 | | 60000000LU, 2); |
205 | | |
206 | | METRIC_DEFINE_counter( |
207 | | server, service_request_bytes_yb_consensus_ConsensusService_GetConsensusState, |
208 | | "Bytes received by yb.consensus.ConsensusService.GetConsensusState() RPC requests", |
209 | | yb::MetricUnit::kBytes, |
210 | | "Bytes received by yb.consensus.ConsensusService.GetConsensusState() RPC requests"); |
211 | | |
212 | | METRIC_DEFINE_counter( |
213 | | server, service_response_bytes_yb_consensus_ConsensusService_GetConsensusState, |
214 | | "Bytes sent in response to yb.consensus.ConsensusService.GetConsensusState() RPC requests", |
215 | | yb::MetricUnit::kBytes, |
216 | | "Bytes sent in response to yb.consensus.ConsensusService.GetConsensusState() RPC requests"); |
217 | | |
218 | | METRIC_DEFINE_histogram_with_percentiles( |
219 | | server, handler_latency_yb_consensus_ConsensusService_GetConsensusState, |
220 | | "Microseconds spent handling yb.consensus.ConsensusService.GetConsensusState() RPC requests", |
221 | | yb::MetricUnit::kMicroseconds, |
222 | | "Microseconds spent handling yb.consensus.ConsensusService.GetConsensusState() RPC requests", |
223 | | 60000000LU, 2); |
224 | | |
225 | | METRIC_DEFINE_counter( |
226 | | server, service_request_bytes_yb_consensus_ConsensusService_StartRemoteBootstrap, |
227 | | "Bytes received by yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests", |
228 | | yb::MetricUnit::kBytes, |
229 | | "Bytes received by yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests"); |
230 | | |
231 | | METRIC_DEFINE_counter( |
232 | | server, service_response_bytes_yb_consensus_ConsensusService_StartRemoteBootstrap, |
233 | | "Bytes sent in response to yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests", |
234 | | yb::MetricUnit::kBytes, |
235 | | "Bytes sent in response to yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests"); |
236 | | |
237 | | METRIC_DEFINE_histogram_with_percentiles( |
238 | | server, handler_latency_yb_consensus_ConsensusService_StartRemoteBootstrap, |
239 | | "Microseconds spent handling yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests", |
240 | | yb::MetricUnit::kMicroseconds, |
241 | | "Microseconds spent handling yb.consensus.ConsensusService.StartRemoteBootstrap() RPC requests", |
242 | | 60000000LU, 2); |
243 | | |
244 | | namespace yb { |
245 | | namespace consensus { |
246 | | |
247 | 16.7k | ConsensusServiceIf::ConsensusServiceIf(const scoped_refptr<MetricEntity>& entity) { |
248 | 16.7k | InitMethods(entity); |
249 | 16.7k | } |
250 | | |
251 | 182 | ConsensusServiceIf::~ConsensusServiceIf() { |
252 | 182 | } |
253 | | |
254 | 16.6k | void ConsensusServiceIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
255 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUpdateConsensus)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUpdateConsensus))); |
256 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kMultiRaftUpdateConsensus)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kMultiRaftUpdateConsensus))); |
257 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRequestConsensusVote)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRequestConsensusVote))); |
258 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kChangeConfig)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kChangeConfig))); |
259 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUnsafeChangeConfig)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUnsafeChangeConfig))); |
260 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetNodeInstance)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetNodeInstance))); |
261 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRunLeaderElection)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRunLeaderElection))); |
262 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderElectionLost)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderElectionLost))); |
263 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderStepDown)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderStepDown))); |
264 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetLastOpId)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetLastOpId))); |
265 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetConsensusState)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetConsensusState))); |
266 | 16.6k | map->emplace(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kStartRemoteBootstrap)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kStartRemoteBootstrap))); |
267 | 16.6k | } |
268 | | |
269 | 27.1M | void ConsensusServiceIf::Handle(::yb::rpc::InboundCallPtr call) { |
270 | 27.1M | auto index = call->method_index(); |
271 | 27.1M | methods_[index].handler(std::move(call)); |
272 | 27.1M | } |
273 | | |
274 | 50.3k | std::string ConsensusServiceIf::service_name() const { |
275 | 50.3k | return "yb.consensus.ConsensusService"; |
276 | 50.3k | } |
277 | 0 | std::string ConsensusServiceIf::static_service_name() { |
278 | 0 | return "yb.consensus.ConsensusService"; |
279 | 0 | } |
280 | | |
281 | 16.7k | void ConsensusServiceIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
282 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUpdateConsensus)] = { |
283 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "UpdateConsensus"), |
284 | 25.5M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
285 | 25.5M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUpdateConsensus)].metrics); |
286 | 25.5M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::ConsensusRequestPB, ::yb::consensus::ConsensusResponsePB>>( |
287 | 25.5M | std::move(call), [this](const ::yb::consensus::ConsensusRequestPB* req, ::yb::consensus::ConsensusResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
288 | 25.5M | UpdateConsensus(req, resp, std::move(rpc_context)); |
289 | 25.5M | }); |
290 | 25.5M | }, |
291 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
292 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_UpdateConsensus.Instantiate(entity), |
293 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_UpdateConsensus.Instantiate(entity), |
294 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_UpdateConsensus.Instantiate(entity)) |
295 | 16.7k | }; |
296 | | |
297 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kMultiRaftUpdateConsensus)] = { |
298 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "MultiRaftUpdateConsensus"), |
299 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
300 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kMultiRaftUpdateConsensus)].metrics); |
301 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::MultiRaftConsensusRequestPB, ::yb::consensus::MultiRaftConsensusResponsePB>>( |
302 | 0 | std::move(call), [this](const ::yb::consensus::MultiRaftConsensusRequestPB* req, ::yb::consensus::MultiRaftConsensusResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
303 | 0 | MultiRaftUpdateConsensus(req, resp, std::move(rpc_context)); |
304 | 0 | }); |
305 | 0 | }, |
306 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
307 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_MultiRaftUpdateConsensus.Instantiate(entity), |
308 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_MultiRaftUpdateConsensus.Instantiate(entity), |
309 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_MultiRaftUpdateConsensus.Instantiate(entity)) |
310 | 16.7k | }; |
311 | | |
312 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRequestConsensusVote)] = { |
313 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "RequestConsensusVote"), |
314 | 1.39M | .handler = [this](::yb::rpc::InboundCallPtr call) { |
315 | 1.39M | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRequestConsensusVote)].metrics); |
316 | 1.39M | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::VoteRequestPB, ::yb::consensus::VoteResponsePB>>( |
317 | 1.39M | std::move(call), [this](const ::yb::consensus::VoteRequestPB* req, ::yb::consensus::VoteResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
318 | 1.39M | RequestConsensusVote(req, resp, std::move(rpc_context)); |
319 | 1.39M | }); |
320 | 1.39M | }, |
321 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
322 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_RequestConsensusVote.Instantiate(entity), |
323 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_RequestConsensusVote.Instantiate(entity), |
324 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_RequestConsensusVote.Instantiate(entity)) |
325 | 16.7k | }; |
326 | | |
327 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kChangeConfig)] = { |
328 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "ChangeConfig"), |
329 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
330 | 5.29k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kChangeConfig)].metrics); |
331 | 5.29k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::ChangeConfigRequestPB, ::yb::consensus::ChangeConfigResponsePB>>( |
332 | 5.29k | std::move(call), [this](const ::yb::consensus::ChangeConfigRequestPB* req, ::yb::consensus::ChangeConfigResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
333 | 5.29k | ChangeConfig(req, resp, std::move(rpc_context)); |
334 | 5.29k | }); |
335 | 5.29k | }, |
336 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
337 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_ChangeConfig.Instantiate(entity), |
338 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_ChangeConfig.Instantiate(entity), |
339 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_ChangeConfig.Instantiate(entity)) |
340 | 16.7k | }; |
341 | | |
342 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUnsafeChangeConfig)] = { |
343 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "UnsafeChangeConfig"), |
344 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
345 | 6 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kUnsafeChangeConfig)].metrics); |
346 | 6 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::UnsafeChangeConfigRequestPB, ::yb::consensus::UnsafeChangeConfigResponsePB>>( |
347 | 6 | std::move(call), [this](const ::yb::consensus::UnsafeChangeConfigRequestPB* req, ::yb::consensus::UnsafeChangeConfigResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
348 | 6 | UnsafeChangeConfig(req, resp, std::move(rpc_context)); |
349 | 6 | }); |
350 | 6 | }, |
351 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
352 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_UnsafeChangeConfig.Instantiate(entity), |
353 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_UnsafeChangeConfig.Instantiate(entity), |
354 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_UnsafeChangeConfig.Instantiate(entity)) |
355 | 16.7k | }; |
356 | | |
357 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetNodeInstance)] = { |
358 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "GetNodeInstance"), |
359 | 20.9k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
360 | 20.9k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetNodeInstance)].metrics); |
361 | 20.9k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::GetNodeInstanceRequestPB, ::yb::consensus::GetNodeInstanceResponsePB>>( |
362 | 20.9k | std::move(call), [this](const ::yb::consensus::GetNodeInstanceRequestPB* req, ::yb::consensus::GetNodeInstanceResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
363 | 20.9k | GetNodeInstance(req, resp, std::move(rpc_context)); |
364 | 20.9k | }); |
365 | 20.9k | }, |
366 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
367 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_GetNodeInstance.Instantiate(entity), |
368 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_GetNodeInstance.Instantiate(entity), |
369 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_GetNodeInstance.Instantiate(entity)) |
370 | 16.7k | }; |
371 | | |
372 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRunLeaderElection)] = { |
373 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "RunLeaderElection"), |
374 | 96.2k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
375 | 96.2k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kRunLeaderElection)].metrics); |
376 | 96.2k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::RunLeaderElectionRequestPB, ::yb::consensus::RunLeaderElectionResponsePB>>( |
377 | 96.2k | std::move(call), [this](const ::yb::consensus::RunLeaderElectionRequestPB* req, ::yb::consensus::RunLeaderElectionResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
378 | 96.2k | RunLeaderElection(req, resp, std::move(rpc_context)); |
379 | 96.2k | }); |
380 | 96.2k | }, |
381 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
382 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_RunLeaderElection.Instantiate(entity), |
383 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_RunLeaderElection.Instantiate(entity), |
384 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_RunLeaderElection.Instantiate(entity)) |
385 | 16.7k | }; |
386 | | |
387 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderElectionLost)] = { |
388 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "LeaderElectionLost"), |
389 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
390 | 77 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderElectionLost)].metrics); |
391 | 77 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::LeaderElectionLostRequestPB, ::yb::consensus::LeaderElectionLostResponsePB>>( |
392 | 77 | std::move(call), [this](const ::yb::consensus::LeaderElectionLostRequestPB* req, ::yb::consensus::LeaderElectionLostResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
393 | 77 | LeaderElectionLost(req, resp, std::move(rpc_context)); |
394 | 77 | }); |
395 | 77 | }, |
396 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
397 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_LeaderElectionLost.Instantiate(entity), |
398 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_LeaderElectionLost.Instantiate(entity), |
399 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_LeaderElectionLost.Instantiate(entity)) |
400 | 16.7k | }; |
401 | | |
402 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderStepDown)] = { |
403 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "LeaderStepDown"), |
404 | 54.1k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
405 | 54.1k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kLeaderStepDown)].metrics); |
406 | 54.1k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::LeaderStepDownRequestPB, ::yb::consensus::LeaderStepDownResponsePB>>( |
407 | 54.1k | std::move(call), [this](const ::yb::consensus::LeaderStepDownRequestPB* req, ::yb::consensus::LeaderStepDownResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
408 | 54.1k | LeaderStepDown(req, resp, std::move(rpc_context)); |
409 | 54.1k | }); |
410 | 54.1k | }, |
411 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
412 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_LeaderStepDown.Instantiate(entity), |
413 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_LeaderStepDown.Instantiate(entity), |
414 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_LeaderStepDown.Instantiate(entity)) |
415 | 16.7k | }; |
416 | | |
417 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetLastOpId)] = { |
418 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "GetLastOpId"), |
419 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
420 | 575 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetLastOpId)].metrics); |
421 | 575 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::GetLastOpIdRequestPB, ::yb::consensus::GetLastOpIdResponsePB>>( |
422 | 575 | std::move(call), [this](const ::yb::consensus::GetLastOpIdRequestPB* req, ::yb::consensus::GetLastOpIdResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
423 | 575 | GetLastOpId(req, resp, std::move(rpc_context)); |
424 | 575 | }); |
425 | 575 | }, |
426 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
427 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_GetLastOpId.Instantiate(entity), |
428 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_GetLastOpId.Instantiate(entity), |
429 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_GetLastOpId.Instantiate(entity)) |
430 | 16.7k | }; |
431 | | |
432 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetConsensusState)] = { |
433 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "GetConsensusState"), |
434 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
435 | 4.06k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kGetConsensusState)].metrics); |
436 | 4.06k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::GetConsensusStateRequestPB, ::yb::consensus::GetConsensusStateResponsePB>>( |
437 | 4.06k | std::move(call), [this](const ::yb::consensus::GetConsensusStateRequestPB* req, ::yb::consensus::GetConsensusStateResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
438 | 4.06k | GetConsensusState(req, resp, std::move(rpc_context)); |
439 | 4.06k | }); |
440 | 4.06k | }, |
441 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
442 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_GetConsensusState.Instantiate(entity), |
443 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_GetConsensusState.Instantiate(entity), |
444 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_GetConsensusState.Instantiate(entity)) |
445 | 16.7k | }; |
446 | | |
447 | 16.7k | methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kStartRemoteBootstrap)] = { |
448 | 16.7k | .method = ::yb::rpc::RemoteMethod("yb.consensus.ConsensusService", "StartRemoteBootstrap"), |
449 | 16.7k | .handler = [this](::yb::rpc::InboundCallPtr call) { |
450 | 10.6k | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(ConsensusServiceRpcMethodIndexes::kStartRemoteBootstrap)].metrics); |
451 | 10.6k | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::consensus::StartRemoteBootstrapRequestPB, ::yb::consensus::StartRemoteBootstrapResponsePB>>( |
452 | 10.6k | std::move(call), [this](const ::yb::consensus::StartRemoteBootstrapRequestPB* req, ::yb::consensus::StartRemoteBootstrapResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
453 | 10.6k | StartRemoteBootstrap(req, resp, std::move(rpc_context)); |
454 | 10.6k | }); |
455 | 10.6k | }, |
456 | 16.7k | .metrics = ::yb::rpc::RpcMethodMetrics( |
457 | 16.7k | METRIC_service_request_bytes_yb_consensus_ConsensusService_StartRemoteBootstrap.Instantiate(entity), |
458 | 16.7k | METRIC_service_response_bytes_yb_consensus_ConsensusService_StartRemoteBootstrap.Instantiate(entity), |
459 | 16.7k | METRIC_handler_latency_yb_consensus_ConsensusService_StartRemoteBootstrap.Instantiate(entity)) |
460 | 16.7k | }; |
461 | | |
462 | 16.7k | } |
463 | | |
464 | | } // namespace consensus |
465 | | } // namespace yb |