IP ranges cleanup

Dockerfile

@@ -8,5 +8,6 @@ RUN ./hack/build-go.sh
 FROM alpine:latest
 LABEL org.opencontainers.image.source https://github.com/k8snetworkplumbingwg/whereabouts
 COPY --from=0 /go/src/github.com/dougbtv/whereabouts/bin/whereabouts .
+COPY --from=0 /go/src/github.com/dougbtv/whereabouts/bin/ip-reconciler .
 COPY script/install-cni.sh .
 CMD ["/install-cni.sh"]

README.md

@@ -42,7 +42,11 @@ You can install this plugin with a Daemonset, using:
 
 ```
 git clone https://github.com/dougbtv/whereabouts && cd whereabouts
-kubectl apply -f ./doc/daemonset-install.yaml -f ./doc/whereabouts.cni.cncf.io_ippools.yaml -f ./doc/whereabouts.cni.cncf.io_overlappingrangeipreservations.yaml
+kubectl apply \
+    -f ./doc/daemonset-install.yaml \
+    -f ./doc/whereabouts.cni.cncf.io_ippools.yaml \
+    -f ./doc/whereabouts.cni.cncf.io_overlappingrangeipreservations.yaml \
+    -f doc/ip-reconciler-job.yaml
 ```
 
 The daemonset installation requires Kubernetes Version 1.16 or later.

cmd/reconciler/errors.go

@@ -0,0 +1,8 @@
+package main
+
+const (
+	kubeconfigNotFound = iota + 1
+	couldNotStartOrphanedIPMonitor
+	failedToReconcileIPPools
+	failedToReconcileClusterWideIPs
+)

cmd/reconciler/ip.go

@@ -0,0 +1,44 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"github.com/dougbtv/whereabouts/pkg/storage"
+	"os"
+
+	"github.com/dougbtv/whereabouts/pkg/logging"
+	"github.com/dougbtv/whereabouts/pkg/reconciler"
+)
+
+func main() {
+	kubeConfigFile := flag.String("kubeconfig", "", "the path to the Kubernetes configuration file")
+	flag.Parse()
+
+	if *kubeConfigFile == "" {
+		_ = logging.Errorf("must specify the kubernetes config file, via the '-kubeconfig' flag")
+		os.Exit(kubeconfigNotFound)
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), storage.RequestTimeout)
+	defer cancel()
+	ipReconcileLoop, err := reconciler.NewReconcileLooper(*kubeConfigFile, ctx)
+	if err != nil {
+		_ = logging.Errorf("failed to create the reconcile looper: %v", err)
+		os.Exit(couldNotStartOrphanedIPMonitor)
+	}
+
+	cleanedUpIps, err := ipReconcileLoop.ReconcileIPPools()
+	if err != nil {
+		_ = logging.Errorf("failed to clean up IP for allocations: %v", err)
+		os.Exit(failedToReconcileIPPools)
+	}
+	if len(cleanedUpIps) > 0 {
+		logging.Debugf("successfully cleanup IPs: %+v", cleanedUpIps)
+	} else {
+		logging.Debugf("no IP addresses to cleanup")
+	}
+
+	if err := ipReconcileLoop.ReconcileOverlappingIPAddresses(); err != nil {
+		os.Exit(failedToReconcileClusterWideIPs)
+	}
+}