github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-02 16:29:21 +00:00
Code Issues Projects Releases Wiki Activity

Remove redundant pod helper

Browse Source
This commit is contained in:
Michail Kargakis 2017-02-10 17:55:23 +01:00
parent ce998a9fa7
commit fe137a8123
3 changed files with 3 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
pkg/controller/deployment/util/deployment_util.go
View File

@ -786,31 +786,6 @@ func GetAvailableReplicaCountForReplicaSets(replicaSets []*extensions.ReplicaSet
return totalAvailableReplicas return totalAvailableReplicas
} }
// IsPodAvailable return true if the pod is available.
// TODO: Remove this once we start using replica set status for calculating available pods
// for a deployment.
func IsPodAvailable(pod *v1.Pod, minReadySeconds int32, now time.Time) bool {
if !controller.IsPodActive(pod) {
return false
}
// Check if we've passed minReadySeconds since LastTransitionTime
// If so, this pod is ready
for _, c := range pod.Status.Conditions {
// we only care about pod ready conditions
if c.Type == v1.PodReady && c.Status == v1.ConditionTrue {
glog.V(4).Infof("Comparing pod %s/%s ready condition last transition time %s + minReadySeconds %d with now %s.", pod.Namespace, pod.Name, c.LastTransitionTime.String(), minReadySeconds, now.String())
// 2 cases that this ready condition is valid (passed minReadySeconds, i.e. the pod is available):
// 1. minReadySeconds == 0, or
// 2. LastTransitionTime (is set) + minReadySeconds (>0) < current time
minReadySecondsDuration := time.Duration(minReadySeconds) * time.Second
if minReadySeconds == 0 || !c.LastTransitionTime.IsZero() && c.LastTransitionTime.Add(minReadySecondsDuration).Before(now) {
return true
}
}
}
return false
}
// IsRollingUpdate returns true if the strategy type is a rolling update. // IsRollingUpdate returns true if the strategy type is a rolling update.
func IsRollingUpdate(deployment *extensions.Deployment) bool { func IsRollingUpdate(deployment *extensions.Deployment) bool {
return deployment.Spec.Strategy.Type == extensions.RollingUpdateDeploymentStrategyType return deployment.Spec.Strategy.Type == extensions.RollingUpdateDeploymentStrategyType

2
pkg/kubectl/rolling_updater.go
View File

@ -429,7 +429,7 @@ func (r *RollingUpdater) readyPods(oldRc, newRc *api.ReplicationController, minR
if v1Pod.DeletionTimestamp != nil { if v1Pod.DeletionTimestamp != nil {
continue continue
} }
if !deploymentutil.IsPodAvailable(v1Pod, minReadySeconds, r.nowFn().Time) { if !v1.IsPodAvailable(v1Pod, minReadySeconds, r.nowFn()) {
continue continue
} }
switch controller.Name { switch controller.Name {

4
test/e2e/framework/util.go
View File

@ -3412,7 +3412,7 @@ func WaitForPodsReady(c clientset.Interface, ns, name string, minReadySeconds in
return false, nil return false, nil
} }
for _, pod := range pods.Items { for _, pod := range pods.Items {
if !deploymentutil.IsPodAvailable(&pod, int32(minReadySeconds), time.Now()) { if !v1.IsPodAvailable(&pod, int32(minReadySeconds), metav1.Now()) {
return false, nil return false, nil
} }
} }
@ -3499,7 +3499,7 @@ func logPodsOfDeployment(c clientset.Interface, deployment *extensions.Deploymen
} }
for _, pod := range podList.Items { for _, pod := range podList.Items {
availability := "not available" availability := "not available"
if deploymentutil.IsPodAvailable(&pod, minReadySeconds, time.Now()) { if v1.IsPodAvailable(&pod, minReadySeconds, metav1.Now()) {
availability = "available" availability = "available"
} }
Logf("Pod %s is %s:\n%+v", pod.Name, availability, pod) Logf("Pod %s is %s:\n%+v", pod.Name, availability, pod)