k8s_openapi/v1_36/api/apps/v1/
daemon_set_spec.rs

1// Generated from definition io.k8s.api.apps.v1.DaemonSetSpec
2
3/// DaemonSetSpec is the specification of a daemon set.
4#[derive(Clone, Debug, Default, PartialEq)]
5pub struct DaemonSetSpec {
6    /// The minimum number of seconds for which a newly created DaemonSet pod should be ready without any of its container crashing, for it to be considered available. Defaults to 0 (pod will be considered available as soon as it is ready).
7    pub min_ready_seconds: Option<i32>,
8
9    /// The number of old history to retain to allow rollback. This is a pointer to distinguish between explicit zero and not specified. Defaults to 10.
10    pub revision_history_limit: Option<i32>,
11
12    /// A label query over pods that are managed by the daemon set. Must match in order to be controlled. It must match the pod template's labels. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors
13    pub selector: crate::apimachinery::pkg::apis::meta::v1::LabelSelector,
14
15    /// An object that describes the pod that will be created. The DaemonSet will create exactly one copy of this pod on every node that matches the template's node selector (or on every node if no node selector is specified). The only allowed template.spec.restartPolicy value is "Always". More info: https://kubernetes.io/docs/concepts/workloads/controllers/replicationcontroller#pod-template
16    pub template: crate::api::core::v1::PodTemplateSpec,
17
18    /// An update strategy to replace existing DaemonSet pods with new pods.
19    pub update_strategy: Option<crate::api::apps::v1::DaemonSetUpdateStrategy>,
20}
21
22impl crate::DeepMerge for DaemonSetSpec {
23    fn merge_from(&mut self, other: Self) {
24        crate::DeepMerge::merge_from(&mut self.min_ready_seconds, other.min_ready_seconds);
25        crate::DeepMerge::merge_from(&mut self.revision_history_limit, other.revision_history_limit);
26        crate::DeepMerge::merge_from(&mut self.selector, other.selector);
27        crate::DeepMerge::merge_from(&mut self.template, other.template);
28        crate::DeepMerge::merge_from(&mut self.update_strategy, other.update_strategy);
29    }
30}
31
32impl<'de> crate::serde::Deserialize<'de> for DaemonSetSpec {
33    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
34        #[allow(non_camel_case_types)]
35        enum Field {
36            Key_min_ready_seconds,
37            Key_revision_history_limit,
38            Key_selector,
39            Key_template,
40            Key_update_strategy,
41            Other,
42        }
43
44        impl<'de> crate::serde::Deserialize<'de> for Field {
45            fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
46                struct Visitor;
47
48                impl crate::serde::de::Visitor<'_> for Visitor {
49                    type Value = Field;
50
51                    fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
52                        f.write_str("field identifier")
53                    }
54
55                    fn visit_str<E>(self, v: &str) -> Result<Self::Value, E> where E: crate::serde::de::Error {
56                        Ok(match v {
57                            "minReadySeconds" => Field::Key_min_ready_seconds,
58                            "revisionHistoryLimit" => Field::Key_revision_history_limit,
59                            "selector" => Field::Key_selector,
60                            "template" => Field::Key_template,
61                            "updateStrategy" => Field::Key_update_strategy,
62                            _ => Field::Other,
63                        })
64                    }
65                }
66
67                deserializer.deserialize_identifier(Visitor)
68            }
69        }
70
71        struct Visitor;
72
73        impl<'de> crate::serde::de::Visitor<'de> for Visitor {
74            type Value = DaemonSetSpec;
75
76            fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
77                f.write_str("DaemonSetSpec")
78            }
79
80            fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error> where A: crate::serde::de::MapAccess<'de> {
81                let mut value_min_ready_seconds: Option<i32> = None;
82                let mut value_revision_history_limit: Option<i32> = None;
83                let mut value_selector: Option<crate::apimachinery::pkg::apis::meta::v1::LabelSelector> = None;
84                let mut value_template: Option<crate::api::core::v1::PodTemplateSpec> = None;
85                let mut value_update_strategy: Option<crate::api::apps::v1::DaemonSetUpdateStrategy> = None;
86
87                while let Some(key) = crate::serde::de::MapAccess::next_key::<Field>(&mut map)? {
88                    match key {
89                        Field::Key_min_ready_seconds => value_min_ready_seconds = crate::serde::de::MapAccess::next_value(&mut map)?,
90                        Field::Key_revision_history_limit => value_revision_history_limit = crate::serde::de::MapAccess::next_value(&mut map)?,
91                        Field::Key_selector => value_selector = crate::serde::de::MapAccess::next_value(&mut map)?,
92                        Field::Key_template => value_template = crate::serde::de::MapAccess::next_value(&mut map)?,
93                        Field::Key_update_strategy => value_update_strategy = crate::serde::de::MapAccess::next_value(&mut map)?,
94                        Field::Other => { let _: crate::serde::de::IgnoredAny = crate::serde::de::MapAccess::next_value(&mut map)?; },
95                    }
96                }
97
98                Ok(DaemonSetSpec {
99                    min_ready_seconds: value_min_ready_seconds,
100                    revision_history_limit: value_revision_history_limit,
101                    selector: value_selector.unwrap_or_default(),
102                    template: value_template.unwrap_or_default(),
103                    update_strategy: value_update_strategy,
104                })
105            }
106        }
107
108        deserializer.deserialize_struct(
109            "DaemonSetSpec",
110            &[
111                "minReadySeconds",
112                "revisionHistoryLimit",
113                "selector",
114                "template",
115                "updateStrategy",
116            ],
117            Visitor,
118        )
119    }
120}
121
122impl crate::serde::Serialize for DaemonSetSpec {
123    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where S: crate::serde::Serializer {
124        let mut state = serializer.serialize_struct(
125            "DaemonSetSpec",
126            2 +
127            self.min_ready_seconds.as_ref().map_or(0, |_| 1) +
128            self.revision_history_limit.as_ref().map_or(0, |_| 1) +
129            self.update_strategy.as_ref().map_or(0, |_| 1),
130        )?;
131        if let Some(value) = &self.min_ready_seconds {
132            crate::serde::ser::SerializeStruct::serialize_field(&mut state, "minReadySeconds", value)?;
133        }
134        if let Some(value) = &self.revision_history_limit {
135            crate::serde::ser::SerializeStruct::serialize_field(&mut state, "revisionHistoryLimit", value)?;
136        }
137        crate::serde::ser::SerializeStruct::serialize_field(&mut state, "selector", &self.selector)?;
138        crate::serde::ser::SerializeStruct::serialize_field(&mut state, "template", &self.template)?;
139        if let Some(value) = &self.update_strategy {
140            crate::serde::ser::SerializeStruct::serialize_field(&mut state, "updateStrategy", value)?;
141        }
142        crate::serde::ser::SerializeStruct::end(state)
143    }
144}
145
146#[cfg(feature = "schemars")]
147impl crate::schemars::JsonSchema for DaemonSetSpec {
148    fn schema_name() -> std::borrow::Cow<'static, str> {
149        "io.k8s.api.apps.v1.DaemonSetSpec".into()
150    }
151
152    fn json_schema(__gen: &mut crate::schemars::SchemaGenerator) -> crate::schemars::Schema {
153        crate::schemars::json_schema!({
154            "description": "DaemonSetSpec is the specification of a daemon set.",
155            "type": "object",
156            "properties": {
157                "minReadySeconds": {
158                    "description": "The minimum number of seconds for which a newly created DaemonSet pod should be ready without any of its container crashing, for it to be considered available. Defaults to 0 (pod will be considered available as soon as it is ready).",
159                    "type": "integer",
160                    "format": "int32",
161                },
162                "revisionHistoryLimit": {
163                    "description": "The number of old history to retain to allow rollback. This is a pointer to distinguish between explicit zero and not specified. Defaults to 10.",
164                    "type": "integer",
165                    "format": "int32",
166                },
167                "selector": ({
168                    let mut schema_obj = __gen.subschema_for::<crate::apimachinery::pkg::apis::meta::v1::LabelSelector>();
169                    schema_obj.ensure_object().insert("description".into(), "A label query over pods that are managed by the daemon set. Must match in order to be controlled. It must match the pod template's labels. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors".into());
170                    schema_obj
171                }),
172                "template": ({
173                    let mut schema_obj = __gen.subschema_for::<crate::api::core::v1::PodTemplateSpec>();
174                    schema_obj.ensure_object().insert("description".into(), "An object that describes the pod that will be created. The DaemonSet will create exactly one copy of this pod on every node that matches the template's node selector (or on every node if no node selector is specified). The only allowed template.spec.restartPolicy value is \"Always\". More info: https://kubernetes.io/docs/concepts/workloads/controllers/replicationcontroller#pod-template".into());
175                    schema_obj
176                }),
177                "updateStrategy": ({
178                    let mut schema_obj = __gen.subschema_for::<crate::api::apps::v1::DaemonSetUpdateStrategy>();
179                    schema_obj.ensure_object().insert("description".into(), "An update strategy to replace existing DaemonSet pods with new pods.".into());
180                    schema_obj
181                }),
182            },
183            "required": [
184                "selector",
185                "template",
186            ],
187        })
188    }
189}
190
191#[cfg(feature = "schemars08")]
192impl crate::schemars08::JsonSchema for DaemonSetSpec {
193    fn schema_name() -> std::string::String {
194        "io.k8s.api.apps.v1.DaemonSetSpec".into()
195    }
196
197    fn json_schema(__gen: &mut crate::schemars08::gen::SchemaGenerator) -> crate::schemars08::schema::Schema {
198        crate::schemars08::schema::Schema::Object(crate::schemars08::schema::SchemaObject {
199            metadata: Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
200                description: Some("DaemonSetSpec is the specification of a daemon set.".into()),
201                ..Default::default()
202            })),
203            instance_type: Some(crate::schemars08::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars08::schema::InstanceType::Object))),
204            object: Some(std::boxed::Box::new(crate::schemars08::schema::ObjectValidation {
205                properties: [
206                    (
207                        "minReadySeconds".into(),
208                        crate::schemars08::schema::Schema::Object(crate::schemars08::schema::SchemaObject {
209                            metadata: Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
210                                description: Some("The minimum number of seconds for which a newly created DaemonSet pod should be ready without any of its container crashing, for it to be considered available. Defaults to 0 (pod will be considered available as soon as it is ready).".into()),
211                                ..Default::default()
212                            })),
213                            instance_type: Some(crate::schemars08::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars08::schema::InstanceType::Integer))),
214                            format: Some("int32".into()),
215                            ..Default::default()
216                        }),
217                    ),
218                    (
219                        "revisionHistoryLimit".into(),
220                        crate::schemars08::schema::Schema::Object(crate::schemars08::schema::SchemaObject {
221                            metadata: Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
222                                description: Some("The number of old history to retain to allow rollback. This is a pointer to distinguish between explicit zero and not specified. Defaults to 10.".into()),
223                                ..Default::default()
224                            })),
225                            instance_type: Some(crate::schemars08::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars08::schema::InstanceType::Integer))),
226                            format: Some("int32".into()),
227                            ..Default::default()
228                        }),
229                    ),
230                    (
231                        "selector".into(),
232                        {
233                            let mut schema_obj = __gen.subschema_for::<crate::apimachinery::pkg::apis::meta::v1::LabelSelector>().into_object();
234                            schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
235                                description: Some("A label query over pods that are managed by the daemon set. Must match in order to be controlled. It must match the pod template's labels. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors".into()),
236                                ..Default::default()
237                            }));
238                            crate::schemars08::schema::Schema::Object(schema_obj)
239                        },
240                    ),
241                    (
242                        "template".into(),
243                        {
244                            let mut schema_obj = __gen.subschema_for::<crate::api::core::v1::PodTemplateSpec>().into_object();
245                            schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
246                                description: Some("An object that describes the pod that will be created. The DaemonSet will create exactly one copy of this pod on every node that matches the template's node selector (or on every node if no node selector is specified). The only allowed template.spec.restartPolicy value is \"Always\". More info: https://kubernetes.io/docs/concepts/workloads/controllers/replicationcontroller#pod-template".into()),
247                                ..Default::default()
248                            }));
249                            crate::schemars08::schema::Schema::Object(schema_obj)
250                        },
251                    ),
252                    (
253                        "updateStrategy".into(),
254                        {
255                            let mut schema_obj = __gen.subschema_for::<crate::api::apps::v1::DaemonSetUpdateStrategy>().into_object();
256                            schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars08::schema::Metadata {
257                                description: Some("An update strategy to replace existing DaemonSet pods with new pods.".into()),
258                                ..Default::default()
259                            }));
260                            crate::schemars08::schema::Schema::Object(schema_obj)
261                        },
262                    ),
263                ].into(),
264                required: [
265                    "selector".into(),
266                    "template".into(),
267                ].into(),
268                ..Default::default()
269            })),
270            ..Default::default()
271        })
272    }
273}
k8s_openapi/v1_36/api/apps/v1/daemon_set_spec.rs

k8s_openapi/v1_36/api/apps/v1/
daemon_set_spec.rs
