FakeControllerSource implements listing/watching for testing.
type FakeControllerSource struct {
Items map[nnu]runtime.Object
Broadcaster *watch.Broadcaster
// Set this to simulate an error on List()
ListError error
// contains filtered or unexported fields
}
func NewFakeControllerSource() *FakeControllerSource
func (f *FakeControllerSource) Add(obj runtime.Object)
Add adds an object to the set and sends an add event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) AddDropWatch(obj runtime.Object)
AddDropWatch adds an object to the set but forgets to send an add event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) Change(e watch.Event, watchProbability float64)
Change records the given event (setting the object's resource version) and sends a watch event with the specified probability.
func (f *FakeControllerSource) Delete(lastValue runtime.Object)
Delete deletes an object from the set and sends a delete event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) DeleteDropWatch(lastValue runtime.Object)
DeleteDropWatch deletes an object from the set but forgets to send a delete event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) List(options metav1.ListOptions) (runtime.Object, error)
List returns a list object, with its resource version set.
func (f *FakeControllerSource) Modify(obj runtime.Object)
Modify updates an object in the set and sends a modified event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) ModifyDropWatch(obj runtime.Object)
ModifyDropWatch updates an object in the set but forgets to send a modify event to watchers. obj's ResourceVersion is set.
func (f *FakeControllerSource) ResetWatch()
ResetWatch simulates connection problems; creates a new Broadcaster and flushes the change queue so that clients have to re-list and watch.
func (f *FakeControllerSource) Shutdown()
Shutdown closes the underlying broadcaster, waiting for events to be delivered. It's an error to call any method after calling shutdown. This is enforced by Shutdown() leaving f locked.
func (f *FakeControllerSource) Watch(options metav1.ListOptions) (watch.Interface, error)
Watch returns a watch, which will be pre-populated with all changes after resourceVersion.
type FakePVCControllerSource struct {
FakeControllerSource
}
func NewFakePVCControllerSource() *FakePVCControllerSource
func (f *FakePVCControllerSource) List(options metav1.ListOptions) (runtime.Object, error)
List returns a list object, with its resource version set.
type FakePVControllerSource struct {
FakeControllerSource
}
func NewFakePVControllerSource() *FakePVControllerSource
func (f *FakePVControllerSource) List(options metav1.ListOptions) (runtime.Object, error)
List returns a list object, with its resource version set.