haproxy.go

package main

import (
	"bufio"
	"fmt"
	"net"
	"os"
	"slices"
	"strings"
)

type Server struct {
	PXname string
	Name   string
	IP     string
	Port   string
	Status string
	Weight string
}

func main() {
	servers := fetchservers()
	fmt.Println(sortservers(servers))
}

func fetchservers() []Server {
	myserver := []Server{}

	// Connect to HAProxy admin.socket
	conn, err := net.Dial("unix", "/var/run/haproxy/admin.sock")
	if err != nil {
		fmt.Fprintln(os.Stderr, "Error connecting to HAProxy socket:", err)
		return nil
	}
	defer conn.Close()

	// Send the "show stat" command to retrieve server stats
	fmt.Fprintln(conn, "show stat")

	scanner := bufio.NewScanner(conn)
	for scanner.Scan() {
		line := scanner.Text()
		if line == "" || strings.HasPrefix(line, "#") {
			continue
		}

		fields := strings.Split(line, ",")
		if len(fields) < 34 {
			continue
		}

		//fmt.Println(fields)
		//if fields[1] != "BACKEND" && fields[1] != "FRONTEND" {
		// Extracting relevant fields from the CSV output
		pxname := fields[0]
		server := fields[1]
		status := fields[17]
		//lastChk := fields[18]
		//checkHealth := fields[39]
		//downtime := fields[13]
		weight := fields[6]
		addr := fields[73]
		ipport := strings.Split(addr, ":")
		ip := ""
		port := ""
		if len(ipport) == 2 {
			ip = ipport[0]
			port = ipport[1]
		}
		//currentSessions := fields[4]
		//maxSessions := fields[5]
		newserver := Server{PXname: pxname, Name: server, IP: ip, Port: port, Status: status, Weight: weight}
		myserver = append(myserver, newserver)

		//}

	}
	//for _, srv := range myserver {
	//    return srv
	//    fmt.Println(srv)
	//    }
	if err := scanner.Err(); err != nil {
		fmt.Fprintln(os.Stderr, "Error reading from HAProxy socket:", err)
		return nil
	}
	return myserver
}
func sortservers(server []Server) ([]Server, []Server, []Server) {
	frontends := []Server{}
	backends := []Server{}
	servers := []Server{}

	for _, s := range server {
		if s.Name == "FRONTEND" && s.PXname != "stats" {
			frontends = append(frontends, s)
		}
		if s.Name == "BACKEND" && s.PXname != "stats" {
			backends = append(backends, s)
		}
		if !slices.Contains(frontends, s) && !slices.Contains(backends, s) && s.PXname != "stats" {
			servers = append(servers, s)
		}
	}
	return frontends, backends, servers
}