refactor for updating

Author: CMGS

3rdmocks/ServerStream.go

@@ -18,8 +18,7 @@ grpc:
 	./rpc/gen/core.proto
 
 deps:
-	env GO111MODULE=on go mod download
-	env GO111MODULE=on go mod vendor
+	go mod vendor
 
 binary:
 	CGO_ENABLED=0 go build -ldflags "$(GO_LDFLAGS)" -gcflags=all=-G=3 -o eru-core

Makefile

@@ -93,22 +93,22 @@ func (m *Metrics) SendMetrics(metrics ...*resources.Metrics) {
 			log.Errorf(nil, "[SendMetrics] Collector not found: %s", metric.Name) //nolint
 			continue
 		}
-		switch collector.(type) { // nolint: gocritic
+		switch collector.(type) { // nolint
 		case *prometheus.GaugeVec:
 			value, err := strconv.ParseFloat(metric.Value, 64)
 			if err != nil {
 				log.Errorf(nil, "[SendMetrics] Error occurred while parsing %v value %v: %v", metric.Name, metric.Value, err) //nolint
 			}
-			collector.(*prometheus.GaugeVec).WithLabelValues(metric.Labels...).Set(value)
+			collector.(*prometheus.GaugeVec).WithLabelValues(metric.Labels...).Set(value) // nolint
 			if err := m.gauge(metric.Key, value); err != nil {
 				log.Errorf(nil, "[SendMetrics] Error occurred while sending %v data to statsd: %v", metric.Name, err) //nolint
 			}
 		case *prometheus.CounterVec:
-			value, err := strconv.ParseInt(metric.Value, 10, 32)
+			value, err := strconv.ParseInt(metric.Value, 10, 32) // nolint
 			if err != nil {
 				log.Errorf(nil, "[SendMetrics] Error occurred while parsing %v value %v: %v", metric.Name, metric.Value, err) //nolint
 			}
-			collector.(*prometheus.CounterVec).WithLabelValues(metric.Labels...).Add(float64(value))
+			collector.(*prometheus.CounterVec).WithLabelValues(metric.Labels...).Add(float64(value)) // nolint
 			if err := m.count(metric.Key, int(value), 1.0); err != nil {
 				log.Errorf(nil, "[SendMetrics] Error occurred while sending %v data to statsd: %v", metric.Name, err) //nolint
 			}

cluster/mocks/Cluster.go

@@ -25,7 +25,6 @@ func NewPluginManager(config types.Config) (*PluginManager, error) {
 		config:  config,
 		plugins: []Plugin{},
 	}
-
 	return pm, nil
 }
 
@@ -56,19 +55,6 @@ func (pm *PluginManager) GetPlugins() []Plugin {
 	return pm.plugins
 }
 
-func (pm *PluginManager) callPlugins(plugins []Plugin, f func(Plugin)) {
-	wg := &sync.WaitGroup{}
-	wg.Add(len(plugins))
-
-	for _, plugin := range plugins {
-		go func(p Plugin) {
-			defer wg.Done()
-			f(p)
-		}(plugin)
-	}
-	wg.Wait()
-}
-
 func callPlugins[T any](ctx context.Context, plugins []Plugin, f func(Plugin) (T, error)) (map[Plugin]T, error) {
 	resMap := sync.Map{}
 	combinedErr := types.NewCombinedErr()

engine/docker/mocks/APIClient.go

@@ -23,10 +23,7 @@ func ListAllExecutableFiles(basedir string) ([]string, error) {
 		return nil
 	})
 
-	if err != nil {
-		return nil, err
-	}
-	return files, nil
+	return files, err
 }
 
 func isExecutable(perm fs.FileMode) bool {