1// Generated from definition io.k8s.api.apps.v1.RollingUpdateDaemonSet
23/// Spec to control the desired behavior of daemon set rolling update.
4#[derive(Clone, Debug, Default, PartialEq)]
5pub struct RollingUpdateDaemonSet {
6/// The maximum number of nodes with an existing available DaemonSet pod that can have an updated DaemonSet pod during during an update. Value can be an absolute number (ex: 5) or a percentage of desired pods (ex: 10%). This can not be 0 if MaxUnavailable is 0. Absolute number is calculated from percentage by rounding up to a minimum of 1. Default value is 0. Example: when this is set to 30%, at most 30% of the total number of nodes that should be running the daemon pod (i.e. status.desiredNumberScheduled) can have their a new pod created before the old pod is marked as deleted. The update starts by launching new pods on 30% of nodes. Once an updated pod is available (Ready for at least minReadySeconds) the old DaemonSet pod on that node is marked deleted. If the old pod becomes unavailable for any reason (Ready transitions to false, is evicted, or is drained) an updated pod is immediatedly created on that node without considering surge limits. Allowing surge implies the possibility that the resources consumed by the daemonset on any given node can double if the readiness check fails, and so resource intensive daemonsets should take into account that they may cause evictions during disruption.
7pub max_surge: Option<crate::apimachinery::pkg::util::intstr::IntOrString>,
89/// The maximum number of DaemonSet pods that can be unavailable during the update. Value can be an absolute number (ex: 5) or a percentage of total number of DaemonSet pods at the start of the update (ex: 10%). Absolute number is calculated from percentage by rounding up. This cannot be 0 if MaxSurge is 0 Default value is 1. Example: when this is set to 30%, at most 30% of the total number of nodes that should be running the daemon pod (i.e. status.desiredNumberScheduled) can have their pods stopped for an update at any given time. The update starts by stopping at most 30% of those DaemonSet pods and then brings up new DaemonSet pods in their place. Once the new pods are available, it then proceeds onto other DaemonSet pods, thus ensuring that at least 70% of original number of DaemonSet pods are available at all times during the update.
10pub max_unavailable: Option<crate::apimachinery::pkg::util::intstr::IntOrString>,
11}
1213impl crate::DeepMerge for RollingUpdateDaemonSet {
14fn merge_from(&mut self, other: Self) {
15crate::DeepMerge::merge_from(&mut self.max_surge, other.max_surge);
16crate::DeepMerge::merge_from(&mut self.max_unavailable, other.max_unavailable);
17 }
18}
1920impl<'de> crate::serde::Deserialize<'de> for RollingUpdateDaemonSet {
21fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
22#[allow(non_camel_case_types)]
23enum Field {
24 Key_max_surge,
25 Key_max_unavailable,
26 Other,
27 }
2829impl<'de> crate::serde::Deserialize<'de> for Field {
30fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
31struct Visitor;
3233impl crate::serde::de::Visitor<'_> for Visitor {
34type Value = Field;
3536fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
37 f.write_str("field identifier")
38 }
3940fn visit_str<E>(self, v: &str) -> Result<Self::Value, E> where E: crate::serde::de::Error {
41Ok(match v {
42"maxSurge" => Field::Key_max_surge,
43"maxUnavailable" => Field::Key_max_unavailable,
44_ => Field::Other,
45 })
46 }
47 }
4849 deserializer.deserialize_identifier(Visitor)
50 }
51 }
5253struct Visitor;
5455impl<'de> crate::serde::de::Visitor<'de> for Visitor {
56type Value = RollingUpdateDaemonSet;
5758fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
59 f.write_str("RollingUpdateDaemonSet")
60 }
6162fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error> where A: crate::serde::de::MapAccess<'de> {
63let mut value_max_surge: Option<crate::apimachinery::pkg::util::intstr::IntOrString> = None;
64let mut value_max_unavailable: Option<crate::apimachinery::pkg::util::intstr::IntOrString> = None;
6566while let Some(key) = crate::serde::de::MapAccess::next_key::<Field>(&mut map)? {
67match key {
68 Field::Key_max_surge => value_max_surge = crate::serde::de::MapAccess::next_value(&mut map)?,
69 Field::Key_max_unavailable => value_max_unavailable = crate::serde::de::MapAccess::next_value(&mut map)?,
70 Field::Other => { let _: crate::serde::de::IgnoredAny = crate::serde::de::MapAccess::next_value(&mut map)?; },
71 }
72 }
7374Ok(RollingUpdateDaemonSet {
75 max_surge: value_max_surge,
76 max_unavailable: value_max_unavailable,
77 })
78 }
79 }
8081 deserializer.deserialize_struct(
82"RollingUpdateDaemonSet",
83&[
84"maxSurge",
85"maxUnavailable",
86 ],
87 Visitor,
88 )
89 }
90}
9192impl crate::serde::Serialize for RollingUpdateDaemonSet {
93fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where S: crate::serde::Serializer {
94let mut state = serializer.serialize_struct(
95"RollingUpdateDaemonSet",
96self.max_surge.as_ref().map_or(0, |_| 1) +
97self.max_unavailable.as_ref().map_or(0, |_| 1),
98 )?;
99if let Some(value) = &self.max_surge {
100crate::serde::ser::SerializeStruct::serialize_field(&mut state, "maxSurge", value)?;
101 }
102if let Some(value) = &self.max_unavailable {
103crate::serde::ser::SerializeStruct::serialize_field(&mut state, "maxUnavailable", value)?;
104 }
105crate::serde::ser::SerializeStruct::end(state)
106 }
107}
108109#[cfg(feature = "schemars")]
110impl crate::schemars::JsonSchema for RollingUpdateDaemonSet {
111fn schema_name() -> std::string::String {
112"io.k8s.api.apps.v1.RollingUpdateDaemonSet".into()
113 }
114115fn json_schema(__gen: &mut crate::schemars::gen::SchemaGenerator) -> crate::schemars::schema::Schema {
116crate::schemars::schema::Schema::Object(crate::schemars::schema::SchemaObject {
117 metadata: Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
118 description: Some("Spec to control the desired behavior of daemon set rolling update.".into()),
119 ..Default::default()
120 })),
121 instance_type: Some(crate::schemars::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars::schema::InstanceType::Object))),
122 object: Some(std::boxed::Box::new(crate::schemars::schema::ObjectValidation {
123 properties: [
124 (
125"maxSurge".into(),
126 {
127let mut schema_obj = __gen.subschema_for::<crate::apimachinery::pkg::util::intstr::IntOrString>().into_object();
128 schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
129 description: Some("The maximum number of nodes with an existing available DaemonSet pod that can have an updated DaemonSet pod during during an update. Value can be an absolute number (ex: 5) or a percentage of desired pods (ex: 10%). This can not be 0 if MaxUnavailable is 0. Absolute number is calculated from percentage by rounding up to a minimum of 1. Default value is 0. Example: when this is set to 30%, at most 30% of the total number of nodes that should be running the daemon pod (i.e. status.desiredNumberScheduled) can have their a new pod created before the old pod is marked as deleted. The update starts by launching new pods on 30% of nodes. Once an updated pod is available (Ready for at least minReadySeconds) the old DaemonSet pod on that node is marked deleted. If the old pod becomes unavailable for any reason (Ready transitions to false, is evicted, or is drained) an updated pod is immediatedly created on that node without considering surge limits. Allowing surge implies the possibility that the resources consumed by the daemonset on any given node can double if the readiness check fails, and so resource intensive daemonsets should take into account that they may cause evictions during disruption.".into()),
130 ..Default::default()
131 }));
132crate::schemars::schema::Schema::Object(schema_obj)
133 },
134 ),
135 (
136"maxUnavailable".into(),
137 {
138let mut schema_obj = __gen.subschema_for::<crate::apimachinery::pkg::util::intstr::IntOrString>().into_object();
139 schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
140 description: Some("The maximum number of DaemonSet pods that can be unavailable during the update. Value can be an absolute number (ex: 5) or a percentage of total number of DaemonSet pods at the start of the update (ex: 10%). Absolute number is calculated from percentage by rounding up. This cannot be 0 if MaxSurge is 0 Default value is 1. Example: when this is set to 30%, at most 30% of the total number of nodes that should be running the daemon pod (i.e. status.desiredNumberScheduled) can have their pods stopped for an update at any given time. The update starts by stopping at most 30% of those DaemonSet pods and then brings up new DaemonSet pods in their place. Once the new pods are available, it then proceeds onto other DaemonSet pods, thus ensuring that at least 70% of original number of DaemonSet pods are available at all times during the update.".into()),
141 ..Default::default()
142 }));
143crate::schemars::schema::Schema::Object(schema_obj)
144 },
145 ),
146 ].into(),
147 ..Default::default()
148 })),
149 ..Default::default()
150 })
151 }
152}