removes statsd

gojekfarm · Mar 25, 2024 · d9c0c23 · d9c0c23
1 parent f9ea645
commit d9c0c23
Show file tree

Hide file tree

Showing 6 changed files with 1 addition and 297 deletions.
diff --git a/example/sampleapp/main.go b/example/sampleapp/main.go
@@ -1,5 +1,3 @@
-//go:build ignore
-
 package main
 
 import (
@@ -8,8 +6,6 @@ import (
 	"math/rand"
 	"time"
 
-	"github.com/gojekfarm/ziggurat/v2/mw/statsd"
-
 	"github.com/gojekfarm/ziggurat/v2/kafka"
 	"github.com/gojekfarm/ziggurat/v2/logger"
 	"github.com/gojekfarm/ziggurat/v2/mw/rabbitmq"
@@ -22,10 +18,6 @@ func main() {
 	ctx := context.Background()
 	l := logger.NewLogger(logger.LevelInfo)
 
-	statsClient := statsd.NewPublisher(statsd.WithLogger(l),
-		statsd.WithDefaultTags(statsd.Tags{"ziggurat-version": "v162"}),
-		statsd.WithPrefix("ziggurat_v162"))
-
 	kcg := kafka.ConsumerGroup{
 		Logger: nil,
 		GroupConfig: kafka.ConsumerConfig{
@@ -58,7 +50,7 @@ func main() {
 		return nil
 	})
 
-	h := ziggurat.Use(router, statsClient.PublishEventDelay, statsClient.PublishHandlerMetrics)
+	h := ziggurat.Use(router)
 
 	if runErr := zig.Run(ctx, h, &kcg); runErr != nil {
 		l.Error("error running streams", runErr)

diff --git a/mw/statsd/options.go b/mw/statsd/options.go
diff --git a/mw/statsd/run_test.go b/mw/statsd/run_test.go
diff --git a/mw/statsd/statsd.go b/mw/statsd/statsd.go
diff --git a/mw/statsd/tags.go b/mw/statsd/tags.go
diff --git a/mw/statsd/tags_test.go b/mw/statsd/tags_test.go