Function writeValuesToKV

kv/consul/client_test.go:18–31

(t *testing.T, client *Client, key string, start, end int, sleep time.Duration)

)

func writeValuesToKV(t *testing.T, client *Client, key string, start, end int, sleep time.Duration) <-chan struct{} {
	t.Helper()

	ch := make(chan struct{})
	go func() {
		defer close(ch)
		for i := start; i <= end; i++ {
			t.Log("ts", time.Now(), "msg", "writing value", "val", i)
			_, _ = client.kv.Put(&consul.KVPair{Key: key, Value: []byte(fmt.Sprintf("%d", i))}, nil)
			time.Sleep(sleep)
		}
	}()
	return ch
}

func TestWatchKeyWithRateLimit(t *testing.T) {
	c, closer := NewInMemoryClientWithConfig(codec.String{}, Config{