Update main.go

README_GO.md

@@ -21,14 +21,17 @@ backend {{ .Name }}
   cookie {{ .CookieName }} {{ .CookieFlags }}
   {{- end }}
 
+  {{- if .HealthCheck }}
+  option httpchk GET {{ .HealthCheck }}
+  http-check expect status 200
+  {{- end }}
+
+  {{- $backend := . }}
   {{- range .Servers }}
-  server {{ .Name }} {{ .Address }}:{{ .Port }}{{ if $.HealthCheck }} check{{ end }}{{ if $.CookieName }} cookie {{ .Cookie }}{{ end }} {{ $.ServerOptions }}
+  server {{ .Name }} {{ .Address }}:{{ .Port }}{{ if $backend.HealthCheck }} check{{ end }}{{ if $backend.CookieName }} cookie {{ .Cookie }}{{ end }}{{ if $backend.ServerOptions }} {{ $backend.ServerOptions }}{{ end }}
   {{- end }}
 
 {{- end }}
-
-{{- end }}
-
 ```
 
 
@@ -45,8 +48,7 @@ Environment=KUBERNETES_HOST=https://10.0.20.7:6443
 Environment=KUBERNETES_TOKEN=eyJhbGciOi...
 Environment=KUBERNETES_VERIFYSSL=false
 Environment=HAPROXY_TEMPLATE=/etc/haproxy/haproxy.tmpl
-ExecStart=/path/to/haproxy-generator > /etc/haproxy/haproxy.cfg
+ExecStart=/bin/bash /etc/haproxy/haproxy-generator.sh
-ExecStartPost=/bin/systemctl restart haproxy
 
 ```
 
@@ -65,3 +67,33 @@ Persistent=true
 WantedBy=timers.target
 
 ```
+
+# Reload Script for post start
+
+Copy the script to /etc/haproxy/haproxy-generator.sh
+```
+#!/bin/bash
+
+/usr/local/bin/haproxy-generator > /etc/haproxy/haproxy.cfg.new
+DIFF=$(diff /etc/haproxy/haproxy.cfg /etc/haproxy/haproxy.cfg.new)
+/sbin/haproxy -f /etc/haproxy/haproxy.cfg.new -c
+VALID=$?
+
+if [ "$DIFF" != "" ] && [ $VALID -eq 0 ]
+then
+    mv /etc/haproxy/haproxy.cfg.new /etc/haproxy/haproxy.cfg
+    /usr/sbin/service haproxy restart
+fi
+```
+
+# Service Annotations
+
+| Annotation-Key                 | Beschreibung                                                                | Typ     | Beispielwert               |
+|--------------------------------|-----------------------------------------------------------------------------|---------|---------------------------|
+| `haproxy/enabled`              | **Aktiviert** die Aufnahme des Services in die HAProxy-Konfiguration        | `bool`  | `"true"`                   |
+| `haproxy/mode`                 | Betriebsmodus des Backends (`tcp` oder `http`)                              | `string`| `"tcp"` / `"http"`         |
+| `haproxy/cookie-name`          | Name des Cookies zur Session-Persistenz                                     | `string`| `"SRVCOOKIE"`              |
+| `haproxy/cookie-flags`         | Zusätzliche Cookie-Optionen für HAProxy                                     | `string`| `"insert indirect nocache"`|
+| `haproxy/health-check`         | Deaktiviert Health-Checks, wenn `"false"` gesetzt wird                      | `bool`  | `"false"`                  |
+| `haproxy/server-options`       | Zusätzliche Optionen für die einzelnen `server`-Zeilen in HAProxy           | `string`| `"ssl verify none"`        |
+| `haproxy/port`                 | Nutze nur **diesen Port** des Services, wenn mehrere Ports definiert sind   | `int`   |`"8080"`                   |

main.go

@@ -33,12 +33,11 @@ type Backend struct {
 	Mode          string
 	CookieName    string
 	CookieFlags   string
-	HealthCheck   bool
+	HealthCheck   string
 	ServerOptions string
 	Servers       []BackendServer
 }
 
-
 func getEnv(key, fallback string) string {
 	if val, ok := os.LookupEnv(key); ok && val != "" {
 		return val
@@ -102,7 +101,6 @@ func main() {
 	k8sToken := getEnv("KUBERNETES_TOKEN", "")
 	verifySSLStr := getEnv("KUBERNETES_VERIFYSSL", "false")
 	templatePath := getEnv("HAPROXY_TEMPLATE", "haproxy.tmpl")
-	annotationCheckEnabled := os.Getenv("KUBERNETES_ANNOTATION_HAPROXY") != ""
 
 	if k8sHost == "" || k8sToken == "" {
 		log.Fatal("KUBERNETES_HOST and KUBERNETES_TOKEN must be set")
@@ -139,16 +137,13 @@ func main() {
 	type EndpointSubsetAddress struct {
 		IP string `json:"ip"`
 	}
-
 	type EndpointSubsetPort struct {
 		Port int `json:"port"`
 	}
-
 	type EndpointSubset struct {
 		Addresses []EndpointSubsetAddress `json:"addresses"`
 		Ports     []EndpointSubsetPort    `json:"ports"`
 	}
-
 	type Endpoint struct {
 		Metadata struct {
 			Name      string `json:"name"`
@@ -186,28 +181,19 @@ func main() {
 	backends := []Backend{}
 
 	for _, svc := range services {
-		if annotationCheckEnabled {
+		ann := svc.Metadata.Annotations
-			val, ok := svc.Metadata.Annotations["haproxy/enabled"]
+		if val, ok := ann["haproxy/enabled"]; !ok || val != "true" {
-			if !ok || val != "true" {
+			continue
-				continue
-			}
 		}
 
 		key := svc.Metadata.Namespace + "/" + svc.Metadata.Name
 		ep, found := endpointMap[key]
-		if !found || len(ep.Subsets) == 0 {
-			continue
-		}
-
-		ann := svc.Metadata.Annotations
 
 		b := Backend{
 			Name:        "SRV_" + strings.ReplaceAll(svc.Metadata.Name, " ", "-"),
 			Balance:     "leastconn",
-			Mode:        "tcp", // default
+			Mode:        "tcp",
-			CookieName:  "",
+			HealthCheck: "",
-			CookieFlags: "",
-			HealthCheck: true,
 		}
 
 		if val, ok := ann["haproxy/mode"]; ok && val != "" {
@@ -219,32 +205,42 @@ func main() {
 		if val, ok := ann["haproxy/cookie-flags"]; ok && val != "" {
 			b.CookieFlags = val
 		}
-		if val, ok := ann["haproxy/health-check"]; ok && strings.ToLower(val) == "false" {
+		if val, ok := ann["haproxy/health-check"]; ok && val != "" {
-			b.HealthCheck = false
+			b.HealthCheck = val
 		}
-
 		if val, ok := ann["haproxy/server-options"]; ok && val != "" {
 			b.ServerOptions = val
 		}
 
-		servers := []BackendServer{}
+		targetPort := 0
-		serverIndex := 1
+		if val, ok := ann["haproxy/port"]; ok && val != "" {
-		for _, subset := range ep.Subsets {
+			if p, err := strconv.Atoi(val); err == nil {
-			for _, addr := range subset.Addresses {
+				targetPort = p
-				for _, port := range subset.Ports {
+			}
-					cookie := hashString(fmt.Sprintf("%s-%s-%d", svc.Metadata.Name, addr.IP, port.Port))
+		}
-					serverName := fmt.Sprintf("%s_%d", svc.Metadata.Name, serverIndex)
-					serverIndex++
 
-					servers = append(servers, BackendServer{
+		servers := []BackendServer{}
-						Name:    serverName,
+
-						Address: addr.IP,
+		if found && len(ep.Subsets) > 0 {
-						Port:    port.Port,
+			for _, subset := range ep.Subsets {
-						Cookie:  cookie,
+				for _, addr := range subset.Addresses {
-					})
+					for _, port := range subset.Ports {
+						if targetPort != 0 && port.Port != targetPort {
+							continue
+						}
+						cookie := hashString(fmt.Sprintf("%s-%s-%d", svc.Metadata.Name, addr.IP, port.Port))
+						serverName := fmt.Sprintf("%s_%d", svc.Metadata.Name, cookie)
+						servers = append(servers, BackendServer{
+							Name:    serverName,
+							Address: addr.IP,
+							Port:    port.Port,
+							Cookie:  cookie,
+						})
+					}
 				}
 			}
 		}
+
 		b.Servers = servers
 		backends = append(backends, b)
 	}
@@ -253,11 +249,11 @@ func main() {
 	if err != nil {
 		log.Fatalf("Failed to get absolute path: %v", err)
 	}
+	
 	tmpl, err := getTemplate(tmplAbsPath)
 	if err != nil {
 		log.Fatalf("Failed to parse template: %v", err)
 	}
-
 	err = tmpl.Execute(os.Stdout, map[string]interface{}{
 		"backends": backends,
 	})