opensearch_client/common/
bulk_by_scroll_task_status_value.rs

1/*
2 * opensearch-client
3 *
4 * Rust Client for OpenSearch
5 *
6 * The version of the OpenAPI document: 3.1.0
7 * Contact: alberto.paro@gmail.com
8 * Generated by Paro OpenAPI Generator
9 */
10
11use crate::common;
12use serde::{Deserialize, Serialize};
13
14
15
16
17#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
18pub struct BulkByScrollTaskStatusValue {
19    #[serde(rename = "throttled_until_millis")]
20    pub throttled_until_millis: String,  /// The number of requests per second effectively executed during the reindex operation.
21    #[serde(rename = "requests_per_second")]
22    pub requests_per_second: f64,  /// The number of version conflicts encountered by the reindex operation.
23    #[serde(rename = "version_conflicts")]
24    pub version_conflicts: u32,  /// The number of documents that were ignored.
25    #[serde(rename = "noops")]
26    pub noops: u32,
27    #[serde(rename = "throttled_millis")]
28    pub throttled_millis: String,
29    #[serde(rename = "slices", default, skip_serializing_if = "Option::is_none")]
30    pub slices: Option<Vec<common::BulkByScrollTaskStatusOrException>>,  /// The number of documents that were successfully created.
31    #[serde(rename = "created", default, skip_serializing_if = "Option::is_none")]
32    pub created: Option<u32>,
33    #[serde(rename = "canceled", default, skip_serializing_if = "Option::is_none")]
34    pub canceled: Option<String>,  /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
35  /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
36    #[serde(rename = "throttled_until", default, skip_serializing_if = "Option::is_none")]
37    pub throttled_until: Option<String>,  /// The number of scroll responses pulled back by the reindex operation.
38    #[serde(rename = "batches")]
39    pub batches: u32,
40    #[serde(rename = "slice_id", default, skip_serializing_if = "Option::is_none")]
41    pub slice_id: Option<u32>,  /// The number of documents that were successfully processed.
42    #[serde(rename = "total")]
43    pub total: u32,
44    #[serde(rename = "retries")]
45    pub retries: common::Retries,  /// The number of documents that were successfully deleted.
46    #[serde(rename = "deleted")]
47    pub deleted: u32,  /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
48  /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
49    #[serde(rename = "throttled", default, skip_serializing_if = "Option::is_none")]
50    pub throttled: Option<String>,  /// The number of documents that were successfully updated after the reindex operation.
51    #[serde(rename = "updated", default, skip_serializing_if = "Option::is_none")]
52    pub updated: Option<u32>,
53}
54
55impl BulkByScrollTaskStatusValue {
56    
57    pub fn new(throttled_until_millis: String, requests_per_second: f64, version_conflicts: u32, noops: u32, throttled_millis: String, batches: u32, total: u32, retries: common::Retries, deleted: u32) -> BulkByScrollTaskStatusValue {
58        BulkByScrollTaskStatusValue {
59            throttled_until_millis,
60            requests_per_second,
61            version_conflicts,
62            noops,
63            throttled_millis,
64            slices: None,
65            created: None,
66            canceled: None,
67            throttled_until: None,
68            batches,
69            slice_id: None,
70            total,
71            retries,
72            deleted,
73            throttled: None,
74            updated: None,
75        }
76    }
77}
opensearch_client/common/bulk_by_scroll_task_status_value.rs

opensearch_client/common/
bulk_by_scroll_task_status_value.rs
