feat: operator 新增 kubelet 日志打印逻辑 --story=119827827 (#553)

TencentBlueKing · Sep 23, 2024 · 55b1ad3 · 55b1ad3
1 parent 8a57d1f
commit 55b1ad3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/pkg/operator/configs/configs.go b/pkg/operator/configs/configs.go
@@ -10,6 +10,7 @@
 package configs
 
 import (
+	"fmt"
 	"os"
 
 	"gopkg.in/yaml.v2"
@@ -70,6 +71,10 @@ type Kubelet struct {
 	Name      string `yaml:"name"`
 }
 
+func (k Kubelet) String() string {
+	return fmt.Sprintf("%s/%s", k.Namespace, k.Name)
+}
+
 // HTTP http 服务配置
 type HTTP struct {
 	Port int    `yaml:"port"`

diff --git a/pkg/operator/operator/kubelet.go b/pkg/operator/operator/kubelet.go
@@ -122,11 +122,13 @@ func (c *Operator) syncNodeEndpoints(ctx context.Context) error {
 	if err != nil {
 		return errors.Wrap(err, "synchronizing kubelet service object failed")
 	}
+	logger.Infof("sync kubelet service %s", configs.G().Kubelet)
 
 	err = k8sutils.CreateOrUpdateEndpoints(ctx, c.client.CoreV1().Endpoints(configs.G().Kubelet.Namespace), eps)
 	if err != nil {
 		return errors.Wrap(err, "synchronizing kubelet endpoints object failed")
 	}
+	logger.Infof("sync kubelet endpoints %s, address count (%d)", configs.G().Kubelet, len(addresses))
 
 	return nil
 }