Merge pull request #23 from inovex/expose-healthz-for-readiness-check

add healthz endpoint

Author: frittentheke

.gitignore

@@ -2,3 +2,4 @@ build/
 
 # vim swap files
 .*.sw*
+clouds.yaml

README.md

@@ -4,3 +4,14 @@ This is an [ExternalDNS provider](https://github.com/kubernetes-sigs/external-dn
 This projects externalizes the yet in-tree [OpenStack Designate provider](https://github.com/kubernetes-sigs/external-dns/tree/master/provider/designate).
 
 ### 🌪 This project is in a very early stage and likely does not do what you expect!
+
+## Development
+
+To run the webhook locally, you'll need to create a [clouds.yaml](https://docs.openstack.org/python-openstackclient/pike/configuration/index.html#clouds-yaml)
+file and put it in one of the standard-locations.
+Then set the cloud to be used in the `OS_CLOUD` environemnt variable.
+You can then start the webhook server using:
+
+```sh
+go run cmd/webhook/main.go
+```

cmd/webhook/main.go

@@ -1,22 +1,59 @@
 package main
 
 import (
+	"net"
+	"net/http"
+
 	log "github.com/sirupsen/logrus"
 
+	"external-dns-openstack-webhook/internal/designate/provider"
+
 	"sigs.k8s.io/external-dns/endpoint"
 	"sigs.k8s.io/external-dns/provider/webhook/api"
 )
 
-import "external-dns-openstack-webhook/internal/designate/provider"
-
 func main() {
+	log.SetLevel(log.DebugLevel)
+
+	startedChan := make(chan struct{})
+	httpApiStarted := false
+
+	go func() {
+		<-startedChan
+		httpApiStarted = true
+	}()
+
+	m := http.NewServeMux()
+	m.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
+		if !httpApiStarted {
+			w.WriteHeader(http.StatusInternalServerError)
+		}
+	})
+
+	go func() {
+		log.Debug("Starting status server on :8080")
+		s := &http.Server{
+			Addr:    "0.0.0.0:8080",
+			Handler: m,
+		}
+
+		l, err := net.Listen("tcp", "0.0.0.0:8080")
+		if err != nil {
+			log.Fatal(err)
+		}
+		err = s.Serve(l)
+		if err != nil {
+			log.Fatalf("health listener stopped : %s", err)
+		}
+	}()
+
+
 	epf := endpoint.NewDomainFilter([]string{})
 	dp, err := provider.NewDesignateProvider(epf, false)
 	if err != nil {
 		log.Fatalf("NewDesignateProvider: %v", err)
 	}
 
-	log.SetLevel(log.DebugLevel)
 	log.Printf("Starting server")
-	api.StartHTTPApi(dp, nil, 0, 0, "127.0.0.1:8888")
+	api.StartHTTPApi(dp, startedChan, 0, 0, "127.0.0.1:8888")
 }