fix: correct misspellings in identifiers, error messages, and log strings

Signed-off-by: WangYuli <wangyl5933@chinaunicom.cn>

Author: WangYuli

core/events/net_rx_latency.go

@@ -160,7 +160,7 @@ func (c *netRecvLatTracing) Start(ctx context.Context) error {
 		default:
 			var pd netRcvPerfEvent
 			if err := reader.ReadInto(&pd); err != nil {
-				return fmt.Errorf("read rrom perf event fail: %w", err)
+				return fmt.Errorf("read from perf event fail: %w", err)
 			}
 			tracerTime := time.Now()
 

core/metrics/cpu_stat.go

@@ -149,7 +149,7 @@ func (c *cpuStatCollector) Update() ([]*metric.Data, error) {
 	}
 
 	for _, container := range containers {
-		containerDataCache := container.LifeResouces("collector_cpu_stat").(*cpuStat)
+		containerDataCache := container.LifeResources("collector_cpu_stat").(*cpuStat)
 		if err := c.updateDataCache(containerDataCache, container); err != nil {
 			log.Infof("failed to update cpu info of %s, %v", container, err)
 			continue

core/metrics/cpu_util.go

@@ -151,7 +151,7 @@ func (c *cpuUtilCollector) Update() ([]*metric.Data, error) {
 			continue
 		}
 
-		containerDataCache := container.LifeResouces("collector_cpu_util").(*cpuUtilStat)
+		containerDataCache := container.LifeResources("collector_cpu_util").(*cpuUtilStat)
 		if err := c.updateDataCache(containerDataCache, container, numCores); err != nil {
 			log.Infof("failed to update cpu info of %s, %v", container, err)
 			continue

core/metrics/runqlat_tracing.go

@@ -104,7 +104,7 @@ func (c *runqlatCollector) updateContainerDataCache(cssContainers map[uint64]*po
 		}
 
 		buf = bytes.NewReader(v.Value)
-		if err := binary.Read(buf, binary.LittleEndian, container.LifeResouces("runqlat").(*latencyBpfData)); err != nil {
+		if err := binary.Read(buf, binary.LittleEndian, container.LifeResources("runqlat").(*latencyBpfData)); err != nil {
 			return fmt.Errorf("read cpu_tg_metric value: %w", err)
 		}
 	}
@@ -148,7 +148,7 @@ func (c *runqlatCollector) Update() ([]*metric.Data, error) {
 
 	data := []*metric.Data{}
 	for _, container := range containers {
-		cache := container.LifeResouces("runqlat").(*latencyBpfData)
+		cache := container.LifeResources("runqlat").(*latencyBpfData)
 
 		data = append(data,
 			metric.NewContainerGaugeData(container, "latency", float64(cache.NumLatencyZone0), "cpu run queue latency for the containers", map[string]string{"zone": "0"}),

internal/pod/container.go

@@ -49,16 +49,16 @@ type Container struct {
 	StartedAt         time.Time         `json:"started_at"`
 	SyncedAt          time.Time         `json:"synced_at"`
 	Labels            map[string]any    `json:"labels"` // custom labels
-	lifeResouces      map[string]any
+	lifeResources     map[string]any
 }
 
 func (c *Container) String() string {
 	return fmt.Sprintf("%s:%s/%s/%s:%s/%s", c.ID, c.Hostname, c.Name, c.Type, c.Qos, c.IPAddress)
 }
 
-// LifeResouces returns the life resouces of container.
-func (c *Container) LifeResouces(key string) any {
-	return c.lifeResouces[key]
+// LifeResources returns the life resources of container.
+func (c *Container) LifeResources(key string) any {
+	return c.lifeResources[key]
 }
 
 // LabelHostNamespace returns namespace label

internal/pod/container_kubelet_sync.go

@@ -413,7 +413,7 @@ func kubeletUpdateContainer(containerID string, container *corev1.Container, con
 		CgroupCss:         css,
 		StartedAt:         startedAt,
 		SyncedAt:          time.Now(),
-		lifeResouces:      make(map[string]any),
+		lifeResources:     make(map[string]any),
 		Labels:            labels,
 	}
 
@@ -514,7 +514,7 @@ func kubeletConfigCacheUpdate(ctx *PodContainerInitCtx) error {
 
 	config, err = kubeletConfigFileDefault()
 	if err != nil {
-		panic("we cant not find any cgroup driver of kubelet after requesting configz and default files")
+		panic("we cannot find any cgroup driver of kubelet after requesting configz and default files")
 	}
 
 	return nil

internal/pod/container_life_resources.go

@@ -48,7 +48,7 @@ func createContainerLifeResources(c *Container) {
 	lifeResourcesTpl.Range(func(key, anythingType any) bool {
 		// create container life resource
 		typ := anythingType.(reflect.Type)
-		c.lifeResouces[key.(string)] = reflect.New(typ.Elem()).Interface()
+		c.lifeResources[key.(string)] = reflect.New(typ.Elem()).Interface()
 		return true
 	})
 }

internal/services/collector.go

@@ -45,7 +45,7 @@ func CollectorDo(ctx *gin.Context) {
 				Timeout:             30 * time.Second,
 			})
 
-		log.Infof("The prometheus Metrics HTTP server is startting: %v", collectorPromHandler)
+		log.Infof("The prometheus Metrics HTTP server is starting: %v", collectorPromHandler)
 	})
 
 	collectorPromHandler.ServeHTTP(ctx.Writer, ctx.Request)

pkg/tracing/register_event.go

@@ -75,11 +75,11 @@ func NewRegister(blackListed []string) (map[string]*EventTracingAttr, error) {
 				}
 
 				tracingStatusCache[name] = statusInitError
-				err = fmt.Errorf("traing name: %s, err: [%w]", name, err)
+				err = fmt.Errorf("tracing name: %s, err: [%w]", name, err)
 				return
 			}
 			if attr.Flag&(FlagTracing|FlagMetric) == 0 {
-				err = fmt.Errorf("traing name: %s, invalid flag", name)
+				err = fmt.Errorf("tracing name: %s, invalid flag", name)
 				return
 			}