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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
/// Eviction evicts a pod from its node subject to certain policies and safety constraints.
/// This is a subresource of Pod. A request to cause such an eviction is
/// created by POSTing to .../pods/<pod name>/evictions.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Eviction {
/// ObjectMeta describes the pod that is being evicted.
/// +optional
#[prost(message, optional, tag="1")]
pub metadata: ::core::option::Option<super::super::super::apimachinery::pkg::apis::meta::v1::ObjectMeta>,
/// DeleteOptions may be provided
/// +optional
#[prost(message, optional, tag="2")]
pub delete_options: ::core::option::Option<super::super::super::apimachinery::pkg::apis::meta::v1::DeleteOptions>,
}
/// PodDisruptionBudget is an object to define the max disruption that can be caused to a collection of pods
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PodDisruptionBudget {
/// Standard object's metadata.
/// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
/// +optional
#[prost(message, optional, tag="1")]
pub metadata: ::core::option::Option<super::super::super::apimachinery::pkg::apis::meta::v1::ObjectMeta>,
/// Specification of the desired behavior of the PodDisruptionBudget.
/// +optional
#[prost(message, optional, tag="2")]
pub spec: ::core::option::Option<PodDisruptionBudgetSpec>,
/// Most recently observed status of the PodDisruptionBudget.
/// +optional
#[prost(message, optional, tag="3")]
pub status: ::core::option::Option<PodDisruptionBudgetStatus>,
}
/// PodDisruptionBudgetList is a collection of PodDisruptionBudgets.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PodDisruptionBudgetList {
/// Standard object's metadata.
/// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
/// +optional
#[prost(message, optional, tag="1")]
pub metadata: ::core::option::Option<super::super::super::apimachinery::pkg::apis::meta::v1::ListMeta>,
/// Items is a list of PodDisruptionBudgets
#[prost(message, repeated, tag="2")]
pub items: ::prost::alloc::vec::Vec<PodDisruptionBudget>,
}
/// PodDisruptionBudgetSpec is a description of a PodDisruptionBudget.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PodDisruptionBudgetSpec {
/// An eviction is allowed if at least "minAvailable" pods selected by
/// "selector" will still be available after the eviction, i.e. even in the
/// absence of the evicted pod. So for example you can prevent all voluntary
/// evictions by specifying "100%".
/// +optional
#[prost(message, optional, tag="1")]
pub min_available: ::core::option::Option<super::super::super::apimachinery::pkg::util::intstr::IntOrString>,
/// Label query over pods whose evictions are managed by the disruption
/// budget.
/// A null selector will match no pods, while an empty ({}) selector will select
/// all pods within the namespace.
/// +patchStrategy=replace
/// +optional
#[prost(message, optional, tag="2")]
pub selector: ::core::option::Option<super::super::super::apimachinery::pkg::apis::meta::v1::LabelSelector>,
/// An eviction is allowed if at most "maxUnavailable" pods selected by
/// "selector" are unavailable after the eviction, i.e. even in absence of
/// the evicted pod. For example, one can prevent all voluntary evictions
/// by specifying 0. This is a mutually exclusive setting with "minAvailable".
/// +optional
#[prost(message, optional, tag="3")]
pub max_unavailable: ::core::option::Option<super::super::super::apimachinery::pkg::util::intstr::IntOrString>,
/// UnhealthyPodEvictionPolicy defines the criteria for when unhealthy pods
/// should be considered for eviction. Current implementation considers healthy pods,
/// as pods that have status.conditions item with type="Ready",status="True".
///
/// Valid policies are IfHealthyBudget and AlwaysAllow.
/// If no policy is specified, the default behavior will be used,
/// which corresponds to the IfHealthyBudget policy.
///
/// IfHealthyBudget policy means that running pods (status.phase="Running"),
/// but not yet healthy can be evicted only if the guarded application is not
/// disrupted (status.currentHealthy is at least equal to status.desiredHealthy).
/// Healthy pods will be subject to the PDB for eviction.
///
/// AlwaysAllow policy means that all running pods (status.phase="Running"),
/// but not yet healthy are considered disrupted and can be evicted regardless
/// of whether the criteria in a PDB is met. This means perspective running
/// pods of a disrupted application might not get a chance to become healthy.
/// Healthy pods will be subject to the PDB for eviction.
///
/// Additional policies may be added in the future.
/// Clients making eviction decisions should disallow eviction of unhealthy pods
/// if they encounter an unrecognized policy in this field.
///
/// This field is beta-level. The eviction API uses this field when
/// the feature gate PDBUnhealthyPodEvictionPolicy is enabled (enabled by default).
/// +optional
#[prost(string, optional, tag="4")]
pub unhealthy_pod_eviction_policy: ::core::option::Option<::prost::alloc::string::String>,
}
/// PodDisruptionBudgetStatus represents information about the status of a
/// PodDisruptionBudget. Status may trail the actual state of a system.
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PodDisruptionBudgetStatus {
/// Most recent generation observed when updating this PDB status. DisruptionsAllowed and other
/// status information is valid only if observedGeneration equals to PDB's object generation.
/// +optional
#[prost(int64, optional, tag="1")]
pub observed_generation: ::core::option::Option<i64>,
/// DisruptedPods contains information about pods whose eviction was
/// processed by the API server eviction subresource handler but has not
/// yet been observed by the PodDisruptionBudget controller.
/// A pod will be in this map from the time when the API server processed the
/// eviction request to the time when the pod is seen by PDB controller
/// as having been marked for deletion (or after a timeout). The key in the map is the name of the pod
/// and the value is the time when the API server processed the eviction request. If
/// the deletion didn't occur and a pod is still there it will be removed from
/// the list automatically by PodDisruptionBudget controller after some time.
/// If everything goes smooth this map should be empty for the most of the time.
/// Large number of entries in the map may indicate problems with pod deletions.
/// +optional
#[prost(map="string, message", tag="2")]
pub disrupted_pods: ::std::collections::HashMap<::prost::alloc::string::String, super::super::super::apimachinery::pkg::apis::meta::v1::Time>,
/// Number of pod disruptions that are currently allowed.
#[prost(int32, optional, tag="3")]
pub disruptions_allowed: ::core::option::Option<i32>,
/// current number of healthy pods
#[prost(int32, optional, tag="4")]
pub current_healthy: ::core::option::Option<i32>,
/// minimum desired number of healthy pods
#[prost(int32, optional, tag="5")]
pub desired_healthy: ::core::option::Option<i32>,
/// total number of pods counted by this disruption budget
#[prost(int32, optional, tag="6")]
pub expected_pods: ::core::option::Option<i32>,
/// Conditions contain conditions for PDB. The disruption controller sets the
/// DisruptionAllowed condition. The following are known values for the reason field
/// (additional reasons could be added in the future):
/// - SyncFailed: The controller encountered an error and wasn't able to compute
/// the number of allowed disruptions. Therefore no disruptions are
/// allowed and the status of the condition will be False.
/// - InsufficientPods: The number of pods are either at or below the number
/// required by the PodDisruptionBudget. No disruptions are
/// allowed and the status of the condition will be False.
/// - SufficientPods: There are more pods than required by the PodDisruptionBudget.
/// The condition will be True, and the number of allowed
/// disruptions are provided by the disruptionsAllowed property.
///
/// +optional
/// +patchMergeKey=type
/// +patchStrategy=merge
/// +listType=map
/// +listMapKey=type
#[prost(message, repeated, tag="7")]
pub conditions: ::prost::alloc::vec::Vec<super::super::super::apimachinery::pkg::apis::meta::v1::Condition>,
}
impl crate::Resource for PodDisruptionBudget {
const API_VERSION: &'static str = "policy/v1";
const GROUP: &'static str = "policy";
const VERSION: &'static str = "v1";
const KIND: &'static str = "PodDisruptionBudget";
const NAME: &'static str = "poddisruptionbudgets";
}
impl crate::HasMetadata for PodDisruptionBudget {
type Metadata = crate::apimachinery::pkg::apis::meta::v1::ObjectMeta;
fn metadata(&self) -> Option<&<Self as crate::HasMetadata>::Metadata> {
self.metadata.as_ref()
}
fn metadata_mut(&mut self) -> Option<&mut <Self as crate::HasMetadata>::Metadata> {
self.metadata.as_mut()
}
}
impl crate::HasSpec for PodDisruptionBudget {
type Spec = crate::api::policy::v1::PodDisruptionBudgetSpec;
fn spec(&self) -> Option<&<Self as crate::HasSpec>::Spec> {
self.spec.as_ref()
}
fn spec_mut(&mut self) -> Option<&mut <Self as crate::HasSpec>::Spec> {
self.spec.as_mut()
}
}
impl crate::HasStatus for PodDisruptionBudget {
type Status = crate::api::policy::v1::PodDisruptionBudgetStatus;
fn status(&self) -> Option<&<Self as crate::HasStatus>::Status> {
self.status.as_ref()
}
fn status_mut(&mut self) -> Option<&mut <Self as crate::HasStatus>::Status> {
self.status.as_mut()
}
}
impl crate::HasConditions for PodDisruptionBudget {
type Condition = crate::apimachinery::pkg::apis::meta::v1::Condition;
fn conditions(&self) -> Option<&[<Self as crate::HasConditions>::Condition]> {
self.status.as_ref().map(|s| s.conditions.as_slice())
}
fn conditions_mut(&mut self) -> Option<&mut Vec<<Self as crate::HasConditions>::Condition>> {
self.status
.as_mut()
.and_then(|s| Some(s.conditions.as_mut()))
}
}