testing

type MockWorkQueue ¶

type MockWorkQueue struct {
	workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

MockWorkQueue is a helper workqueue which can be wrapped around any RateLimitingInterface implementing queue. This allows synchronous testing of the controller. The typical pattern is:

mockQueue.ExpectAdd(3)
vmSource.Add(vm)
vmSource.Add(vm1)
vmSource.Add(vm2)
mockQueue.Wait()

This ensures that informer callbacks which are listening on vmSource enqueued three times an object. Since enqueing is typically the last action in listener callbacks, we can assume that the wanted scenario for a controller is set up, and an execution will process this scenario.

func NewMockWorkQueue(queue workqueue.RateLimitingInterface) *MockWorkQueue

func (q *MockWorkQueue) Add(obj interface{})

func (q *MockWorkQueue) ExpectAdds(diff int)

func (q *MockWorkQueue) Wait()