delete replica sets with code until client-go 3.0 integration

Author: Jeff McCormick

examples/golang/listlog.go

@@ -36,7 +36,7 @@ func main() {
 		fmt.Println("error waiting on lspvc pod to complete" + err.Error())
 	}
 	logOptions := v1.PodLogOptions{}
-	podName := "lspvc-mycluster"
+	podName := "lspvc-donut"
 	req := clientset.Core().Pods("default").GetLogs(podName, &logOptions)
 	if req == nil {
 		fmt.Println("error in get logs for " + podName)

operator/cluster/cluster_strategy_1.go

@@ -282,7 +282,11 @@ func shutdownCluster(clientset *kubernetes.Clientset, client *rest.RESTClient, c
 	//sleep just a bit to give the drain time to work
 	time.Sleep(2000 * time.Millisecond)
 
+	//TODO when client-go 3.0 is ready, use propagation_policy
+	//in the delete options to also delete the replica sets
+
 	//delete the replica deployment
+
 	err = clientset.Deployments(namespace).Delete(replicaName, &v1.DeleteOptions{})
 	if err != nil {
 		log.Error("error deleting replica Deployment " + err.Error())
@@ -311,6 +315,10 @@ func shutdownCluster(clientset *kubernetes.Clientset, client *rest.RESTClient, c
 	}
 	log.Info("deleted master Deployment " + cl.Spec.Name + " in namespace " + namespace)
 
+	*/
+
+	//TODO for k8s 1.6 and client-go 3.0 we can use propagation_policy
+	// to have the replica sets removed as part of the deployment remove
 	//delete replica sets if they exist
 	options := v1.ListOptions{}
 	options.LabelSelector = "pg-cluster=" + cl.Spec.Name
@@ -330,7 +338,6 @@ func shutdownCluster(clientset *kubernetes.Clientset, client *rest.RESTClient, c
 			log.Info("deleted cluster replicaset " + r.Name + " in namespace " + namespace)
 		}
 	}
-	*/
 
 	return err