|
1 | 1 | package main
|
2 | 2 |
|
3 | 3 | import (
|
| 4 | + "net" |
| 5 | + "net/http" |
| 6 | + |
4 | 7 | log "github.com/sirupsen/logrus"
|
5 | 8 |
|
| 9 | + "external-dns-openstack-webhook/internal/designate/provider" |
| 10 | + |
6 | 11 | "sigs.k8s.io/external-dns/endpoint"
|
7 | 12 | "sigs.k8s.io/external-dns/provider/webhook/api"
|
8 | 13 | )
|
9 | 14 |
|
10 |
| -import "external-dns-openstack-webhook/internal/designate/provider" |
11 |
| - |
12 | 15 | func main() {
|
| 16 | + log.SetLevel(log.DebugLevel) |
| 17 | + |
| 18 | + startedChan := make(chan struct{}) |
| 19 | + httpApiStarted := false |
| 20 | + |
| 21 | + go func() { |
| 22 | + <-startedChan |
| 23 | + httpApiStarted = true |
| 24 | + }() |
| 25 | + |
| 26 | + m := http.NewServeMux() |
| 27 | + m.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) { |
| 28 | + if !httpApiStarted { |
| 29 | + w.WriteHeader(http.StatusInternalServerError) |
| 30 | + } |
| 31 | + }) |
| 32 | + |
| 33 | + go func() { |
| 34 | + log.Debug("Starting status server on :8080") |
| 35 | + s := &http.Server{ |
| 36 | + Addr: "0.0.0.0:8080", |
| 37 | + Handler: m, |
| 38 | + } |
| 39 | + |
| 40 | + l, err := net.Listen("tcp", "0.0.0.0:8080") |
| 41 | + if err != nil { |
| 42 | + log.Fatal(err) |
| 43 | + } |
| 44 | + err = s.Serve(l) |
| 45 | + if err != nil { |
| 46 | + log.Fatalf("health listener stopped : %s", err) |
| 47 | + } |
| 48 | + }() |
| 49 | + |
| 50 | + |
13 | 51 | epf := endpoint.NewDomainFilter([]string{})
|
14 | 52 | dp, err := provider.NewDesignateProvider(epf, false)
|
15 | 53 | if err != nil {
|
16 | 54 | log.Fatalf("NewDesignateProvider: %v", err)
|
17 | 55 | }
|
18 | 56 |
|
19 |
| - log.SetLevel(log.DebugLevel) |
20 | 57 | log.Printf("Starting server")
|
21 |
| - api.StartHTTPApi(dp, nil, 0, 0, "127.0.0.1:8888") |
| 58 | + api.StartHTTPApi(dp, startedChan, 0, 0, "127.0.0.1:8888") |
22 | 59 | }
|
0 commit comments