rebase fixes

justtrackio · Feb 10, 2021 · d0d6a58 · d0d6a58
1 parent 688f6da
commit d0d6a58
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 14 deletions.
diff --git a/pkg/cfg/options_test.go b/pkg/cfg/options_test.go
@@ -74,7 +74,7 @@ func (s *OptionsTestSuite) TestWithConfigSetting() {
 
 	actual = s.config.Get("a")
 	expectedMsi = expected.Msi()
-	s.Equal(expected.Msi(), actual)
+	s.Equal(expectedMsi, actual)
 }
 
 func TestOptionsTestSuite(t *testing.T) {

diff --git a/pkg/stream/mpr_metric_module.go b/pkg/stream/mpr_metric_module.go
@@ -19,18 +19,6 @@ const (
 	metricNameStreamMprMessagesPerRunner = "StreamMprMessagesPerRunner"
 )
 
-type mprMetricPerConsumer map[string]float64
-
-func (d mprMetricPerConsumer) Sum() float64 {
-	sum := 0.0
-
-	for _, v := range d {
-		sum += v
-	}
-
-	return sum
-}
-
 type MessagesPerRunnerMetricWriterSettings struct {
 	ConsumerSpecs      []*ConsumerSpec
 	UpdatePeriod       time.Duration
@@ -48,7 +36,7 @@ func MessagesPerRunnerMetricWriterFactory(config cfg.Config, logger mon.Logger)
 		return modules, nil
 	}
 
-	moduleName := fmt.Sprintf("stream-metric-messages-per-runner")
+	moduleName := "stream-metric-messages-per-runner"
 	modules[moduleName] = NewMessagesPerRunnerMetricWriter(settings)
 
 	return modules, nil