MINOR: add trace logs for endpoints and servers

Author: ivanmatmati

pkg/haproxy/api/runtime.go

@@ -79,11 +79,15 @@ func (c *clientNative) GetMap(mapFile string) (*models.Map, error) {
 
 // SyncBackendSrvs syncs states and addresses of a backend servers with corresponding endpoints.
 func (c *clientNative) SyncBackendSrvs(backend *store.RuntimeBackend, portUpdated bool) error {
+	logger := utils.GetLogger()
 	if backend.Name == "" {
 		return nil
 	}
+	logger.Tracef("updating backend  %s for haproxy servers update (address and state) through socket", backend.Name)
 	haproxySrvs := backend.HAProxySrvs
 	addresses := backend.Endpoints.Addresses
+	logger.Tracef("backend %s: list of servers %+v", backend.Name, haproxySrvs)
+	logger.Tracef("backend %s: list of endpoints addresses %+v", backend.Name, addresses)
 	// Disable stale entries from HAProxySrvs
 	// and provide list of Disabled Srvs
 	var disabled []*store.HAProxySrv
@@ -109,18 +113,22 @@ func (c *clientNative) SyncBackendSrvs(backend *store.RuntimeBackend, portUpdate
 		disabled = disabled[1:]
 		delete(addresses, newAddr)
 	}
+
+	logger.Tracef("backend %s: list of servers after treatment  %+v", backend.Name, haproxySrvs)
+	logger.Tracef("backend %s: list of endpoints addresses after treatment  %+v", backend.Name, addresses)
+
 	// Dynamically updates HAProxy backend servers  with HAProxySrvs content
 	var addrErr, stateErr error
 	for _, srv := range haproxySrvs {
 		if !srv.Modified {
 			continue
 		}
 		if srv.Address == "" {
-			// logger.Tracef("server '%s/%s' changed status to %v", newEndpoints.BackendName, srv.Name, "maint")
+			logger.Tracef("backend %s: server '%s' changed status to %v", backend.Name, srv.Name, "maint")
 			addrErr = c.SetServerAddr(backend.Name, srv.Name, "127.0.0.1", 0)
 			stateErr = c.SetServerState(backend.Name, srv.Name, "maint")
 		} else {
-			// logger.Tracef("server '%s/%s' changed status to %v", newEndpoints.BackendName, srv.Name, "ready")
+			logger.Tracef("backend %s: server '%s' changed status to %v", backend.Name, srv.Name, "ready")
 			addrErr = c.SetServerAddr(backend.Name, srv.Name, srv.Address, int(backend.Endpoints.Port))
 			stateErr = c.SetServerState(backend.Name, srv.Name, "ready")
 		}

pkg/service/endpoints.go

@@ -74,6 +74,7 @@ func (s *Service) updateHAProxySrv(client api.HAProxyClient, srvSlot store.HAPro
 	if s.backend.Cookie != nil && s.backend.Cookie.Type == "insert" {
 		srv.Cookie = srv.Name
 	}
+	logger.Tracef("backend %s: about to update server in configuration file :  models.Server { Name: %s, Port: %d, Address: %s, Maintenance: %s }", s.backend.Name, srv.Name, *srv.Port, srv.Address, srv.Maintenance)
 	// Update server
 	errAPI := client.BackendServerEdit(s.backend.Name, srv)
 	if errAPI == nil {
@@ -106,6 +107,7 @@ func (s *Service) scaleHAProxySrvs(backend *store.RuntimeBackend) (reload bool)
 			break
 		}
 	}
+	logger.Tracef("backend %s: number of slots %d", backend.Name, srvSlots)
 	for len(backend.HAProxySrvs) < srvSlots {
 		srv := &store.HAProxySrv{
 			Name:     fmt.Sprintf("SRV_%d", len(backend.HAProxySrvs)+1),

pkg/store/events.go

@@ -95,13 +95,19 @@ func (k *K8s) EventEndpoints(ns *Namespace, data *Endpoints, syncHAproxySrvs fun
 			return false
 		}
 	}
+	logger.Tracef("Treating endpoints event %+v", *data)
 	ns.Endpoints[data.Service][data.SliceName] = data
 
 	endpoints := getEndpoints(ns.Endpoints[data.Service])
+	logger.Tracef("service %s : endpoints list %+v", data.Service, endpoints)
 	_, ok := ns.HAProxyRuntime[data.Service]
 	if !ok || len(endpoints) == 0 {
 		ns.HAProxyRuntime[data.Service] = make(map[string]*RuntimeBackend)
 	}
+	logger.Tracef("service %s : number of already existing backend(s) in this transaction for this endpoint: %d", data.Service, len(ns.HAProxyRuntime[data.Service]))
+	for key, value := range ns.HAProxyRuntime[data.Service] {
+		logger.Tracef("service %s : port name %s, backend %+v", data.Service, key, *value)
+	}
 	for portName, portEndpoints := range endpoints {
 		newBackend := &RuntimeBackend{Endpoints: portEndpoints}
 		backend, ok := ns.HAProxyRuntime[data.Service][portName]

pkg/store/types.go

@@ -15,6 +15,8 @@
 package store
 
 import (
+	"fmt"
+
 	"github.com/haproxytech/client-native/v3/models"
 )
 
@@ -34,6 +36,10 @@ type HAProxySrv struct {
 	Port     int64
 }
 
+func (h *HAProxySrv) String() string {
+	return fmt.Sprintf("%+v", *h)
+}
+
 // PortEndpoints describes endpoints of a service port
 type PortEndpoints struct {
 	Port      int64