Function TestProcessNextItem

internal/pkg/controller/controller_test.go:703–745

(t *testing.T)

}

func TestProcessNextItem(t *testing.T) {
	tests := []struct {
		name           string
		handler        *mockResourceHandler
		expectContinue bool
		expectCalls    int
	}{
		{
			name: "Successful handler execution",
			handler: &mockResourceHandler{
				handleErr:   nil,
				enqueueTime: time.Now().Add(-10 * time.Millisecond),
			},
			expectContinue: true,
			expectCalls:    1,
		},
		{
			name: "Handler returns error",
			handler: &mockResourceHandler{
				handleErr:   errors.New("test error"),
				enqueueTime: time.Now().Add(-10 * time.Millisecond),
			},
			expectContinue: true,
			expectCalls:    1,
		},
	}

	for _, tt := range tests {
		t.Run(
			tt.name, func(t *testing.T) {
				resetGlobalState()
				c := newTestController([]string{}, "")

				c.queue.Add(tt.handler)

				result := c.processNextItem()

				assert.Equal(t, tt.expectContinue, result)
				assert.Equal(t, tt.expectCalls, tt.handler.handleCalls)
			},
		)
	}
}

func TestProcessNextItemQueueShutdown(t *testing.T) {
	resetGlobalState()