feat: drop etcd support

README.md

@@ -25,7 +25,7 @@
   * **Monitoring** ([Grafana](https://github.com/integr8ly/grafana-operator), [Prometheus](https://github.com/coreos/prometheus-operator), [Thanos](https://thanos.io/), [Karma](https://github.com/prymitive/karma), [Canary Checker](https://github.com/flanksource/canary-checker))
   * **Multi-Tenancy** ([Namespace Configurator](https://github.com/redhat-cop/namespace-configuration-operator) Cluster Quotas, [Kiosk](https://github.com/kiosk-sh/kiosk))
 * **Cluster Provisioning** framework for [Kind](https://karina.docs.flanksource.com/admin-guide/provisioning/kind/), [vSphere](https://karina.docs.flanksource.com/admin-guide/provisioning/vsphere/) and Cluster API (Coming Soon)
-* **Operations focused CLI** for health checks, etcd maintenance, backup and restore, rolling updates, logging, etc..
+* **Operations focused CLI** for health checks, backup and restore, rolling updates, logging, etc..
 
 karina leverages a number of other standalone operators built by flanksource:
 

cmd/common_test.go

@@ -30,7 +30,6 @@ func TestGetConfigSetDefaults(t *testing.T) {
 		ControllerExtraArgs: map[string]string{},
 		SchedulerExtraArgs:  map[string]string{},
 		KubeletExtraArgs:    map[string]string{},
-		EtcdExtraArgs:       map[string]string{},
 		ContainerRuntime:    "docker",
 	}))
 }

main.go

@@ -41,7 +41,6 @@ func main() {
 		cmd.DNS,
 		cmd.Exec,
 		cmd.ExecNode,
-		cmd.Etcd,
 		cmd.Harbor,
 		cmd.Images,
 		cmd.Logs,

pkg/api/postgres/types.go

@@ -469,7 +469,6 @@ type OperatorLogicalBackupConfiguration struct {
 type OperatorConfigurationData struct {
 	EnableCRDValidation     *bool    `json:"enable_crd_validation,omitempty"`
 	EnableLazySpiloUpgrade  bool     `json:"enable_lazy_spilo_upgrade,omitempty"`
-	EtcdHost                string   `json:"etcd_host,omitempty"`
 	KubernetesUseConfigMaps bool     `json:"kubernetes_use_configmaps,omitempty"`
 	DockerImage             string   `json:"docker_image,omitempty"`
 	Workers                 uint32   `json:"workers,omitempty"`

pkg/provision/cluster.go

@@ -69,7 +69,6 @@ type Cluster struct {
 	Nodes      NodeMachines
 	Orphans    []types.Machine
 	Kubernetes kubernetes.Interface
-	Etcd       *EtcdClient
 }
 
 func GetCluster(platform *platform.Platform) (*Cluster, error) {
@@ -117,21 +116,16 @@ func GetCluster(platform *platform.Platform) (*Cluster, error) {
 		Nodes:      nodes,
 		Orphans:    orphans,
 		Kubernetes: client,
-		Etcd:       GetEtcdClient(platform, client, ""),
 	}
 	cluster.Platform = platform
 	return cluster, nil
 }
 
 func (cluster *Cluster) Terminate(node types.Machine) error {
-	terminate(cluster.Platform, cluster.Etcd, node)
+	terminate(cluster.Platform, node)
 	return nil
 }
 
-func (cluster *Cluster) GetHealth(node v1.Node) string {
-	return cluster.Etcd.GetHealth(node)
-}
-
 func (cluster *Cluster) Cordon(node v1.Node) error {
 	return cluster.Platform.Cordon(node.Name)
 }

pkg/provision/status.go

@@ -94,7 +94,6 @@ func Status(p *platform.Platform) error {
 		fmt.Fprintf(w, "%s\t", kommons.GetNodeStatus(node))
 		if kommons.IsMasterNode(node) {
 			fmt.Fprintf(w, "%s\t", kubeadm.GetNodeVersion(p, nodeMachine.Node))
-			fmt.Fprintf(w, "%s\t", cluster.GetHealth(node))
 		} else {
 			fmt.Fprintf(w, "\t\t")
 		}