GPUdb C++ API  Version 7.0.19.0
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
admin_show_cluster_operations.h
Go to the documentation of this file.
1 /*
2  * This file was autogenerated by the GPUdb schema processor.
3  *
4  * DO NOT EDIT DIRECTLY.
5  */
6 #ifndef __ADMIN_SHOW_CLUSTER_OPERATIONS_H__
7 #define __ADMIN_SHOW_CLUSTER_OPERATIONS_H__
8 
9 namespace gpudb
10 {
11 
23  struct AdminShowClusterOperationsRequest
24  {
25 
30  AdminShowClusterOperationsRequest() :
31  historyIndex(int32_t()),
32  options(std::map<std::string, std::string>())
33  {
34  }
35 
45  AdminShowClusterOperationsRequest(const int32_t historyIndex_, const std::map<std::string, std::string>& options_):
46  historyIndex( historyIndex_ ),
47  options( options_ )
48  {
49  }
50 
51  int32_t historyIndex;
52  std::map<std::string, std::string> options;
53  };
54 }
55 
56 namespace avro
57 {
58  template<> struct codec_traits<gpudb::AdminShowClusterOperationsRequest>
59  {
60  static void encode(Encoder& e, const gpudb::AdminShowClusterOperationsRequest& v)
61  {
62  ::avro::encode(e, v.historyIndex);
63  ::avro::encode(e, v.options);
64  }
65 
66  static void decode(Decoder& d, gpudb::AdminShowClusterOperationsRequest& v)
67  {
68  if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
69  {
70  const std::vector<size_t> fo = rd->fieldOrder();
71 
72  for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
73  {
74  switch (*it)
75  {
76  case 0:
77  ::avro::decode(d, v.historyIndex);
78  break;
79 
80  case 1:
81  ::avro::decode(d, v.options);
82  break;
83 
84  default:
85  break;
86  }
87  }
88  }
89  else
90  {
91  ::avro::decode(d, v.historyIndex);
92  ::avro::decode(d, v.options);
93  }
94  }
95  };
96 }
97 
98 namespace gpudb
99 {
100 
112  struct AdminShowClusterOperationsResponse
113  {
114 
119  AdminShowClusterOperationsResponse() :
120  historyIndex(int32_t()),
121  historySize(int32_t()),
122  inProgress(bool()),
123  startTime(std::string()),
124  endTime(std::string()),
125  endpoint(std::string()),
126  endpointSchema(std::string()),
127  overallStatus(std::string()),
128  userStopped(bool()),
129  percentComplete(int32_t()),
130  dryRun(bool()),
131  messages(std::vector<std::string>()),
132  addRanks(bool()),
133  addRanksStatus(std::string()),
134  ranksBeingAdded(std::vector<int32_t>()),
135  rankHosts(std::vector<std::string>()),
136  addRanksPercentComplete(int32_t()),
137  removeRanks(bool()),
138  removeRanksStatus(std::string()),
139  ranksBeingRemoved(std::vector<int32_t>()),
140  removeRanksPercentComplete(int32_t()),
141  rebalance(bool()),
142  rebalanceUnshardedData(bool()),
143  rebalanceUnshardedDataStatus(std::string()),
144  unshardedRebalancePercentComplete(int32_t()),
145  rebalanceShardedData(bool()),
146  shardArrayVersion(int64_t()),
147  rebalanceShardedDataStatus(std::string()),
148  numShardsChanging(int32_t()),
149  shardedRebalancePercentComplete(int32_t()),
150  info(std::map<std::string, std::string>())
151  {
152  }
153 
154  int32_t historyIndex;
155  int32_t historySize;
156  bool inProgress;
157  std::string startTime;
158  std::string endTime;
159  std::string endpoint;
160  std::string endpointSchema;
161  std::string overallStatus;
162  bool userStopped;
163  int32_t percentComplete;
164  bool dryRun;
165  std::vector<std::string> messages;
166  bool addRanks;
167  std::string addRanksStatus;
168  std::vector<int32_t> ranksBeingAdded;
169  std::vector<std::string> rankHosts;
170  int32_t addRanksPercentComplete;
171  bool removeRanks;
172  std::string removeRanksStatus;
173  std::vector<int32_t> ranksBeingRemoved;
174  int32_t removeRanksPercentComplete;
175  bool rebalance;
176  bool rebalanceUnshardedData;
177  std::string rebalanceUnshardedDataStatus;
178  int32_t unshardedRebalancePercentComplete;
179  bool rebalanceShardedData;
180  int64_t shardArrayVersion;
181  std::string rebalanceShardedDataStatus;
182  int32_t numShardsChanging;
183  int32_t shardedRebalancePercentComplete;
184  std::map<std::string, std::string> info;
185  };
186 }
187 
188 namespace avro
189 {
190  template<> struct codec_traits<gpudb::AdminShowClusterOperationsResponse>
191  {
192  static void encode(Encoder& e, const gpudb::AdminShowClusterOperationsResponse& v)
193  {
194  ::avro::encode(e, v.historyIndex);
195  ::avro::encode(e, v.historySize);
196  ::avro::encode(e, v.inProgress);
197  ::avro::encode(e, v.startTime);
198  ::avro::encode(e, v.endTime);
199  ::avro::encode(e, v.endpoint);
200  ::avro::encode(e, v.endpointSchema);
201  ::avro::encode(e, v.overallStatus);
202  ::avro::encode(e, v.userStopped);
203  ::avro::encode(e, v.percentComplete);
204  ::avro::encode(e, v.dryRun);
205  ::avro::encode(e, v.messages);
206  ::avro::encode(e, v.addRanks);
207  ::avro::encode(e, v.addRanksStatus);
208  ::avro::encode(e, v.ranksBeingAdded);
209  ::avro::encode(e, v.rankHosts);
210  ::avro::encode(e, v.addRanksPercentComplete);
211  ::avro::encode(e, v.removeRanks);
212  ::avro::encode(e, v.removeRanksStatus);
213  ::avro::encode(e, v.ranksBeingRemoved);
214  ::avro::encode(e, v.removeRanksPercentComplete);
215  ::avro::encode(e, v.rebalance);
216  ::avro::encode(e, v.rebalanceUnshardedData);
217  ::avro::encode(e, v.rebalanceUnshardedDataStatus);
218  ::avro::encode(e, v.unshardedRebalancePercentComplete);
219  ::avro::encode(e, v.rebalanceShardedData);
220  ::avro::encode(e, v.shardArrayVersion);
221  ::avro::encode(e, v.rebalanceShardedDataStatus);
222  ::avro::encode(e, v.numShardsChanging);
223  ::avro::encode(e, v.shardedRebalancePercentComplete);
224  ::avro::encode(e, v.info);
225  }
226 
227  static void decode(Decoder& d, gpudb::AdminShowClusterOperationsResponse& v)
228  {
229  if (::avro::ResolvingDecoder *rd = dynamic_cast< ::avro::ResolvingDecoder*>(&d))
230  {
231  const std::vector<size_t> fo = rd->fieldOrder();
232 
233  for (std::vector<size_t>::const_iterator it = fo.begin(); it != fo.end(); ++it)
234  {
235  switch (*it)
236  {
237  case 0:
238  ::avro::decode(d, v.historyIndex);
239  break;
240 
241  case 1:
242  ::avro::decode(d, v.historySize);
243  break;
244 
245  case 2:
246  ::avro::decode(d, v.inProgress);
247  break;
248 
249  case 3:
250  ::avro::decode(d, v.startTime);
251  break;
252 
253  case 4:
254  ::avro::decode(d, v.endTime);
255  break;
256 
257  case 5:
258  ::avro::decode(d, v.endpoint);
259  break;
260 
261  case 6:
262  ::avro::decode(d, v.endpointSchema);
263  break;
264 
265  case 7:
266  ::avro::decode(d, v.overallStatus);
267  break;
268 
269  case 8:
270  ::avro::decode(d, v.userStopped);
271  break;
272 
273  case 9:
274  ::avro::decode(d, v.percentComplete);
275  break;
276 
277  case 10:
278  ::avro::decode(d, v.dryRun);
279  break;
280 
281  case 11:
282  ::avro::decode(d, v.messages);
283  break;
284 
285  case 12:
286  ::avro::decode(d, v.addRanks);
287  break;
288 
289  case 13:
290  ::avro::decode(d, v.addRanksStatus);
291  break;
292 
293  case 14:
294  ::avro::decode(d, v.ranksBeingAdded);
295  break;
296 
297  case 15:
298  ::avro::decode(d, v.rankHosts);
299  break;
300 
301  case 16:
302  ::avro::decode(d, v.addRanksPercentComplete);
303  break;
304 
305  case 17:
306  ::avro::decode(d, v.removeRanks);
307  break;
308 
309  case 18:
310  ::avro::decode(d, v.removeRanksStatus);
311  break;
312 
313  case 19:
314  ::avro::decode(d, v.ranksBeingRemoved);
315  break;
316 
317  case 20:
318  ::avro::decode(d, v.removeRanksPercentComplete);
319  break;
320 
321  case 21:
322  ::avro::decode(d, v.rebalance);
323  break;
324 
325  case 22:
326  ::avro::decode(d, v.rebalanceUnshardedData);
327  break;
328 
329  case 23:
330  ::avro::decode(d, v.rebalanceUnshardedDataStatus);
331  break;
332 
333  case 24:
334  ::avro::decode(d, v.unshardedRebalancePercentComplete);
335  break;
336 
337  case 25:
338  ::avro::decode(d, v.rebalanceShardedData);
339  break;
340 
341  case 26:
342  ::avro::decode(d, v.shardArrayVersion);
343  break;
344 
345  case 27:
346  ::avro::decode(d, v.rebalanceShardedDataStatus);
347  break;
348 
349  case 28:
350  ::avro::decode(d, v.numShardsChanging);
351  break;
352 
353  case 29:
354  ::avro::decode(d, v.shardedRebalancePercentComplete);
355  break;
356 
357  case 30:
358  ::avro::decode(d, v.info);
359  break;
360 
361  default:
362  break;
363  }
364  }
365  }
366  else
367  {
368  ::avro::decode(d, v.historyIndex);
369  ::avro::decode(d, v.historySize);
370  ::avro::decode(d, v.inProgress);
371  ::avro::decode(d, v.startTime);
372  ::avro::decode(d, v.endTime);
373  ::avro::decode(d, v.endpoint);
374  ::avro::decode(d, v.endpointSchema);
375  ::avro::decode(d, v.overallStatus);
376  ::avro::decode(d, v.userStopped);
377  ::avro::decode(d, v.percentComplete);
378  ::avro::decode(d, v.dryRun);
379  ::avro::decode(d, v.messages);
380  ::avro::decode(d, v.addRanks);
381  ::avro::decode(d, v.addRanksStatus);
382  ::avro::decode(d, v.ranksBeingAdded);
383  ::avro::decode(d, v.rankHosts);
384  ::avro::decode(d, v.addRanksPercentComplete);
385  ::avro::decode(d, v.removeRanks);
386  ::avro::decode(d, v.removeRanksStatus);
387  ::avro::decode(d, v.ranksBeingRemoved);
388  ::avro::decode(d, v.removeRanksPercentComplete);
389  ::avro::decode(d, v.rebalance);
390  ::avro::decode(d, v.rebalanceUnshardedData);
391  ::avro::decode(d, v.rebalanceUnshardedDataStatus);
392  ::avro::decode(d, v.unshardedRebalancePercentComplete);
393  ::avro::decode(d, v.rebalanceShardedData);
394  ::avro::decode(d, v.shardArrayVersion);
395  ::avro::decode(d, v.rebalanceShardedDataStatus);
396  ::avro::decode(d, v.numShardsChanging);
397  ::avro::decode(d, v.shardedRebalancePercentComplete);
398  ::avro::decode(d, v.info);
399  }
400  }
401  };
402 }
403 
404 #endif
gpudb::AdminShowClusterOperationsRequest::AdminShowClusterOperationsRequest
AdminShowClusterOperationsRequest(const int32_t historyIndex_, const std::map< std::string, std::string > &options_)
Constructs an AdminShowClusterOperationsRequest object with the specified parameters.
Definition: admin_show_cluster_operations.h:45
gpudb::AdminShowClusterOperationsResponse::AdminShowClusterOperationsResponse
AdminShowClusterOperationsResponse()
Constructs an AdminShowClusterOperationsResponse object with default parameter values.
Definition: admin_show_cluster_operations.h:119
gpudb::AdminShowClusterOperationsRequest::AdminShowClusterOperationsRequest
AdminShowClusterOperationsRequest()
Constructs an AdminShowClusterOperationsRequest object with default parameter values.
Definition: admin_show_cluster_operations.h:30
gpudb::AdminShowClusterOperationsRequest::options
std::map< std::string, std::string > options
Definition: admin_show_cluster_operations.h:52