remove proto and go-metrics direct dependencies

lovoo · Oct 31, 2018 · 09bf905 · 09bf905
1 parent a83ac41
commit 09bf905
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 15 deletions.
diff --git a/tester/tester.go b/tester/tester.go
@@ -9,8 +9,6 @@ import (
 	"reflect"
 	"sync"
 
-	"github.com/golang/protobuf/proto"
-
 	"github.com/lovoo/goka"
 	"github.com/lovoo/goka/kafka"
 	"github.com/lovoo/goka/storage"
@@ -225,17 +223,6 @@ func (km *Tester) StorageBuilder() storage.Builder {
 	}
 }
 
-// ConsumeProto simulates a message on kafka in a topic with a key.
-func (km *Tester) ConsumeProto(topic string, key string, msg proto.Message) {
-	data, err := proto.Marshal(msg)
-	if err != nil && km.t != nil {
-		km.t.Errorf("Error marshaling message for consume: %v", err)
-	}
-	km.waitStartup()
-	km.pushMessage(topic, key, data)
-	km.waitForConsumers()
-}
-
 // ConsumeString simulates a message with a string payload.
 func (km *Tester) ConsumeString(topic string, key string, msg string) {
 	km.waitStartup()

diff --git a/web/monitor/monitoring.go b/web/monitor/monitoring.go
@@ -13,7 +13,6 @@ import (
 	"net/http"
 
 	"github.com/gorilla/mux"
-	"github.com/rcrowley/go-metrics"
 )
 
 var baseTemplates = append(templates.BaseTemplates, "web/templates/monitor/menu.go.html")
@@ -57,7 +56,6 @@ func (s *Server) BasePath() string {
 type processorStats struct {
 	ID       string
 	ClientID string
-	metrics  metrics.Registry
 }
 
 func (s *Server) AttachProcessor(processor *goka.Processor) {