Fix debug level logs log-level

kysre · Feb 10, 2024 · 4e6794f · 4e6794f
1 parent 36e7271
commit 4e6794f
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 13 deletions.
diff --git a/leader/cmd/tasks/datanode_data_sync.go b/leader/cmd/tasks/datanode_data_sync.go
@@ -53,7 +53,7 @@ func (s *DataNodeDataSyncer) SyncData(failedDataNode *models.DataNode) {
 	if !s.shouldSync {
 		return
 	}
-	s.logger.Info(fmt.Sprintf("Start datasync for datanode[%d]", failedDataNode.ID))
+	s.logger.Debug(fmt.Sprintf("Start datasync for datanode[%d]", failedDataNode.ID))
 	// Create context for requests
 	ctx, cancel := context.WithTimeout(context.Background(), time.Duration(s.dataSyncTimeout)*time.Second)
 	defer cancel()
@@ -106,7 +106,7 @@ func (s *DataNodeDataSyncer) SyncData(failedDataNode *models.DataNode) {
 	s.dataNodeDirectory.UpdateDataNodeState(failedDataNode.ID, models.DataNodeStateUNHEALTHY)
 	s.dataNodeDirectory.UpdateDataNodeState(prevDataNode.ID, models.DataNodeStateAVAILABLE)
 	s.dataNodeDirectory.UpdateDataNodeState(afterDataNode.ID, models.DataNodeStateAVAILABLE)
-	s.logger.Info(fmt.Sprintf("Done datasync for datanode[%d]", failedDataNode.ID))
+	s.logger.Debug(fmt.Sprintf("Done datasync for datanode[%d]", failedDataNode.ID))
 }
 
 func (s *DataNodeDataSyncer) pushMessagesToDataNode(

diff --git a/leader/cmd/tasks/datanode_health_check.go b/leader/cmd/tasks/datanode_health_check.go
@@ -34,7 +34,7 @@ func (hc *DataNodeHealthChecker) RunHealthChecks() {
 	for {
 		select {
 		case <-ticker.C:
-			logrus.Info("Running DataNode health-check")
+			logrus.Debug("Running DataNode health-check")
 			hc.checkNodes()
 		}
 	}

diff --git a/leader/cmd/tasks/datanode_remaining_check.go b/leader/cmd/tasks/datanode_remaining_check.go
@@ -16,7 +16,7 @@ func RunRemainingCheck(dataNodeDirectory *models.DataNodeDirectory, remainingChe
 	for {
 		select {
 		case <-ticker.C:
-			logrus.Info("Running DataNode remaining-check")
+			logrus.Debug("Running DataNode remaining-check")
 			updateNodesRemaining(dataNodeDirectory)
 		}
 	}

diff --git a/leader/cmd/tasks/leader_sync.go b/leader/cmd/tasks/leader_sync.go
@@ -31,7 +31,7 @@ func NewLeaderSyncer(
 }
 
 func (ls *LeaderSyncer) RunLeaderSync() {
-	ls.logger.Info("Running leader sync")
+	ls.logger.Debug("Running leader sync")
 	tickerPeriod := time.Duration(ls.period) * time.Second
 	ticker := time.NewTicker(tickerPeriod)
 	for {

diff --git a/leader/internal/app/core/queue_core.go b/leader/internal/app/core/queue_core.go
@@ -46,8 +46,8 @@ func (c *queueCore) Push(
 		c.logger.Error(err)
 		return nil, err
 	}
-	c.logger.Info(fmt.Sprintf("Push key: %s to DataNode %v", key, dataNodeClient))
-	c.logger.Info(fmt.Sprintf("Push key: %s to DataNodeReplica %v", key, dataNodeReplicaClient))
+	c.logger.Debug(fmt.Sprintf("Push key: %s to DataNode %v", key, dataNodeClient))
+	c.logger.Debug(fmt.Sprintf("Push key: %s to DataNodeReplica %v", key, dataNodeReplicaClient))
 	// Create grpc requests
 	messagePb := datanode.QueueMessage{Key: key}
 	messagePb.Value = append(messagePb.Value, request.GetValue()...)
@@ -75,14 +75,14 @@ func (c *queueCore) Pull(
 	c.collectRpsMetrics("Pull")
 	defer c.collectLatencyMetrics("Pull", startTime)
 
-	c.logger.Info("Received Pull request")
+	c.logger.Debug("Received Pull request")
 	// Get datanode
 	client, err := c.balancer.GetPullDataNodeClient(ctx)
 	if err != nil {
 		c.logger.Error(err)
 		return nil, err
 	}
-	c.logger.Info(fmt.Sprintf("Pull req datanode client: %v", client))
+	c.logger.Debug(fmt.Sprintf("Pull req datanode client: %v", client))
 	// Get pull response
 	dataNodeRes, err := client.Pull(ctx, request)
 	if err != nil {
@@ -91,7 +91,7 @@ func (c *queueCore) Pull(
 	}
 	// Return response in correct format
 	message := dataNodeRes.GetMessage()
-	c.logger.Info(fmt.Sprintf("Pull response with key: %s", message.GetKey()))
+	c.logger.Debug(fmt.Sprintf("Pull response with key: %s", message.GetKey()))
 	response := queue.PullResponse{Key: message.GetKey()}
 	response.Value = append(response.Value, message.GetValue()...)
 	return &response, nil
@@ -106,15 +106,15 @@ func (c *queueCore) AcknowledgePull(
 	defer c.collectLatencyMetrics("Ack", startTime)
 
 	key := request.GetKey()
-	c.logger.Info(fmt.Sprintf("Received Ack Pull key=%s", key))
+	c.logger.Debug(fmt.Sprintf("Received Ack Pull key=%s", key))
 	// Get datanode & it's replica client
 	dataNodeClient, dataNodeReplicaClient, err := c.balancer.GetPushDataNodeAndReplicaClient(ctx, key)
 	if err != nil {
 		c.logger.Error(err)
 		return nil, err
 	}
-	c.logger.Info(fmt.Sprintf("Ack key: %s to DataNode %v", key, dataNodeClient))
-	c.logger.Info(fmt.Sprintf("Ack key: %s to DataNodeReplica %v", key, dataNodeReplicaClient))
+	c.logger.Debug(fmt.Sprintf("Ack key: %s to DataNode %v", key, dataNodeClient))
+	c.logger.Debug(fmt.Sprintf("Ack key: %s to DataNodeReplica %v", key, dataNodeReplicaClient))
 	// Create requests & send Ack to datanode & it's replica
 	dataNodeReq := datanode.AcknowledgePullRequest{Key: key, IsReplica: false}
 	dataNodeReplicaReq := datanode.AcknowledgePullRequest{Key: key, IsReplica: true}