Function TestHasReachedMaxRetryAttempt

cmd/workers_test.go:10–34

(t *testing.T)

)

func TestHasReachedMaxRetryAttempt(t *testing.T) {
	cfg := &config.Configuration{
		Queue: config.QueueConfig{
			MaxRetryAttempts: 5,
		},
	}

	tests := []struct {
		name       string
		retryCount int
		want       bool
	}{
		{name: "below max", retryCount: 4, want: false},
		{name: "at max", retryCount: 5, want: true},
		{name: "above max", retryCount: 6, want: true},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			if got := hasReachedMaxRetryAttempt(cfg, tt.retryCount); got != tt.want {
				t.Fatalf("hasReachedMaxRetryAttempt() = %v, want %v", got, tt.want)
			}
		})
	}
}

func TestShouldRejectLockContentionImmediately(t *testing.T) {
	cfg := &config.Configuration{