func NewFakeControllerSource() *FakeControllerSource { … } func NewFakePVControllerSource() *FakePVControllerSource { … } func NewFakePVCControllerSource() *FakePVCControllerSource { … } type FakeControllerSource … type FakePVControllerSource … type FakePVCControllerSource … type nnu … // 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) ResetWatch() { … } // Add adds an object to the set and sends an add event to watchers. // obj's ResourceVersion is set. func (f *FakeControllerSource) Add(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) Modify(obj runtime.Object) { … } // Delete deletes an object from the set and sends a delete event to watchers. // obj's ResourceVersion is set. func (f *FakeControllerSource) Delete(lastValue 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) AddDropWatch(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) ModifyDropWatch(obj 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) DeleteDropWatch(lastValue runtime.Object) { … } func (f *FakeControllerSource) key(accessor metav1.Object) nnu { … } // Change records the given event (setting the object's resource version) and // sends a watch event with the specified probability. func (f *FakeControllerSource) Change(e watch.Event, watchProbability float64) { … } func (f *FakeControllerSource) getListItemsLocked() ([]runtime.Object, error) { … } // List returns a list object, with its resource version set. func (f *FakeControllerSource) List(options metav1.ListOptions) (runtime.Object, error) { … } // List returns a list object, with its resource version set. func (f *FakePVControllerSource) List(options metav1.ListOptions) (runtime.Object, error) { … } // List returns a list object, with its resource version set. func (f *FakePVCControllerSource) List(options metav1.ListOptions) (runtime.Object, error) { … } // Watch returns a watch, which will be pre-populated with all changes // after resourceVersion. func (f *FakeControllerSource) Watch(options metav1.ListOptions) (watch.Interface, error) { … } // 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) Shutdown() { … }
Codebase Browser
kubernetes