Function TestJoinMembersWithRetryBackoff

kv/memberlist/memberlist_client_test.go:1053–1194

(t *testing.T)

}

func TestJoinMembersWithRetryBackoff(t *testing.T) {

	c := dataCodec{}

	const members = 3
	const key = "ring"

	tests := map[string]struct {
		dnsDelayForFirstKV int
		startDelayForRest  time.Duration
		queryType          string
	}{
		"Test late start of members with fast join": {
			dnsDelayForFirstKV: 0,
			startDelayForRest:  1 * time.Second,
			queryType:          "",
		},
		"Test late start of members with DNS lookup": {
			dnsDelayForFirstKV: 0,
			startDelayForRest:  1 * time.Second,
			queryType:          "dns+",
		},
		"Test late start of DNS service": {
			dnsDelayForFirstKV: 5, // fail DNS lookup for 5 times (fast join and first couple of normal join DNS lookups)
			startDelayForRest:  0,
			queryType:          "dns+",
		},
	}

	for testName, testData := range tests {
		testData := testData

		t.Run(testName, func(t *testing.T) {
			t.Parallel()

			var clients []*Client

			stop := make(chan struct{})
			start := make(chan struct{})

			ports, err := getFreePorts(members)
			require.NoError(t, err)

			watcher := services.NewFailureWatcher()
			go func() {
				for {
					select {
					case err := <-watcher.Chan():
						t.Errorf("service reported error: %v", err)
					case <-stop:
						return
					}
				}
			}()

			kvsStarted := &sync.WaitGroup{}
			for i, port := range ports {
				id := fmt.Sprintf("Member-%d", i)