opensearch-client 0.3.1

Strongly typed OpenSearch Client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

/*
 * opensearch-client
 *
 * Rust Client for OpenSearch
 *
 * The version of the OpenAPI document: 3.1.0
 * Contact: alberto.paro@gmail.com
 * Generated by Paro OpenAPI Generator
 */

use crate::common;
use crate::indices;
use serde::{Deserialize, Serialize};

#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
pub struct DataStream {
    #[serde(
        rename = "ilm_policy",
        default,
        skip_serializing_if = "Option::is_none"
    )]
    pub ilm_policy: Option<String>,
    /// Array of objects containing information about the data stream's backing indexes.
    /// The last item in this array contains information about the stream's current write index.
    #[serde(rename = "indices")]
    pub indices: Vec<indices::DataStreamIndex>,
    /// If `true`, the data stream is hidden.
    #[serde(rename = "hidden", default, skip_serializing_if = "Option::is_none")]
    pub hidden: Option<bool>,
    /// Indicates if ILM should take precedence over DSL in case both are configured to managed this data stream.
    #[serde(
        rename = "prefer_ilm",
        default,
        skip_serializing_if = "Option::is_none"
    )]
    pub prefer_ilm: Option<bool>,
    /// Current generation for the data stream. This number acts as a cumulative count of the stream's rollovers, starting at 1.
    #[serde(rename = "generation")]
    pub generation: u32,
    #[serde(rename = "status")]
    pub status: common::HealthStatus,
    #[serde(rename = "_meta", default, skip_serializing_if = "Option::is_none")]
    pub meta: Option<common::Metadata>,
    /// If `true`, the data stream is created and managed by an OpenSearch stack component and cannot be modified through normal user interaction.
    #[serde(rename = "system", default, skip_serializing_if = "Option::is_none")]
    pub system: Option<bool>,
    #[serde(rename = "template")]
    pub template: String,
    #[serde(rename = "timestamp_field")]
    pub timestamp_field: indices::DataStreamTimestampField,
    /// If `true`, the data stream is created and managed by cross-cluster replication and the local cluster can not write into this data stream or change its mappings.
    #[serde(
        rename = "replicated",
        default,
        skip_serializing_if = "Option::is_none"
    )]
    pub replicated: Option<bool>,
    #[serde(rename = "name")]
    pub name: String,
    #[serde(
        rename = "next_generation_managed_by",
        default,
        skip_serializing_if = "Option::is_none"
    )]
    pub next_generation_managed_by: Option<String>,
    /// If `true`, the data stream allows custom routing on write request.
    #[serde(
        rename = "allow_custom_routing",
        default,
        skip_serializing_if = "Option::is_none"
    )]
    pub allow_custom_routing: Option<bool>,
}

impl DataStream {
    pub fn new(
        indices: Vec<indices::DataStreamIndex>,
        generation: u32,
        status: common::HealthStatus,
        template: String,
        timestamp_field: indices::DataStreamTimestampField,
        name: String,
    ) -> DataStream {
        DataStream {
            ilm_policy: None,
            indices,
            hidden: None,
            prefer_ilm: None,
            generation,
            status,
            meta: None,
            system: None,
            template,
            timestamp_field,
            replicated: None,
            name,
            next_generation_managed_by: None,
            allow_custom_routing: None,
        }
    }
}