Add soft delete flag to DNS Operator plan.

Signed-off-by: Phil Brookes <[email protected]>

Author: philbrookes

Makefile

@@ -250,8 +250,10 @@ build: manifests generate fmt vet ## Build manager binary.
 .PHONY: run
 run: GIT_SHA=$(shell git rev-parse HEAD || echo "unknown")
 run: DIRTY=$(shell hack/check-git-dirty.sh || echo "unknown")
+run: MPORT=:8080
+run: PPORT=:8081
 run: manifests generate fmt vet ## Run a controller from your host.
-	go run -ldflags "-X main.version=v${VERSION} -X main.gitSHA=${GIT_SHA} -X main.dirty=${DIRTY}" --race ./cmd/main.go --zap-devel --provider inmemory,aws,google,azure
+	go run -ldflags "-X main.version=v${VERSION} -X main.gitSHA=${GIT_SHA} -X main.dirty=${DIRTY}" --race ./cmd/main.go --zap-devel --provider inmemory,aws,google,azure --metrics-bind-address ${MPORT} --health-probe-bind-address ${PPORT}
 
 .PHONY: run-with-probes
 run-with-probes: GIT_SHA=$(shell git rev-parse HEAD || echo "unknown")

internal/common/helper.go

@@ -1,9 +1,12 @@
 package common
 
 import (
+	"fmt"
+	"io"
 	"time"
 
 	"k8s.io/apimachinery/pkg/util/rand"
+	externaldnsendpoint "sigs.k8s.io/external-dns/endpoint"
 )
 
 // RandomizeValidationDuration randomizes duration for a given variance with a min value of 1 sec
@@ -27,3 +30,34 @@ func RandomizeDuration(variance, duration float64) time.Duration {
 		int64(lowerLimit),
 		int64(upperLimit)))
 }
+
+func WriteEndpoints(s io.Writer, endpoints []*externaldnsendpoint.Endpoint, title string) {
+	fmt.Fprintf(s, "\n====== %s ======\n", title)
+	for _, ep := range endpoints {
+		fmt.Fprintf(s, "	endpoint: %v > %+v with labels: %+v and flags: %+v\n", ep.DNSName, ep.Targets, ep.Labels, ep.ProviderSpecific)
+	}
+	fmt.Fprintf(s, "====== %s ======\n\n", title)
+}
+
+func RemoveLabelFromEndpoint(label string, endpoint *externaldnsendpoint.Endpoint) *externaldnsendpoint.Endpoint {
+	if endpoint.Labels == nil {
+		return endpoint
+	}
+
+	delete(endpoint.Labels, label)
+	return endpoint
+}
+
+func RemoveLabelFromEndpoints(label string, endpoints []*externaldnsendpoint.Endpoint) []*externaldnsendpoint.Endpoint {
+	for _, e := range endpoints {
+		RemoveLabelFromEndpoint(label, e)
+	}
+	return endpoints
+}
+func RemoveLabelsFromEndpoints(labels []string, endpoints []*externaldnsendpoint.Endpoint) []*externaldnsendpoint.Endpoint {
+	for _, l := range labels {
+		RemoveLabelFromEndpoints(l, endpoints)
+	}
+
+	return endpoints
+}