Add pause functionality

Author: tom1299

internal/pkg/handler/upgrade.go

@@ -281,44 +281,51 @@ func PerformAction(clients kube.Clients, config util.Config, upgradeFuncs callba
 		if result == constants.Updated {
 
 			if _, ok := i.(*app.Deployment); ok {
-				logrus.Infof("Resource '%s' is of type 'Deployment'", config.ResourceName)
+				accessor, err := meta.Accessor(i)
+				if err != nil {
+					logrus.Errorf("Failed to get accessor for resource '%s': %v", i, err)
+					return err
+				}
+				deploymentName := accessor.GetName()
+				deploymentNamespace := accessor.GetNamespace()
+				logrus.Infof("Resource name: %s, namespace: %s is of type Deployment", deploymentName, deploymentNamespace)
 				annotations := upgradeFuncs.AnnotationsFunc(i)
 				pauseValue := annotations["pause"]
 				if pauseValue != "" {
 					logrus.Infof("Pause value is %s", pauseValue)
 					pauseDuration, err := time.ParseDuration(pauseValue)
 					if err != nil {
-						logrus.Errorf("Failed to parse pause value '%s' for resource '%s': %v", pauseValue, config.ResourceName, err)
+						logrus.Errorf("Failed to parse pause value '%s' for resource '%s': %v", pauseValue, deploymentName, err)
 					} else {
-						logrus.Infof("Parsed pause value for resource '%s' is %d seconds", config.ResourceName, int(pauseDuration.Seconds()))
+						logrus.Infof("Parsed pause value for resource '%s' is %d seconds", deploymentName, int(pauseDuration.Seconds()))
 						deployment, ok := i.(*app.Deployment)
 						if !ok {
-							logrus.Errorf("Failed to cast resource '%s' to Deployment", config.ResourceName)
+							logrus.Errorf("Failed to cast resource '%s' to Deployment", deploymentName)
 							return errors.New("failed to cast resource to Deployment")
 						}
 
 						if !deployment.Spec.Paused {
 							deployment.Spec.Paused = true
-							logrus.Infof("Pausing Deployment '%s' in namespace '%s'", config.ResourceName, config.Namespace)
+							logrus.Infof("Pausing Deployment '%s' in namespace '%s'", deploymentName, deploymentNamespace)
 							deployment.Annotations["paused-by-reloader-at"] = time.Now().Format(time.RFC3339)
 
 							time.AfterFunc(pauseDuration, func() {
-								deployment, err := clients.KubernetesClient.AppsV1().Deployments(config.Namespace).Get(context.TODO(), config.ResourceName, metav1.GetOptions{})
+								deployment, err := clients.KubernetesClient.AppsV1().Deployments(deploymentNamespace).Get(context.TODO(), deploymentName, metav1.GetOptions{})
 								if err != nil {
-									logrus.Errorf("Failed to get Deployment '%s' in namespace '%s': %v", config.ResourceName, config.Namespace, err)
+									logrus.Errorf("Failed to get Deployment '%s' in namespace '%s': %v", deploymentName, deploymentNamespace, err)
 									return
 								}
 
 								deployment.Spec.Paused = false
 								deployment.Annotations["paused-by-reloader-at"] = ""
 
-								_, err = clients.KubernetesClient.AppsV1().Deployments(config.Namespace).Update(context.TODO(), deployment, metav1.UpdateOptions{})
+								_, err = clients.KubernetesClient.AppsV1().Deployments(deploymentNamespace).Update(context.TODO(), deployment, metav1.UpdateOptions{})
 								if err != nil {
-									logrus.Errorf("Failed to update Deployment '%s' in namespace '%s': %v", config.ResourceName, config.Namespace, err)
+									logrus.Errorf("Failed to update Deployment '%s' in namespace '%s': %v", deploymentName, deploymentNamespace, err)
 								}
 							})
 						} else {
-							logrus.Infof("Deployment '%s' in namespace '%s' is already paused", config.ResourceName, config.Namespace)
+							logrus.Infof("Deployment '%s' in namespace '%s' is already paused", deploymentName, deploymentNamespace)
 						}
 					}
 				}