testutils

Documentation

Index

• func ExpectEvent(recorder *record.FakeRecorder, reason string)
• func ExpectEvents(recorder *record.FakeRecorder, reasons ...string)
• func HaveBodyEqualTo(expected interface{}) types.GomegaMatcher
• func HaveStatusCode(expected interface{}) types.GomegaMatcher
• func IgnoreEvents(recorder *record.FakeRecorder)
• func NewFakeInformerFor(obj runtime.Object) (cache.SharedIndexInformer, *framework.FakeControllerSource)
• func RepresentMimeType(expected interface{}) types.GomegaMatcher
• type DataVolumeFeeder
  • func NewDataVolumeFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *DataVolumeFeeder
  • func (v *DataVolumeFeeder) Add(dataVolume *cdiv1.DataVolume)
  • func (v *DataVolumeFeeder) Delete(dataVolume *cdiv1.DataVolume)
  • func (v *DataVolumeFeeder) Modify(dataVolume *cdiv1.DataVolume)
• type DomainFeeder
  • func NewDomainFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *DomainFeeder
  • func (v *DomainFeeder) Add(vmi *api.Domain)
  • func (v *DomainFeeder) Delete(vmi *api.Domain)
  • func (v *DomainFeeder) Modify(vmi *api.Domain)
• type MockWorkQueue
  • func NewMockWorkQueue(queue workqueue.RateLimitingInterface) *MockWorkQueue
  • func (q *MockWorkQueue) Add(obj interface{})
  • func (q *MockWorkQueue) AddRateLimited(item interface{})
  • func (q *MockWorkQueue) ExpectAdds(diff int)
  • func (q *MockWorkQueue) GetRateLimitedEnqueueCount() int
  • func (q *MockWorkQueue) Wait()
• type PodFeeder
  • func NewPodFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *PodFeeder
  • func (v *PodFeeder) Add(pod *k8sv1.Pod)
  • func (v *PodFeeder) Delete(pod *k8sv1.Pod)
  • func (v *PodFeeder) Modify(pod *k8sv1.Pod)
• type VirtualMachineFeeder
  • func NewVirtualMachineFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *VirtualMachineFeeder
  • func (v *VirtualMachineFeeder) Add(vmi *v1.VirtualMachineInstance)
  • func (v *VirtualMachineFeeder) Delete(vmi *v1.VirtualMachineInstance)
  • func (v *VirtualMachineFeeder) Modify(vmi *v1.VirtualMachineInstance)

Functions

func ExpectEvent

func ExpectEvent(recorder *record.FakeRecorder, reason string)

func ExpectEvents

func ExpectEvents(recorder *record.FakeRecorder, reasons ...string)

ExpectEvents checks for given reasons in arbitrary order

func HaveBodyEqualTo

func HaveBodyEqualTo(expected interface{}) types.GomegaMatcher

func HaveStatusCode

func HaveStatusCode(expected interface{}) types.GomegaMatcher

func IgnoreEvents

func IgnoreEvents(recorder *record.FakeRecorder)

In case we don't care about emitted events, we simply consume all of them and return.

func NewFakeInformerFor

func NewFakeInformerFor(obj runtime.Object) (cache.SharedIndexInformer, *framework.FakeControllerSource)

func RepresentMimeType

func RepresentMimeType(expected interface{}) types.GomegaMatcher

Types

type DataVolumeFeeder

type DataVolumeFeeder struct {
	MockQueue *MockWorkQueue
	Source    *framework.FakeControllerSource
}

func NewDataVolumeFeeder

func NewDataVolumeFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *DataVolumeFeeder

func (*DataVolumeFeeder) Add

func (v *DataVolumeFeeder) Add(dataVolume *cdiv1.DataVolume)

func (*DataVolumeFeeder) Delete

func (v *DataVolumeFeeder) Delete(dataVolume *cdiv1.DataVolume)

func (*DataVolumeFeeder) Modify

func (v *DataVolumeFeeder) Modify(dataVolume *cdiv1.DataVolume)

type DomainFeeder

type DomainFeeder struct {
	MockQueue *MockWorkQueue
	Source    *framework.FakeControllerSource
}

func NewDomainFeeder

func NewDomainFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *DomainFeeder

func (*DomainFeeder) Add

func (v *DomainFeeder) Add(vmi *api.Domain)

func (*DomainFeeder) Delete

func (v *DomainFeeder) Delete(vmi *api.Domain)

func (*DomainFeeder) Modify

func (v *DomainFeeder) Modify(vmi *api.Domain)

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)
vmiSource.Add(vmi)
vmiSource.Add(vmi1)
vmiSource.Add(vmi2)
MockQueue.Wait()

This ensures that Source callbacks which are listening on vmiSource 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

func NewMockWorkQueue(queue workqueue.RateLimitingInterface) *MockWorkQueue

func (*MockWorkQueue) Add

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

func (*MockWorkQueue) AddRateLimited

func (q *MockWorkQueue) AddRateLimited(item interface{})

func (*MockWorkQueue) ExpectAdds

func (q *MockWorkQueue) ExpectAdds(diff int)

ExpectAdds allows setting the amount of expected enqueues.

func (*MockWorkQueue) GetRateLimitedEnqueueCount

func (q *MockWorkQueue) GetRateLimitedEnqueueCount() int

func (*MockWorkQueue) Wait

func (q *MockWorkQueue) Wait()

Wait waits until the expected amount of ExpectedAdds has happened. It will not block if there were no expectations set.

type PodFeeder

type PodFeeder struct {
	MockQueue *MockWorkQueue
	Source    *framework.FakeControllerSource
}

func NewPodFeeder

func NewPodFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *PodFeeder

func (*PodFeeder) Add

func (v *PodFeeder) Add(pod *k8sv1.Pod)

func (*PodFeeder) Delete

func (v *PodFeeder) Delete(pod *k8sv1.Pod)

func (*PodFeeder) Modify

func (v *PodFeeder) Modify(pod *k8sv1.Pod)

type VirtualMachineFeeder

type VirtualMachineFeeder struct {
	MockQueue *MockWorkQueue
	Source    *framework.FakeControllerSource
}

func NewVirtualMachineFeeder

func NewVirtualMachineFeeder(queue *MockWorkQueue, source *framework.FakeControllerSource) *VirtualMachineFeeder

func (*VirtualMachineFeeder) Add

func (v *VirtualMachineFeeder) Add(vmi *v1.VirtualMachineInstance)

func (*VirtualMachineFeeder) Delete

func (v *VirtualMachineFeeder) Delete(vmi *v1.VirtualMachineInstance)

func (*VirtualMachineFeeder) Modify

func (v *VirtualMachineFeeder) Modify(vmi *v1.VirtualMachineInstance)