Function TestLock_Refresh_retry_transient_error

redislock_test.go:263–285

(t *testing.T)

}

func TestLock_Refresh_retry_transient_error(t *testing.T) {
	rc := redisConnect(t)
	flaky := &flakyScripter{Client: rc.Client}
	client := New(flaky)

	lock, err := client.Obtain(t.Context(), rc.lockKey(), time.Hour, nil)
	if err != nil {
		t.Fatal(err)
	}
	defer lock.Release(t.Context())

	// fail the next 2 refresh attempts; the 3rd should succeed.
	flaky.fails.Store(2)
	if err := lock.Refresh(t.Context(), time.Minute, &Options{
		RetryStrategy: LimitRetry(LinearBackoff(5*time.Millisecond), 5),
	}); err != nil {
		t.Fatalf("expected refresh to recover, got %v", err)
	}
	if remaining := flaky.fails.Load(); remaining != 0 {
		t.Fatalf("expected all injected failures to be consumed, %d remaining", remaining)
	}
	assertTTL(t, lock, time.Minute)
}

func TestLock_Refresh_retry_transient_error_exhausted(t *testing.T) {
	rc := redisConnect(t)