Delay key proc sampler (#160)

Add unit test for newV3KeyProcessor

rules/key_processor.go

@@ -121,14 +121,14 @@ func (v3kp *v3KeyProcessor) processKey(key string, value *string, api readAPI, l
 
 func (v3kp *v3KeyProcessor) bufferCapacitySampler(logger *zap.Logger) {
 	for {
+		time.Sleep(time.Minute)
 		remainingBuffer := cap(v3kp.kpChannel) - len(v3kp.kpChannel)
 		metrics.KeyProcessBufferCap(remainingBuffer)
 		currentHour := time.Now().UTC().Hour()
 		if (float32(remainingBuffer)/float32(cap(v3kp.kpChannel))) < 0.05 && v3kp.lastNotified != currentHour {
 			logger.Warn("Rules engine buffer is near capacity", zap.Int("capacity", cap(v3kp.kpChannel)), zap.Int("remaining", remainingBuffer))
 			v3kp.lastNotified = currentHour
 		}
-		time.Sleep(time.Minute)
 	}
 }
 

rules/key_processor_test.go

@@ -2,6 +2,7 @@ package rules
 
 import (
 	"testing"
+	"time"
 
 	"github.com/stretchr/testify/assert"
 	"go.uber.org/zap"
@@ -77,3 +78,26 @@ func TestV3KeyProcessor(t *testing.T) {
 	work := <-channel
 	assert.Equal(t, "/test/lock/key", work.lockKey)
 }
+
+func TestNewV3KeyProcessor(t *testing.T) {
+	value := "value"
+	rule, err := NewEqualsLiteralRule("/test/:key", &value)
+	assert.NoError(t, err)
+	rm := newRuleManager(map[string]constraint{}, false)
+	rm.addRule(rule)
+	api := newMapReadAPI()
+	api.put("/test/key", value)
+
+	channel := make(chan v3RuleWork)
+	kpChannel := make(chan *keyTask, 1000)
+	logger := getTestLogger()
+	kp := newV3KeyProcessor(channel, &rm, kpChannel, 1, logger)
+	kp.setCallback(0, V3RuleTaskCallback(v3DummyCallback))
+	kp.setContextProvider(0, defaultContextProvider)
+	kp.setRuleID(0, "testKey")
+	kp.setLockKeyPattern(0, "/test/lock/:key")
+	go kp.processKey("/test/key", &value, api, logger, map[string]string{}, nil)
+	time.Sleep(time.Second)
+	work := <-channel
+	assert.Equal(t, "/test/lock/key", work.lockKey)
+}