Fix kubernetes cluster initialisation

kgantsov · Sep 6, 2024 · cf1c09f · cf1c09f
1 parent d9e09c1
commit cf1c09f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cmd/server/main.go b/cmd/server/main.go
@@ -64,7 +64,7 @@ func main() {
 	if ServiceName != "" {
 		namespace := "default"
 		serviceDiscovery := cluster.NewServiceDiscoverySRV(namespace, ServiceName)
-		cl := cluster.NewCluster(serviceDiscovery, namespace, ServiceName, httpPort)
+		cl = cluster.NewCluster(serviceDiscovery, namespace, ServiceName, httpPort)
 
 		if err := cl.Init(); err != nil {
 			log.Warn().Msgf("Error initialising a cluster: %s", err)
@@ -89,7 +89,7 @@ func main() {
 	defer db.Close()
 
 	log.Info().Msgf(
-		"Starting node %s with HTTP on %s and Raft on %s %+v", nodeID, httpPort, raftPort, hosts,
+		"Starting node (%s) %s with HTTP on %s and Raft on %s %+v", ServiceName, nodeID, httpPort, raftPort, hosts,
 	)
 	node := raft.NewNode(
 		db, filepath.Join(dataDir, nodeID, "raft"), nodeID, httpPort, raftPort, hosts,