add logs

pkg/service/aerospike_service.go

@@ -41,23 +41,22 @@ func (nv *defaultNamespaceValidator) MissingNamespaces(
 	cluster *model.AerospikeCluster,
 	namespaces []string,
 ) []string {
-	//if len(namespaces) == 0 {
-	return nil
-	//}
-	//
-	//backupClient, err := nv.ClientManager.GetClient(cluster)
-	//if err != nil {
-	//	slog.Info("Failed to connect to aerospike cluster", slog.Any("error", err))
-	//	return nil
-	//}
-	//defer nv.ClientManager.Close(backupClient)
-	//
-	//namespacesInCluster, err := getAllNamespacesOfCluster(backupClient.AerospikeClient())
-	//if err != nil {
-	//	slog.Info("Failed to retrieve namespaces from cluster", slog.Any("error", err))
-	//}
-	//
-	//return util.MissingElements(namespaces, namespacesInCluster)
+	if len(namespaces) == 0 {
+		return nil
+	}
+	backupClient, err := nv.ClientManager.GetClient(cluster)
+	if err != nil {
+		slog.Info("Failed to connect to aerospike cluster", slog.Any("error", err))
+		return nil
+	}
+	defer nv.ClientManager.Close(backupClient)
+
+	namespacesInCluster, err := getAllNamespacesOfCluster(backupClient.AerospikeClient())
+	if err != nil {
+		slog.Info("Failed to retrieve namespaces from cluster", slog.Any("error", err))
+	}
+
+	return util.MissingElements(namespaces, namespacesInCluster)
 }
 
 func (nv *defaultNamespaceValidator) ValidateRoutines(cluster *model.AerospikeCluster, config *model.Config) error {
@@ -89,14 +88,17 @@ func filterRoutinesByCluster(
 
 // getAllNamespacesOfCluster retrieves a list of all namespaces in an Aerospike cluster.
 func getAllNamespacesOfCluster(client backup.AerospikeClient) ([]string, error) {
+	slog.Info("Retrieving namespaces")
 	node, err := client.Cluster().GetRandomNode()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get node: %w", err)
 	}
+	slog.Info("Got node")
 	infoRes, err := node.RequestInfo(&as.InfoPolicy{}, namespaceInfo)
 	if err != nil {
 		return nil, fmt.Errorf("failed to get cluster info: %w", err)
 	}
+	slog.Info("Received response")
 	namespaces := infoRes[namespaceInfo]
 	return strings.Split(namespaces, ";"), nil
 }

pkg/service/client_manager.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"fmt"
+	"log/slog"
 	"sync"
 	"time"
 
@@ -70,13 +71,16 @@ func (cm *ClientManagerImpl) GetClient(cluster *model.AerospikeCluster) (*backup
 			info.closeTimer = nil
 		}
 		info.count++
+		slog.Info("Got client from cache")
 		return info.client, nil
 	}
 
+	slog.Info("Creating new client")
 	client, err := cm.createClient(cluster)
 	if err != nil {
 		return nil, fmt.Errorf("cannot create backup client: %w", err)
 	}
+	slog.Info("Created new client")
 
 	cm.clients[cluster] = &clientInfo{
 		client: client,
@@ -113,8 +117,10 @@ func (cm *ClientManagerImpl) Close(client *backup.Client) {
 
 	for id, info := range cm.clients {
 		if info.client == client {
+			slog.Info("Decreasing client reference counter")
 			info.count--
 			if info.count == 0 {
+				slog.Info("Scheduling client closing")
 				info.closeTimer = cm.scheduleClosing(id)
 			}
 			return
@@ -134,6 +140,7 @@ func (cm *ClientManagerImpl) scheduleClosing(cluster *model.AerospikeCluster) *t
 
 		// Check if the client still exists and count is still 0
 		if info, exists := cm.clients[cluster]; exists && info.count == 0 {
+			slog.Info("Closing unused client")
 			info.client.AerospikeClient().Close()
 			delete(cm.clients, cluster)
 		}