Benchmark added

balancing/balance_breaker_test.go

@@ -437,3 +437,21 @@ func TestLengthDelimitedCounter(t *testing.T) {
 	wg.Wait()
 	require.Equal(t, sum, counter.Sum())
 }
+
+func BenchmarkCallMetrics(b *testing.B) {
+	clockAdvance := 4 * time.Millisecond
+	timer := &mockTimer{
+		baseTime:   time.Now(),
+		advanceDur: clockAdvance}
+	retention := 20 * time.Second
+	resolution := 10 * time.Second
+	callMeter := newCallMeterWithTimer(retention, resolution, timer.now)
+	iterations := int(retention / clockAdvance)
+	for i := 0; i < iterations; i++ {
+		callMeter.UpdateTimeSpent(10 * time.Millisecond)
+	}
+	for n := 0; n < b.N; n++ {
+		callMeter.TimeSpent()
+		callMeter.Calls()
+	}
+}

config/validator.go

@@ -67,8 +67,6 @@ func (c *YamlConfig) validateRegionCluster(policyName string, policies confregio
 	}
 
 	for _, policy := range policies.Shards {
-		println("dupa")
-		fmt.Printf("sharding policies %v\n", c.Shards)
 		_, exists := c.Shards[policy.ShardName]
 		if !exists {
 			errList = append(errList, fmt.Errorf("Shard \"%s\" in policy \"%s\" is not defined", policy.ShardName, policyName))