Ensure managed schedules are deleted

The pgo-rmdata job was not set up to delete the ConfigMap objects that
are managed by the scheduler for scheduled tasks. This corrects that
issue and ensures any scheduled task for a cluster being deleted is
also removed.

Issue: [ch6500]

Author: Jonathan S. Katz

kubeapi/configmap.go

@@ -84,3 +84,25 @@ func DeleteConfigMap(clientset *kubernetes.Clientset, name, namespace string) er
 	return err
 
 }
+
+// DeleteConfigMaps deletes a ConfigMap by a selector
+func DeleteConfigMaps(clientset *kubernetes.Clientset, selector, namespace string) error {
+	log.Debugf("deleting configmaps with selector '%s'", selector)
+
+	deleteOptions := meta_v1.DeleteOptions{}
+	listOptions := meta_v1.ListOptions{
+		LabelSelector: selector,
+	}
+
+	err := clientset.CoreV1().ConfigMaps(namespace).DeleteCollection(
+		&deleteOptions, listOptions)
+
+	if err != nil {
+		log.Error("error deleting ConfigMap " + err.Error())
+		return err
+	}
+
+	log.Debugf("deleted configmaps with selector '%s'", selector)
+
+	return nil
+}

pgo-rmdata/rmdata/process.go

@@ -83,6 +83,11 @@ func Delete(request Request) {
 	}
 
 	log.Info("rmdata.Process cluster use case")
+
+	// first, clear out any of the scheduled jobs that may occur, as this would be
+	// executing asynchronously against any stale data
+	removeSchedules(request)
+
 	//the user had done something like:
 	//pgo delete cluster mycluster --delete-data
 	if request.RemoveData {
@@ -589,3 +594,22 @@ func removeReplicaServices(request Request) {
 	}
 
 }
+
+// removeSchedules removes any of the ConfigMap objects that were created to
+// execute schedule tasks, such as backups
+// As these are consistently labeled, we can leverage Kuernetes selectors to
+// delete all of them
+func removeSchedules(request Request) {
+	log.Debugf("removing schedules for '%s'", request.ClusterName)
+
+	// a ConfigMap used for the schedule uses the following label selector:
+	// crunchy-scheduler=true,<config.LABEL_PG_CLUSTER>=<request.ClusterName>
+	selector := fmt.Sprintf("crunchy-scheduler=true,%s=%s",
+		config.LABEL_PG_CLUSTER, request.ClusterName)
+
+	// run the query the deletes all of the scheduled configmaps
+	// if there is an error, log it, but continue on without making a big stink
+	if err := kubeapi.DeleteConfigMaps(request.Clientset, selector, request.Namespace); err != nil {
+		log.Error(err)
+	}
+}