-
Notifications
You must be signed in to change notification settings - Fork 366
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[DEVOPS-635] Refactor waiting for resources to be ready
- Loading branch information
Julio Chana
committed
Dec 26, 2017
1 parent
da955e4
commit 11d12b2
Showing
2 changed files
with
176 additions
and
85 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,142 @@ | ||
| package failover | ||
|
|
||
| import ( | ||
| "github.com/spotahome/redis-operator/pkg/log" | ||
|
|
||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "k8s.io/client-go/pkg/api/v1" | ||
| ) | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForPod(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for pod to be ready") | ||
| pod, _ := r.Client.CoreV1().Pods(namespace).Get(name, metav1.GetOptions{}) | ||
| for _, condition := range pod.Status.Conditions { | ||
| if condition.Type == "Ready" && condition.Status == v1.ConditionTrue { | ||
| return | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForService(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for service to find bootstrap pod") | ||
| endpoints, _ := r.Client.CoreV1().Endpoints(namespace).Get(name, metav1.GetOptions{}) | ||
| addresses := 0 | ||
| for _, subset := range endpoints.Subsets { | ||
| addresses += len(subset.Addresses) | ||
| } | ||
| if addresses > 0 { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForDeployment(name string, namespace string, replicas int32, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for Sentinel deployment to be fully operative") | ||
| deployment, _ := r.Client.AppsV1beta1().Deployments(namespace).Get(name, metav1.GetOptions{}) | ||
| if deployment.Status.ReadyReplicas == replicas { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForStatefulset(name string, namespace string, replicas int32, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for Redis statefulset to be fully operative") | ||
| statefulset, _ := r.Client.AppsV1beta1().StatefulSets(namespace).Get(name, metav1.GetOptions{}) | ||
| if statefulset.Status.ReadyReplicas == replicas { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForPodDeletion(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for pod to terminate") | ||
| podList, _ := r.Client.CoreV1().Pods(namespace).List(metav1.ListOptions{}) | ||
| found := false | ||
| for _, pod := range podList.Items { | ||
| if pod.Name == name { | ||
| found = true | ||
| } | ||
| } | ||
| if !found { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForStatefulsetDeletion(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for statefulset to terminate") | ||
| statefulsetList, _ := r.Client.AppsV1beta1().StatefulSets(namespace).List(metav1.ListOptions{}) | ||
| found := false | ||
| for _, statefulset := range statefulsetList.Items { | ||
| if statefulset.Name == name { | ||
| found = true | ||
| } | ||
| } | ||
| if !found { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForDeploymentDeletion(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for deployment to terminate") | ||
| deploymentList, _ := r.Client.Apps().Deployments(namespace).List(metav1.ListOptions{}) | ||
| found := false | ||
| for _, deployment := range deploymentList.Items { | ||
| if deployment.Name == name { | ||
| found = true | ||
| } | ||
| } | ||
| if !found { | ||
| return | ||
| } | ||
| } | ||
| } | ||
|
|
||
| func (r *RedisFailoverKubeClient) waitForServiceDeletion(name string, namespace string, logger log.Logger) { | ||
| t := r.clock.NewTicker(loopInterval) | ||
| defer t.Stop() | ||
|
|
||
| for range t.C { | ||
| logger.Debug("Waiting for service to disappear") | ||
| serviceList, _ := r.Client.Core().Services(namespace).List(metav1.ListOptions{}) | ||
| found := false | ||
| for _, service := range serviceList.Items { | ||
| if service.Name == name { | ||
| found = true | ||
| } | ||
| } | ||
| if !found { | ||
| return | ||
| } | ||
| } | ||
| } |