1// Generated from definition io.k8s.api.batch.v1.PodFailurePolicyRule
23/// PodFailurePolicyRule describes how a pod failure is handled when the requirements are met. One of onExitCodes and onPodConditions, but not both, can be used in each rule.
4#[derive(Clone, Debug, Default, PartialEq)]
5pub struct PodFailurePolicyRule {
6/// Specifies the action taken on a pod failure when the requirements are satisfied. Possible values are:
7 ///
8 /// - FailJob: indicates that the pod's job is marked as Failed and all
9 /// running pods are terminated.
10 /// - FailIndex: indicates that the pod's index is marked as Failed and will
11 /// not be restarted.
12 /// - Ignore: indicates that the counter towards the .backoffLimit is not
13 /// incremented and a replacement pod is created.
14 /// - Count: indicates that the pod is handled in the default way - the
15 /// counter towards the .backoffLimit is incremented.
16 /// Additional values are considered to be added in the future. Clients should react to an unknown action by skipping the rule.
17pub action: std::string::String,
1819/// Represents the requirement on the container exit codes.
20pub on_exit_codes: Option<crate::api::batch::v1::PodFailurePolicyOnExitCodesRequirement>,
2122/// Represents the requirement on the pod conditions. The requirement is represented as a list of pod condition patterns. The requirement is satisfied if at least one pattern matches an actual pod condition. At most 20 elements are allowed.
23pub on_pod_conditions: Option<std::vec::Vec<crate::api::batch::v1::PodFailurePolicyOnPodConditionsPattern>>,
24}
2526impl crate::DeepMerge for PodFailurePolicyRule {
27fn merge_from(&mut self, other: Self) {
28crate::DeepMerge::merge_from(&mut self.action, other.action);
29crate::DeepMerge::merge_from(&mut self.on_exit_codes, other.on_exit_codes);
30crate::merge_strategies::list::atomic(&mut self.on_pod_conditions, other.on_pod_conditions);
31 }
32}
3334impl<'de> crate::serde::Deserialize<'de> for PodFailurePolicyRule {
35fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
36#[allow(non_camel_case_types)]
37enum Field {
38 Key_action,
39 Key_on_exit_codes,
40 Key_on_pod_conditions,
41 Other,
42 }
4344impl<'de> crate::serde::Deserialize<'de> for Field {
45fn deserialize<D>(deserializer: D) -> Result<Self, D::Error> where D: crate::serde::Deserializer<'de> {
46struct Visitor;
4748impl crate::serde::de::Visitor<'_> for Visitor {
49type Value = Field;
5051fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
52 f.write_str("field identifier")
53 }
5455fn visit_str<E>(self, v: &str) -> Result<Self::Value, E> where E: crate::serde::de::Error {
56Ok(match v {
57"action" => Field::Key_action,
58"onExitCodes" => Field::Key_on_exit_codes,
59"onPodConditions" => Field::Key_on_pod_conditions,
60_ => Field::Other,
61 })
62 }
63 }
6465 deserializer.deserialize_identifier(Visitor)
66 }
67 }
6869struct Visitor;
7071impl<'de> crate::serde::de::Visitor<'de> for Visitor {
72type Value = PodFailurePolicyRule;
7374fn expecting(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
75 f.write_str("PodFailurePolicyRule")
76 }
7778fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error> where A: crate::serde::de::MapAccess<'de> {
79let mut value_action: Option<std::string::String> = None;
80let mut value_on_exit_codes: Option<crate::api::batch::v1::PodFailurePolicyOnExitCodesRequirement> = None;
81let mut value_on_pod_conditions: Option<std::vec::Vec<crate::api::batch::v1::PodFailurePolicyOnPodConditionsPattern>> = None;
8283while let Some(key) = crate::serde::de::MapAccess::next_key::<Field>(&mut map)? {
84match key {
85 Field::Key_action => value_action = crate::serde::de::MapAccess::next_value(&mut map)?,
86 Field::Key_on_exit_codes => value_on_exit_codes = crate::serde::de::MapAccess::next_value(&mut map)?,
87 Field::Key_on_pod_conditions => value_on_pod_conditions = crate::serde::de::MapAccess::next_value(&mut map)?,
88 Field::Other => { let _: crate::serde::de::IgnoredAny = crate::serde::de::MapAccess::next_value(&mut map)?; },
89 }
90 }
9192Ok(PodFailurePolicyRule {
93 action: value_action.unwrap_or_default(),
94 on_exit_codes: value_on_exit_codes,
95 on_pod_conditions: value_on_pod_conditions,
96 })
97 }
98 }
99100 deserializer.deserialize_struct(
101"PodFailurePolicyRule",
102&[
103"action",
104"onExitCodes",
105"onPodConditions",
106 ],
107 Visitor,
108 )
109 }
110}
111112impl crate::serde::Serialize for PodFailurePolicyRule {
113fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where S: crate::serde::Serializer {
114let mut state = serializer.serialize_struct(
115"PodFailurePolicyRule",
1161 +
117self.on_exit_codes.as_ref().map_or(0, |_| 1) +
118self.on_pod_conditions.as_ref().map_or(0, |_| 1),
119 )?;
120crate::serde::ser::SerializeStruct::serialize_field(&mut state, "action", &self.action)?;
121if let Some(value) = &self.on_exit_codes {
122crate::serde::ser::SerializeStruct::serialize_field(&mut state, "onExitCodes", value)?;
123 }
124if let Some(value) = &self.on_pod_conditions {
125crate::serde::ser::SerializeStruct::serialize_field(&mut state, "onPodConditions", value)?;
126 }
127crate::serde::ser::SerializeStruct::end(state)
128 }
129}
130131#[cfg(feature = "schemars")]
132impl crate::schemars::JsonSchema for PodFailurePolicyRule {
133fn schema_name() -> std::string::String {
134"io.k8s.api.batch.v1.PodFailurePolicyRule".into()
135 }
136137fn json_schema(__gen: &mut crate::schemars::gen::SchemaGenerator) -> crate::schemars::schema::Schema {
138crate::schemars::schema::Schema::Object(crate::schemars::schema::SchemaObject {
139 metadata: Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
140 description: Some("PodFailurePolicyRule describes how a pod failure is handled when the requirements are met. One of onExitCodes and onPodConditions, but not both, can be used in each rule.".into()),
141 ..Default::default()
142 })),
143 instance_type: Some(crate::schemars::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars::schema::InstanceType::Object))),
144 object: Some(std::boxed::Box::new(crate::schemars::schema::ObjectValidation {
145 properties: [
146 (
147"action".into(),
148crate::schemars::schema::Schema::Object(crate::schemars::schema::SchemaObject {
149 metadata: Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
150 description: Some("Specifies the action taken on a pod failure when the requirements are satisfied. Possible values are:\n\n- FailJob: indicates that the pod's job is marked as Failed and all\n running pods are terminated.\n- FailIndex: indicates that the pod's index is marked as Failed and will\n not be restarted.\n- Ignore: indicates that the counter towards the .backoffLimit is not\n incremented and a replacement pod is created.\n- Count: indicates that the pod is handled in the default way - the\n counter towards the .backoffLimit is incremented.\nAdditional values are considered to be added in the future. Clients should react to an unknown action by skipping the rule.".into()),
151 ..Default::default()
152 })),
153 instance_type: Some(crate::schemars::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars::schema::InstanceType::String))),
154 ..Default::default()
155 }),
156 ),
157 (
158"onExitCodes".into(),
159 {
160let mut schema_obj = __gen.subschema_for::<crate::api::batch::v1::PodFailurePolicyOnExitCodesRequirement>().into_object();
161 schema_obj.metadata = Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
162 description: Some("Represents the requirement on the container exit codes.".into()),
163 ..Default::default()
164 }));
165crate::schemars::schema::Schema::Object(schema_obj)
166 },
167 ),
168 (
169"onPodConditions".into(),
170crate::schemars::schema::Schema::Object(crate::schemars::schema::SchemaObject {
171 metadata: Some(std::boxed::Box::new(crate::schemars::schema::Metadata {
172 description: Some("Represents the requirement on the pod conditions. The requirement is represented as a list of pod condition patterns. The requirement is satisfied if at least one pattern matches an actual pod condition. At most 20 elements are allowed.".into()),
173 ..Default::default()
174 })),
175 instance_type: Some(crate::schemars::schema::SingleOrVec::Single(std::boxed::Box::new(crate::schemars::schema::InstanceType::Array))),
176 array: Some(std::boxed::Box::new(crate::schemars::schema::ArrayValidation {
177 items: Some(crate::schemars::schema::SingleOrVec::Single(std::boxed::Box::new(__gen.subschema_for::<crate::api::batch::v1::PodFailurePolicyOnPodConditionsPattern>()))),
178 ..Default::default()
179 })),
180 ..Default::default()
181 }),
182 ),
183 ].into(),
184 required: [
185"action".into(),
186 ].into(),
187 ..Default::default()
188 })),
189 ..Default::default()
190 })
191 }
192}