refactor(events): remove unused meter initialization in Analyze and startQueue functions

Author: osmontero

plugins/events/main.go

@@ -118,9 +118,6 @@ func main() {
 }
 
 func (p *analysisServer) Analyze(event *plugins.Event, _ grpc.ServerStreamingServer[plugins.Alert]) error {
-	m := utils.NewMeter("Enqueue log for OpenSearch")
-	defer m.Elapsed("finished")
-
 	jLog, err := utils.ToString(event)
 	if err != nil {
 		return catcher.Error("cannot convert event to json", err, nil)

plugins/events/queue.go

@@ -3,13 +3,13 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/threatwinds/go-sdk/catcher"
-	"github.com/threatwinds/go-sdk/plugins"
-	"github.com/threatwinds/go-sdk/utils"
 	"runtime"
 	"sync"
 	"time"
 
+	"github.com/threatwinds/go-sdk/catcher"
+	"github.com/threatwinds/go-sdk/plugins"
+
 	"github.com/threatwinds/go-sdk/opensearch"
 	"github.com/tidwall/gjson"
 )
@@ -60,16 +60,6 @@ func startQueue() {
 	numCPU := runtime.NumCPU() * 2
 	for i := 0; i < numCPU; i++ {
 		go func() {
-			ndM := utils.NewMeter("NDJson", utils.MeterOptions{
-				LogSlow:       true,
-				SlowThreshold: 20 * time.Millisecond,
-			})
-
-			bulkM := utils.NewMeter("Bulk", utils.MeterOptions{
-				LogSlow:       true,
-				SlowThreshold: 1 * time.Second,
-			})
-
 			var ndMutex = &sync.Mutex{}
 			var nd = make([]opensearch.BulkItem, 0, 10)
 
@@ -81,7 +71,6 @@ func startQueue() {
 					}
 
 					ndMutex.Lock()
-					bulkM.Reset()
 
 					err := opensearch.Bulk(context.Background(), nd)
 					if err != nil {
@@ -91,23 +80,17 @@ func startQueue() {
 					nd = make([]opensearch.BulkItem, 0, 10)
 
 					ndMutex.Unlock()
-					bulkM.Elapsed("bulk sent")
 				}
 			}()
 
 			for {
 				l := <-logs
 
-				ndM.Reset()
-
 				dataType := gjson.Get(l, "dataType").String()
 				id := gjson.Get(l, "id").String()
 				index := opensearch.BuildCurrentIndex("v11", "log", dataType)
 
-				ndM.Elapsed("get index and id")
-
 				ndMutex.Lock()
-				ndM.Reset()
 
 				nd = append(nd, opensearch.BulkItem{
 					Index:  index,
@@ -117,7 +100,6 @@ func startQueue() {
 				})
 
 				ndMutex.Unlock()
-				ndM.Elapsed("append to NDJson list")
 			}
 		}()
 	}

plugins/geolocation/main.go

@@ -122,9 +122,6 @@ func main() {
 }
 
 func (p *parsingServer) ParseLog(_ context.Context, transform *plugins.Transform) (*plugins.Draft, error) {
-	m := utils.NewMeter("ParseLog")
-	defer m.Elapsed("finished")
-
 	source, ok := transform.Step.Dynamic.Params["source"]
 	if !ok {
 		return transform.Draft, catcher.Error("'source' parameter required", nil, nil)