/Users/deen/code/yugabyte-db/build/debugcov-clang-dynamic-arm64-ninja/src/yb/master/master_backup.service.cc
Line | Count | Source (jump to first uncovered line) |
1 | | // THIS FILE IS AUTOGENERATED FROM yb/master/master_backup.proto |
2 | | |
3 | | #include "yb/master/master_backup.pb.h" |
4 | | #include "yb/master/master_backup.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_master_MasterBackup_CreateSnapshot, |
18 | | "Bytes received by yb.master.MasterBackup.CreateSnapshot() RPC requests", |
19 | | yb::MetricUnit::kBytes, |
20 | | "Bytes received by yb.master.MasterBackup.CreateSnapshot() RPC requests"); |
21 | | |
22 | | METRIC_DEFINE_counter( |
23 | | server, service_response_bytes_yb_master_MasterBackup_CreateSnapshot, |
24 | | "Bytes sent in response to yb.master.MasterBackup.CreateSnapshot() RPC requests", |
25 | | yb::MetricUnit::kBytes, |
26 | | "Bytes sent in response to yb.master.MasterBackup.CreateSnapshot() RPC requests"); |
27 | | |
28 | | METRIC_DEFINE_histogram_with_percentiles( |
29 | | server, handler_latency_yb_master_MasterBackup_CreateSnapshot, |
30 | | "Microseconds spent handling yb.master.MasterBackup.CreateSnapshot() RPC requests", |
31 | | yb::MetricUnit::kMicroseconds, |
32 | | "Microseconds spent handling yb.master.MasterBackup.CreateSnapshot() RPC requests", |
33 | | 60000000LU, 2); |
34 | | |
35 | | METRIC_DEFINE_counter( |
36 | | server, service_request_bytes_yb_master_MasterBackup_ListSnapshots, |
37 | | "Bytes received by yb.master.MasterBackup.ListSnapshots() RPC requests", |
38 | | yb::MetricUnit::kBytes, |
39 | | "Bytes received by yb.master.MasterBackup.ListSnapshots() RPC requests"); |
40 | | |
41 | | METRIC_DEFINE_counter( |
42 | | server, service_response_bytes_yb_master_MasterBackup_ListSnapshots, |
43 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshots() RPC requests", |
44 | | yb::MetricUnit::kBytes, |
45 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshots() RPC requests"); |
46 | | |
47 | | METRIC_DEFINE_histogram_with_percentiles( |
48 | | server, handler_latency_yb_master_MasterBackup_ListSnapshots, |
49 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshots() RPC requests", |
50 | | yb::MetricUnit::kMicroseconds, |
51 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshots() RPC requests", |
52 | | 60000000LU, 2); |
53 | | |
54 | | METRIC_DEFINE_counter( |
55 | | server, service_request_bytes_yb_master_MasterBackup_ListSnapshotRestorations, |
56 | | "Bytes received by yb.master.MasterBackup.ListSnapshotRestorations() RPC requests", |
57 | | yb::MetricUnit::kBytes, |
58 | | "Bytes received by yb.master.MasterBackup.ListSnapshotRestorations() RPC requests"); |
59 | | |
60 | | METRIC_DEFINE_counter( |
61 | | server, service_response_bytes_yb_master_MasterBackup_ListSnapshotRestorations, |
62 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshotRestorations() RPC requests", |
63 | | yb::MetricUnit::kBytes, |
64 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshotRestorations() RPC requests"); |
65 | | |
66 | | METRIC_DEFINE_histogram_with_percentiles( |
67 | | server, handler_latency_yb_master_MasterBackup_ListSnapshotRestorations, |
68 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshotRestorations() RPC requests", |
69 | | yb::MetricUnit::kMicroseconds, |
70 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshotRestorations() RPC requests", |
71 | | 60000000LU, 2); |
72 | | |
73 | | METRIC_DEFINE_counter( |
74 | | server, service_request_bytes_yb_master_MasterBackup_RestoreSnapshot, |
75 | | "Bytes received by yb.master.MasterBackup.RestoreSnapshot() RPC requests", |
76 | | yb::MetricUnit::kBytes, |
77 | | "Bytes received by yb.master.MasterBackup.RestoreSnapshot() RPC requests"); |
78 | | |
79 | | METRIC_DEFINE_counter( |
80 | | server, service_response_bytes_yb_master_MasterBackup_RestoreSnapshot, |
81 | | "Bytes sent in response to yb.master.MasterBackup.RestoreSnapshot() RPC requests", |
82 | | yb::MetricUnit::kBytes, |
83 | | "Bytes sent in response to yb.master.MasterBackup.RestoreSnapshot() RPC requests"); |
84 | | |
85 | | METRIC_DEFINE_histogram_with_percentiles( |
86 | | server, handler_latency_yb_master_MasterBackup_RestoreSnapshot, |
87 | | "Microseconds spent handling yb.master.MasterBackup.RestoreSnapshot() RPC requests", |
88 | | yb::MetricUnit::kMicroseconds, |
89 | | "Microseconds spent handling yb.master.MasterBackup.RestoreSnapshot() RPC requests", |
90 | | 60000000LU, 2); |
91 | | |
92 | | METRIC_DEFINE_counter( |
93 | | server, service_request_bytes_yb_master_MasterBackup_DeleteSnapshot, |
94 | | "Bytes received by yb.master.MasterBackup.DeleteSnapshot() RPC requests", |
95 | | yb::MetricUnit::kBytes, |
96 | | "Bytes received by yb.master.MasterBackup.DeleteSnapshot() RPC requests"); |
97 | | |
98 | | METRIC_DEFINE_counter( |
99 | | server, service_response_bytes_yb_master_MasterBackup_DeleteSnapshot, |
100 | | "Bytes sent in response to yb.master.MasterBackup.DeleteSnapshot() RPC requests", |
101 | | yb::MetricUnit::kBytes, |
102 | | "Bytes sent in response to yb.master.MasterBackup.DeleteSnapshot() RPC requests"); |
103 | | |
104 | | METRIC_DEFINE_histogram_with_percentiles( |
105 | | server, handler_latency_yb_master_MasterBackup_DeleteSnapshot, |
106 | | "Microseconds spent handling yb.master.MasterBackup.DeleteSnapshot() RPC requests", |
107 | | yb::MetricUnit::kMicroseconds, |
108 | | "Microseconds spent handling yb.master.MasterBackup.DeleteSnapshot() RPC requests", |
109 | | 60000000LU, 2); |
110 | | |
111 | | METRIC_DEFINE_counter( |
112 | | server, service_request_bytes_yb_master_MasterBackup_ImportSnapshotMeta, |
113 | | "Bytes received by yb.master.MasterBackup.ImportSnapshotMeta() RPC requests", |
114 | | yb::MetricUnit::kBytes, |
115 | | "Bytes received by yb.master.MasterBackup.ImportSnapshotMeta() RPC requests"); |
116 | | |
117 | | METRIC_DEFINE_counter( |
118 | | server, service_response_bytes_yb_master_MasterBackup_ImportSnapshotMeta, |
119 | | "Bytes sent in response to yb.master.MasterBackup.ImportSnapshotMeta() RPC requests", |
120 | | yb::MetricUnit::kBytes, |
121 | | "Bytes sent in response to yb.master.MasterBackup.ImportSnapshotMeta() RPC requests"); |
122 | | |
123 | | METRIC_DEFINE_histogram_with_percentiles( |
124 | | server, handler_latency_yb_master_MasterBackup_ImportSnapshotMeta, |
125 | | "Microseconds spent handling yb.master.MasterBackup.ImportSnapshotMeta() RPC requests", |
126 | | yb::MetricUnit::kMicroseconds, |
127 | | "Microseconds spent handling yb.master.MasterBackup.ImportSnapshotMeta() RPC requests", |
128 | | 60000000LU, 2); |
129 | | |
130 | | METRIC_DEFINE_counter( |
131 | | server, service_request_bytes_yb_master_MasterBackup_CreateSnapshotSchedule, |
132 | | "Bytes received by yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests", |
133 | | yb::MetricUnit::kBytes, |
134 | | "Bytes received by yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests"); |
135 | | |
136 | | METRIC_DEFINE_counter( |
137 | | server, service_response_bytes_yb_master_MasterBackup_CreateSnapshotSchedule, |
138 | | "Bytes sent in response to yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests", |
139 | | yb::MetricUnit::kBytes, |
140 | | "Bytes sent in response to yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests"); |
141 | | |
142 | | METRIC_DEFINE_histogram_with_percentiles( |
143 | | server, handler_latency_yb_master_MasterBackup_CreateSnapshotSchedule, |
144 | | "Microseconds spent handling yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests", |
145 | | yb::MetricUnit::kMicroseconds, |
146 | | "Microseconds spent handling yb.master.MasterBackup.CreateSnapshotSchedule() RPC requests", |
147 | | 60000000LU, 2); |
148 | | |
149 | | METRIC_DEFINE_counter( |
150 | | server, service_request_bytes_yb_master_MasterBackup_ListSnapshotSchedules, |
151 | | "Bytes received by yb.master.MasterBackup.ListSnapshotSchedules() RPC requests", |
152 | | yb::MetricUnit::kBytes, |
153 | | "Bytes received by yb.master.MasterBackup.ListSnapshotSchedules() RPC requests"); |
154 | | |
155 | | METRIC_DEFINE_counter( |
156 | | server, service_response_bytes_yb_master_MasterBackup_ListSnapshotSchedules, |
157 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshotSchedules() RPC requests", |
158 | | yb::MetricUnit::kBytes, |
159 | | "Bytes sent in response to yb.master.MasterBackup.ListSnapshotSchedules() RPC requests"); |
160 | | |
161 | | METRIC_DEFINE_histogram_with_percentiles( |
162 | | server, handler_latency_yb_master_MasterBackup_ListSnapshotSchedules, |
163 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshotSchedules() RPC requests", |
164 | | yb::MetricUnit::kMicroseconds, |
165 | | "Microseconds spent handling yb.master.MasterBackup.ListSnapshotSchedules() RPC requests", |
166 | | 60000000LU, 2); |
167 | | |
168 | | METRIC_DEFINE_counter( |
169 | | server, service_request_bytes_yb_master_MasterBackup_DeleteSnapshotSchedule, |
170 | | "Bytes received by yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests", |
171 | | yb::MetricUnit::kBytes, |
172 | | "Bytes received by yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests"); |
173 | | |
174 | | METRIC_DEFINE_counter( |
175 | | server, service_response_bytes_yb_master_MasterBackup_DeleteSnapshotSchedule, |
176 | | "Bytes sent in response to yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests", |
177 | | yb::MetricUnit::kBytes, |
178 | | "Bytes sent in response to yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests"); |
179 | | |
180 | | METRIC_DEFINE_histogram_with_percentiles( |
181 | | server, handler_latency_yb_master_MasterBackup_DeleteSnapshotSchedule, |
182 | | "Microseconds spent handling yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests", |
183 | | yb::MetricUnit::kMicroseconds, |
184 | | "Microseconds spent handling yb.master.MasterBackup.DeleteSnapshotSchedule() RPC requests", |
185 | | 60000000LU, 2); |
186 | | |
187 | | namespace yb { |
188 | | namespace master { |
189 | | |
190 | 5.42k | MasterBackupIf::MasterBackupIf(const scoped_refptr<MetricEntity>& entity) { |
191 | 5.42k | InitMethods(entity); |
192 | 5.42k | } |
193 | | |
194 | 87 | MasterBackupIf::~MasterBackupIf() { |
195 | 87 | } |
196 | | |
197 | 5.42k | void MasterBackupIf::FillEndpoints(const ::yb::rpc::RpcServicePtr& service, ::yb::rpc::RpcEndpointMap* map) { |
198 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshot)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshot))); |
199 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshots)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshots))); |
200 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotRestorations)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotRestorations))); |
201 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kRestoreSnapshot)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kRestoreSnapshot))); |
202 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshot)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshot))); |
203 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kImportSnapshotMeta)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kImportSnapshotMeta))); |
204 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshotSchedule)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshotSchedule))); |
205 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotSchedules)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotSchedules))); |
206 | 5.42k | map->emplace(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshotSchedule)].method.serialized_body(), std::make_pair(service, static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshotSchedule))); |
207 | 5.42k | } |
208 | | |
209 | 0 | void MasterBackupIf::Handle(::yb::rpc::InboundCallPtr call) { |
210 | 0 | auto index = call->method_index(); |
211 | 0 | methods_[index].handler(std::move(call)); |
212 | 0 | } |
213 | | |
214 | 16.2k | std::string MasterBackupIf::service_name() const { |
215 | 16.2k | return "yb.master.MasterBackup"; |
216 | 16.2k | } |
217 | 0 | std::string MasterBackupIf::static_service_name() { |
218 | 0 | return "yb.master.MasterBackup"; |
219 | 0 | } |
220 | | |
221 | 5.42k | void MasterBackupIf::InitMethods(const scoped_refptr<MetricEntity>& entity) { |
222 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshot)] = { |
223 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "CreateSnapshot"), |
224 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
225 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshot)].metrics); |
226 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateSnapshotRequestPB, ::yb::master::CreateSnapshotResponsePB>>( |
227 | 0 | std::move(call), [this](const ::yb::master::CreateSnapshotRequestPB* req, ::yb::master::CreateSnapshotResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
228 | 0 | CreateSnapshot(req, resp, std::move(rpc_context)); |
229 | 0 | }); |
230 | 0 | }, |
231 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
232 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_CreateSnapshot.Instantiate(entity), |
233 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_CreateSnapshot.Instantiate(entity), |
234 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_CreateSnapshot.Instantiate(entity)) |
235 | 5.42k | }; |
236 | | |
237 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshots)] = { |
238 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "ListSnapshots"), |
239 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
240 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshots)].metrics); |
241 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListSnapshotsRequestPB, ::yb::master::ListSnapshotsResponsePB>>( |
242 | 0 | std::move(call), [this](const ::yb::master::ListSnapshotsRequestPB* req, ::yb::master::ListSnapshotsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
243 | 0 | ListSnapshots(req, resp, std::move(rpc_context)); |
244 | 0 | }); |
245 | 0 | }, |
246 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
247 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_ListSnapshots.Instantiate(entity), |
248 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_ListSnapshots.Instantiate(entity), |
249 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_ListSnapshots.Instantiate(entity)) |
250 | 5.42k | }; |
251 | | |
252 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotRestorations)] = { |
253 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "ListSnapshotRestorations"), |
254 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
255 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotRestorations)].metrics); |
256 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListSnapshotRestorationsRequestPB, ::yb::master::ListSnapshotRestorationsResponsePB>>( |
257 | 0 | std::move(call), [this](const ::yb::master::ListSnapshotRestorationsRequestPB* req, ::yb::master::ListSnapshotRestorationsResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
258 | 0 | ListSnapshotRestorations(req, resp, std::move(rpc_context)); |
259 | 0 | }); |
260 | 0 | }, |
261 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
262 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_ListSnapshotRestorations.Instantiate(entity), |
263 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_ListSnapshotRestorations.Instantiate(entity), |
264 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_ListSnapshotRestorations.Instantiate(entity)) |
265 | 5.42k | }; |
266 | | |
267 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kRestoreSnapshot)] = { |
268 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "RestoreSnapshot"), |
269 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
270 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kRestoreSnapshot)].metrics); |
271 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::RestoreSnapshotRequestPB, ::yb::master::RestoreSnapshotResponsePB>>( |
272 | 0 | std::move(call), [this](const ::yb::master::RestoreSnapshotRequestPB* req, ::yb::master::RestoreSnapshotResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
273 | 0 | RestoreSnapshot(req, resp, std::move(rpc_context)); |
274 | 0 | }); |
275 | 0 | }, |
276 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
277 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_RestoreSnapshot.Instantiate(entity), |
278 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_RestoreSnapshot.Instantiate(entity), |
279 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_RestoreSnapshot.Instantiate(entity)) |
280 | 5.42k | }; |
281 | | |
282 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshot)] = { |
283 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "DeleteSnapshot"), |
284 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
285 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshot)].metrics); |
286 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteSnapshotRequestPB, ::yb::master::DeleteSnapshotResponsePB>>( |
287 | 0 | std::move(call), [this](const ::yb::master::DeleteSnapshotRequestPB* req, ::yb::master::DeleteSnapshotResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
288 | 0 | DeleteSnapshot(req, resp, std::move(rpc_context)); |
289 | 0 | }); |
290 | 0 | }, |
291 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
292 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_DeleteSnapshot.Instantiate(entity), |
293 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_DeleteSnapshot.Instantiate(entity), |
294 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_DeleteSnapshot.Instantiate(entity)) |
295 | 5.42k | }; |
296 | | |
297 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kImportSnapshotMeta)] = { |
298 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "ImportSnapshotMeta"), |
299 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
300 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kImportSnapshotMeta)].metrics); |
301 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ImportSnapshotMetaRequestPB, ::yb::master::ImportSnapshotMetaResponsePB>>( |
302 | 0 | std::move(call), [this](const ::yb::master::ImportSnapshotMetaRequestPB* req, ::yb::master::ImportSnapshotMetaResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
303 | 0 | ImportSnapshotMeta(req, resp, std::move(rpc_context)); |
304 | 0 | }); |
305 | 0 | }, |
306 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
307 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_ImportSnapshotMeta.Instantiate(entity), |
308 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_ImportSnapshotMeta.Instantiate(entity), |
309 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_ImportSnapshotMeta.Instantiate(entity)) |
310 | 5.42k | }; |
311 | | |
312 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshotSchedule)] = { |
313 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "CreateSnapshotSchedule"), |
314 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
315 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kCreateSnapshotSchedule)].metrics); |
316 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::CreateSnapshotScheduleRequestPB, ::yb::master::CreateSnapshotScheduleResponsePB>>( |
317 | 0 | std::move(call), [this](const ::yb::master::CreateSnapshotScheduleRequestPB* req, ::yb::master::CreateSnapshotScheduleResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
318 | 0 | CreateSnapshotSchedule(req, resp, std::move(rpc_context)); |
319 | 0 | }); |
320 | 0 | }, |
321 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
322 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_CreateSnapshotSchedule.Instantiate(entity), |
323 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_CreateSnapshotSchedule.Instantiate(entity), |
324 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_CreateSnapshotSchedule.Instantiate(entity)) |
325 | 5.42k | }; |
326 | | |
327 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotSchedules)] = { |
328 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "ListSnapshotSchedules"), |
329 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
330 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kListSnapshotSchedules)].metrics); |
331 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::ListSnapshotSchedulesRequestPB, ::yb::master::ListSnapshotSchedulesResponsePB>>( |
332 | 0 | std::move(call), [this](const ::yb::master::ListSnapshotSchedulesRequestPB* req, ::yb::master::ListSnapshotSchedulesResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
333 | 0 | ListSnapshotSchedules(req, resp, std::move(rpc_context)); |
334 | 0 | }); |
335 | 0 | }, |
336 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
337 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_ListSnapshotSchedules.Instantiate(entity), |
338 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_ListSnapshotSchedules.Instantiate(entity), |
339 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_ListSnapshotSchedules.Instantiate(entity)) |
340 | 5.42k | }; |
341 | | |
342 | 5.42k | methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshotSchedule)] = { |
343 | 5.42k | .method = ::yb::rpc::RemoteMethod("yb.master.MasterBackup", "DeleteSnapshotSchedule"), |
344 | 0 | .handler = [this](::yb::rpc::InboundCallPtr call) { |
345 | 0 | call->SetRpcMethodMetrics(methods_[static_cast<size_t>(MasterBackupRpcMethodIndexes::kDeleteSnapshotSchedule)].metrics); |
346 | 0 | ::yb::rpc::HandleCall<::yb::rpc::RpcCallPBParamsImpl<::yb::master::DeleteSnapshotScheduleRequestPB, ::yb::master::DeleteSnapshotScheduleResponsePB>>( |
347 | 0 | std::move(call), [this](const ::yb::master::DeleteSnapshotScheduleRequestPB* req, ::yb::master::DeleteSnapshotScheduleResponsePB* resp, ::yb::rpc::RpcContext rpc_context) { |
348 | 0 | DeleteSnapshotSchedule(req, resp, std::move(rpc_context)); |
349 | 0 | }); |
350 | 0 | }, |
351 | 5.42k | .metrics = ::yb::rpc::RpcMethodMetrics( |
352 | 5.42k | METRIC_service_request_bytes_yb_master_MasterBackup_DeleteSnapshotSchedule.Instantiate(entity), |
353 | 5.42k | METRIC_service_response_bytes_yb_master_MasterBackup_DeleteSnapshotSchedule.Instantiate(entity), |
354 | 5.42k | METRIC_handler_latency_yb_master_MasterBackup_DeleteSnapshotSchedule.Instantiate(entity)) |
355 | 5.42k | }; |
356 | | |
357 | 5.42k | } |
358 | | |
359 | | } // namespace master |
360 | | } // namespace yb |