remove some unused code and additional updates

Signed-off-by: Brian Downs <brian.downs@gmail.com>

pkg/controller/addressallocator/controller.go

@@ -1,50 +0,0 @@
-package addressallocator
-
-import (
-	"context"
-
-	"github.com/rancher/k3k/pkg/apis/k3k.io/v1alpha1"
-	"k8s.io/apimachinery/pkg/runtime"
-	"sigs.k8s.io/controller-runtime/pkg/client"
-	"sigs.k8s.io/controller-runtime/pkg/controller"
-	"sigs.k8s.io/controller-runtime/pkg/handler"
-	"sigs.k8s.io/controller-runtime/pkg/manager"
-	"sigs.k8s.io/controller-runtime/pkg/reconcile"
-	"sigs.k8s.io/controller-runtime/pkg/source"
-)
-
-const (
-	AddressAllocatorController = "address-allocator-controller"
-)
-
-type AddressAllocatorReconciler struct {
-	Client client.Client
-	Scheme *runtime.Scheme
-}
-
-// Add adds a new controller to the manager
-func Add(mgr manager.Manager) error {
-	// initialize a new Reconciler
-	reconciler := AddressAllocatorReconciler{
-		Client: mgr.GetClient(),
-		Scheme: mgr.GetScheme(),
-	}
-
-	controller, err := controller.New(AddressAllocatorController, mgr, controller.Options{
-		Reconciler:              &reconciler,
-		MaxConcurrentReconciles: 1,
-	})
-
-	if err != nil {
-		return err
-	}
-
-	return controller.Watch(&source.Kind{Type: &v1alpha1.Cluster{}},
-		&handler.EnqueueRequestForObject{})
-
-}
-
-// Reconcile will allocate cluster/service cidrs to new clusters
-func (r *AddressAllocatorReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error) {
-	return reconcile.Result{}, nil
-}

pkg/controller/cluster/cidr_allocation.go

@@ -1,129 +0,0 @@
-package cluster
-
-import (
-	"context"
-	"fmt"
-	"net"
-	"time"
-
-	"github.com/rancher/k3k/pkg/apis/k3k.io/v1alpha1"
-	"github.com/rancher/k3k/pkg/controller/util"
-	"k8s.io/apimachinery/pkg/types"
-)
-
-const (
-	cidrAllocationClusterPoolName = "k3k-cluster-cidr-allocation-pool"
-	cidrAllocationServicePoolName = "k3k-service-cidr-allocation-pool"
-
-	defaultClusterCIDR        = "10.44.0.0/16"
-	defaultClusterServiceCIDR = "10.45.0.0/16"
-)
-
-// determineOctet dertermines the octet for the
-// given mask bits of a subnet.
-func determineOctet(mb int) uint8 {
-	switch {
-	case mb <= 8:
-		return 1
-	case mb >= 8 && mb <= 16:
-		return 2
-	case mb >= 8 && mb <= 24:
-		return 3
-	case mb >= 8 && mb <= 32:
-		return 4
-	default:
-		return 0
-	}
-}
-
-// generateSubnets generates all subnets for the given CIDR.
-func generateSubnets(cidr string) ([]string, error) {
-	_, ipNet, err := net.ParseCIDR(cidr)
-	if err != nil {
-		return nil, err
-	}
-	usedBits, _ := ipNet.Mask.Size()
-
-	octet := determineOctet(usedBits)
-
-	ip := ipNet.IP.To4()
-	octetVal := ip[octet-1]
-
-	var subnets []string
-
-	for i := octetVal; i < 254; i++ {
-		octetVal++
-		ip[octet-1] = octetVal
-		subnets = append(subnets, fmt.Sprintf("%s/%d", ip, usedBits))
-	}
-
-	return subnets, nil
-}
-
-// nextCIDR retrieves the next available CIDR address from the given pool.
-func (c *ClusterReconciler) nextCIDR(ctx context.Context, cidrAllocationPoolName, clusterName string) (*net.IPNet, error) {
-	var cidrPool v1alpha1.CIDRAllocationPool
-
-	nn := types.NamespacedName{
-		Name: cidrAllocationPoolName,
-	}
-	if err := c.Client.Get(ctx, nn, &cidrPool); err != nil {
-		return nil, util.WrapErr("failed to get cidrpool", err)
-	}
-
-	var ipNet *net.IPNet
-
-	for _, pool := range cidrPool.Status.Pool {
-		if pool.ClusterName == clusterName {
-			_, ipn, err := net.ParseCIDR(pool.IPNet)
-			if err != nil {
-				return nil, util.WrapErr("failed to parse cidr", err)
-			}
-			return ipn, nil
-		}
-	}
-	for i := 0; i < len(cidrPool.Status.Pool); i++ {
-		if cidrPool.Status.Pool[i].ClusterName == "" && cidrPool.Status.Pool[i].Issued == 0 {
-			cidrPool.Status.Pool[i].ClusterName = clusterName
-			cidrPool.Status.Pool[i].Issued = time.Now().Unix()
-
-			_, ipn, err := net.ParseCIDR(cidrPool.Status.Pool[i].IPNet)
-			if err != nil {
-				return nil, util.WrapErr("failed to parse cidr", err)
-			}
-			if err := c.Client.Update(ctx, &cidrPool); err != nil {
-				return nil, util.WrapErr("failed to update cidr pool", err)
-			}
-			ipNet = ipn
-
-			break
-		}
-	}
-
-	return ipNet, nil
-}
-
-// releaseCIDR updates the given CIDR pool by marking the address as available.
-func (c *ClusterReconciler) releaseCIDR(ctx context.Context, cidrAllocationPoolName, clusterName string) error {
-	var cidrPool v1alpha1.CIDRAllocationPool
-
-	nn := types.NamespacedName{
-		Name: cidrAllocationPoolName,
-	}
-	if err := c.Client.Get(ctx, nn, &cidrPool); err != nil {
-		return err
-	}
-
-	for i := 0; i < len(cidrPool.Status.Pool); i++ {
-		if cidrPool.Status.Pool[i].ClusterName == clusterName {
-			cidrPool.Status.Pool[i].ClusterName = ""
-			cidrPool.Status.Pool[i].Issued = 0
-		}
-
-		if err := c.Client.Status().Update(ctx, &cidrPool); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}

pkg/controller/cluster/config/agent.go

@@ -9,8 +9,8 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-func AgentConfig(cluster *v1alpha1.Cluster, serviceIP string) v1.Secret {
-	config := agentConfigData(serviceIP, cluster.Spec.Token)
+func Agent(cluster *v1alpha1.Cluster, serviceIP string) v1.Secret {
+	config := agentData(serviceIP, cluster.Spec.Token)
 
 	return v1.Secret{
 		TypeMeta: metav1.TypeMeta{
@@ -27,7 +27,7 @@ func AgentConfig(cluster *v1alpha1.Cluster, serviceIP string) v1.Secret {
 	}
 }
 
-func agentConfigData(serviceIP, token string) string {
+func agentData(serviceIP, token string) string {
 	return fmt.Sprintf(`server: https://%s:6443
 token: %s`, serviceIP, token)
 }

pkg/controller/cluster/config/server.go

@@ -7,13 +7,13 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-func ServerConfig(cluster *v1alpha1.Cluster, init bool, serviceIP string) (*v1.Secret, error) {
+func Server(cluster *v1alpha1.Cluster, init bool, serviceIP string) (*v1.Secret, error) {
 	name := "k3k-server-config"
 	if init {
 		name = "k3k-init-server-config"
 	}
 
-	config := serverConfigData(serviceIP, cluster)
+	config := serverData(serviceIP, cluster)
 	if init {
 		config = initConfigData(cluster)
 	}
@@ -32,7 +32,7 @@ func ServerConfig(cluster *v1alpha1.Cluster, init bool, serviceIP string) (*v1.S
 	}, nil
 }
 
-func serverConfigData(serviceIP string, cluster *v1alpha1.Cluster) string {
+func serverData(serviceIP string, cluster *v1alpha1.Cluster) string {
 	return "cluster-init: true\nserver: https://" + serviceIP + ":6443" + serverOptions(cluster)
 }
 

pkg/controller/cluster/controller.go

@@ -102,16 +102,6 @@ func (c *ClusterReconciler) createCluster(ctx context.Context, cluster *v1alpha1
 		return util.WrapErr("failed to create ns", err)
 	}
 
-	cluster.Status.ClusterCIDR = cluster.Spec.ClusterCIDR
-	if cluster.Status.ClusterCIDR == "" {
-		cluster.Status.ClusterCIDR = defaultClusterCIDR
-	}
-
-	cluster.Status.ServiceCIDR = cluster.Spec.ServiceCIDR
-	if cluster.Status.ServiceCIDR == "" {
-		cluster.Status.ServiceCIDR = defaultClusterServiceCIDR
-	}
-
 	klog.Infof("creating cluster service")
 	serviceIP, err := c.createClusterService(ctx, cluster)
 	if err != nil {
@@ -177,7 +167,7 @@ func (c *ClusterReconciler) createNamespace(ctx context.Context, cluster *v1alph
 
 func (c *ClusterReconciler) createClusterConfigs(ctx context.Context, cluster *v1alpha1.Cluster, serviceIP string) error {
 	// create init node config
-	initServerConfig, err := config.ServerConfig(cluster, true, serviceIP)
+	initServerConfig, err := config.Server(cluster, true, serviceIP)
 	if err != nil {
 		return err
 	}
@@ -193,7 +183,7 @@ func (c *ClusterReconciler) createClusterConfigs(ctx context.Context, cluster *v
 	}
 
 	// create servers configuration
-	serverConfig, err := config.ServerConfig(cluster, false, serviceIP)
+	serverConfig, err := config.Server(cluster, false, serviceIP)
 	if err != nil {
 		return err
 	}
@@ -207,7 +197,7 @@ func (c *ClusterReconciler) createClusterConfigs(ctx context.Context, cluster *v
 	}
 
 	// create agents configuration
-	agentsConfig := config.AgentConfig(cluster, serviceIP)
+	agentsConfig := config.Agent(cluster, serviceIP)
 	if err := controllerutil.SetControllerReference(cluster, &agentsConfig, c.Scheme); err != nil {
 		return err
 	}
@@ -289,30 +279,7 @@ func (c *ClusterReconciler) createDeployments(ctx context.Context, cluster *v1al
 }
 
 func (c *ClusterReconciler) createCIDRPools(ctx context.Context) error {
-	clusterSubnets, err := generateSubnets(defaultClusterCIDR)
-	if err != nil {
-		return err
-	}
-
-	var clusterSubnetAllocations []v1alpha1.Allocation
-	for _, cs := range clusterSubnets {
-		clusterSubnetAllocations = append(clusterSubnetAllocations, v1alpha1.Allocation{
-			IPNet: cs,
-		})
-	}
-
-	cidrClusterPool := v1alpha1.CIDRAllocationPool{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: cidrAllocationClusterPoolName,
-		},
-		Spec: v1alpha1.CIDRAllocationPoolSpec{
-			DefaultClusterCIDR: defaultClusterCIDR,
-		},
-		Status: v1alpha1.CIDRAllocationPoolStatus{
-			Pool: clusterSubnetAllocations,
-		},
-	}
-	if err := c.Client.Create(ctx, &cidrClusterPool); err != nil {
+	if err := c.Client.Create(ctx, &v1alpha1.CIDRAllocationPool{}); err != nil {
 		if !apierrors.IsAlreadyExists(err) {
 			// return nil since the resource has
 			// already been created
@@ -320,35 +287,13 @@ func (c *ClusterReconciler) createCIDRPools(ctx context.Context) error {
 		}
 	}
 
-	clusterServiceSubnets, err := generateSubnets(defaultClusterServiceCIDR)
-	if err != nil {
-		return err
-	}
-
-	var clusterServiceSubnetAllocations []v1alpha1.Allocation
-	for _, ss := range clusterServiceSubnets {
-		clusterServiceSubnetAllocations = append(clusterServiceSubnetAllocations, v1alpha1.Allocation{
-			IPNet: ss,
-		})
-	}
-
-	cidrServicePool := v1alpha1.CIDRAllocationPool{
-		ObjectMeta: metav1.ObjectMeta{
-			Name: cidrAllocationServicePoolName,
-		},
-		Spec: v1alpha1.CIDRAllocationPoolSpec{
-			DefaultClusterCIDR: defaultClusterCIDR,
-		},
-		Status: v1alpha1.CIDRAllocationPoolStatus{
-			Pool: clusterServiceSubnetAllocations,
-		},
-	}
-	if err := c.Client.Create(ctx, &cidrServicePool); err != nil {
+	if err := c.Client.Create(ctx, &v1alpha1.CIDRAllocationPool{}); err != nil {
 		if !apierrors.IsAlreadyExists(err) {
 			// return nil since the resource has
 			// already been created
 			return err
 		}
 	}
+
 	return nil
 }

pkg/controller/cluster/server/ingress.go

@@ -46,8 +46,9 @@ func Ingress(ctx context.Context, cluster *v1alpha1.Cluster, client client.Clien
 }
 
 func ingressRules(cluster *v1alpha1.Cluster, addresses []string) []networkingv1.IngressRule {
-	ingressRules := []networkingv1.IngressRule{}
+	var ingressRules []networkingv1.IngressRule
 	pathTypePrefix := networkingv1.PathTypePrefix
+
 	for _, address := range addresses {
 		rule := networkingv1.IngressRule{
 			Host: cluster.Name + "." + address + wildcardDNS,
@@ -72,6 +73,7 @@ func ingressRules(cluster *v1alpha1.Cluster, addresses []string) []networkingv1.
 		}
 		ingressRules = append(ingressRules, rule)
 	}
+
 	return ingressRules
 }
 

pkg/controller/cluster/server/service.go

@@ -16,6 +16,7 @@ func Service(cluster *v1alpha1.Cluster) *v1.Service {
 			}
 		}
 	}
+
 	return &v1.Service{
 		TypeMeta: metav1.TypeMeta{
 			Kind:       "Service",

pkg/controller/util/util.go

@@ -35,7 +35,8 @@ func nodeAddress(node *v1.Node) string {
 		if ip.Type == "ExternalIP" && ip.Address != "" {
 			externalIP = ip.Address
 			break
-		} else if ip.Type == "InternalIP" && ip.Address != "" {
+		}
+		if ip.Type == "InternalIP" && ip.Address != "" {
 			internalIP = ip.Address
 		}
 	}