DEV-40217: Support to set log levels and improve logs in argus related projects

Author: jeremy

cmd/watch.go

@@ -113,7 +113,7 @@ func pollCollectorSetStatus(conn *grpc.ClientConn) (bool, error) {
 		case <-timeout:
 			return false, fmt.Errorf("Timeout waiting for collectors to become available")
 		case <-ticker.C:
-			log.Debugf("Start to check the collectors status")
+			log.Debugf("Checking collectors status")
 			ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*500)
 			defer cancel()
 			req := &healthpb.HealthCheckRequest{
@@ -127,7 +127,7 @@ func pollCollectorSetStatus(conn *grpc.ClientConn) (bool, error) {
 			if healthCheckResponse.GetStatus() == healthpb.HealthCheckResponse_SERVING {
 				return true, nil
 			}
-			log.Debugf("The collectors is not ready: %d", healthCheckResponse.GetStatus())
+			log.Debugf("The collectors are not ready: %d", healthCheckResponse.GetStatus())
 		}
 	}
 }

pkg/sync/initsyncer.go

@@ -67,7 +67,7 @@ func (i *InitSyncer) InitSync() {
 		// wait the init sync processes finishing
 		wg.Wait()
 	}
-	log.Infof("Finish syncing the resource devices")
+	log.Infof("Finished syncing the resource devices")
 }
 
 func (i *InitSyncer) intSyncNodes(parentGroupID int32) {

pkg/watch/namespace/namespace.go

@@ -34,7 +34,7 @@ func (w Watcher) ObjType() runtime.Object {
 func (w Watcher) AddFunc() func(obj interface{}) {
 	return func(obj interface{}) {
 		namespace := obj.(*v1.Namespace)
-		log.Debugf("Handle adding namespace event: %s", namespace.Name)
+		log.Debugf("Handling add namespace event: %s", namespace.Name)
 		for name, parentID := range w.DeviceGroups {
 			var appliesTo devicegroup.AppliesToBuilder
 			// Ensure that we are creating namespaces for namespaced resources.
@@ -71,7 +71,7 @@ func (w Watcher) AddFunc() func(obj interface{}) {
 // UpdateFunc is a function that implements the Watcher interface.
 func (w Watcher) UpdateFunc() func(oldObj, newObj interface{}) {
 	return func(oldObj, newObj interface{}) {
-		log.Debugf("Ignore updating namespace event")
+		log.Debugf("Ignoring update namespace event")
 		// oldNamespace := oldObj.(*v1.Namespace)
 		// newNamespace := newObj.(*v1.Namespace)
 	}

pkg/watch/node/node.go

@@ -43,7 +43,7 @@ func (w *Watcher) AddFunc() func(obj interface{}) {
 	return func(obj interface{}) {
 		node := obj.(*v1.Node)
 
-		log.Debugf("Handle adding node event: %s", node.Name)
+		log.Debugf("Handling add node event: %s", node.Name)
 
 		// Require an IP address.
 		if getInternalAddress(node.Status.Addresses) == nil {
@@ -59,7 +59,7 @@ func (w *Watcher) UpdateFunc() func(oldObj, newObj interface{}) {
 		old := oldObj.(*v1.Node)
 		new := newObj.(*v1.Node)
 
-		log.Debugf("Handle updating node event: %s", old.Name)
+		log.Debugf("Handling update node event: %s", old.Name)
 
 		// If the old node does not have an IP, then there is no way we could
 		// have added it to LogicMonitor. Therefore, it must be a new device.
@@ -83,7 +83,7 @@ func (w *Watcher) DeleteFunc() func(obj interface{}) {
 	return func(obj interface{}) {
 		node := obj.(*v1.Node)
 
-		log.Debugf("Handle deleting node event: %s", node.Name)
+		log.Debugf("Handling delete node event: %s", node.Name)
 
 		// Delete the node.
 		if w.Config().DeleteDevices {

pkg/watch/pod/pod.go

@@ -37,7 +37,7 @@ func (w *Watcher) AddFunc() func(obj interface{}) {
 	return func(obj interface{}) {
 		pod := obj.(*v1.Pod)
 
-		log.Debugf("Handle adding pod event: %s", pod.Name)
+		log.Debugf("Handling add pod event: %s", pod.Name)
 
 		// Require an IP address.
 		if pod.Status.PodIP == "" {
@@ -53,7 +53,7 @@ func (w *Watcher) UpdateFunc() func(oldObj, newObj interface{}) {
 		old := oldObj.(*v1.Pod)
 		new := newObj.(*v1.Pod)
 
-		log.Debugf("Handle updating pod event: %s", old.Name)
+		log.Debugf("Handling update pod event: %s", old.Name)
 
 		// If the old pod does not have an IP, then there is no way we could
 		// have added it to LogicMonitor. Therefore, it must be a new w.
@@ -83,7 +83,7 @@ func (w *Watcher) DeleteFunc() func(obj interface{}) {
 	return func(obj interface{}) {
 		pod := obj.(*v1.Pod)
 
-		log.Debugf("Handle deleting pod event: %s", pod.Name)
+		log.Debugf("Handling delete pod event: %s", pod.Name)
 
 		// Delete the pod.
 		if w.Config().DeleteDevices {