var keyFunc … type FakeNodeHandler … type FakeLegacyHandler … // GetUpdatedNodesCopy returns a slice of Nodes with updates applied. func (m *FakeNodeHandler) GetUpdatedNodesCopy() []*v1.Node { … } // Core returns fake CoreInterface. func (m *FakeNodeHandler) Core() v1core.CoreV1Interface { … } // CoreV1 returns fake CoreV1Interface func (m *FakeNodeHandler) CoreV1() v1core.CoreV1Interface { … } // Nodes return fake NodeInterfaces. func (m *FakeLegacyHandler) Nodes() v1core.NodeInterface { … } // Create adds a new Node to the fake store. func (m *FakeNodeHandler) Create(_ context.Context, node *v1.Node, _ metav1.CreateOptions) (*v1.Node, error) { … } // Get returns a Node from the fake store. func (m *FakeNodeHandler) Get(ctx context.Context, name string, opts metav1.GetOptions) (*v1.Node, error) { … } func (m *FakeNodeHandler) runAsyncCalls() { … } // List returns a list of Nodes from the fake store. func (m *FakeNodeHandler) List(_ context.Context, opts metav1.ListOptions) (*v1.NodeList, error) { … } // Delete deletes a Node from the fake store. func (m *FakeNodeHandler) Delete(_ context.Context, id string, opt metav1.DeleteOptions) error { … } // DeleteCollection deletes a collection of Nodes from the fake store. func (m *FakeNodeHandler) DeleteCollection(_ context.Context, opt metav1.DeleteOptions, listOpts metav1.ListOptions) error { … } // Update updates a Node in the fake store. func (m *FakeNodeHandler) Update(_ context.Context, node *v1.Node, _ metav1.UpdateOptions) (*v1.Node, error) { … } // UpdateStatus updates a status of a Node in the fake store. func (m *FakeNodeHandler) UpdateStatus(_ context.Context, node *v1.Node, _ metav1.UpdateOptions) (*v1.Node, error) { … } // PatchStatus patches a status of a Node in the fake store. func (m *FakeNodeHandler) PatchStatus(ctx context.Context, nodeName string, data []byte) (*v1.Node, error) { … } // Watch watches Nodes in a fake store. func (m *FakeNodeHandler) Watch(_ context.Context, opts metav1.ListOptions) (watch.Interface, error) { … } // Patch patches a Node in the fake store. func (m *FakeNodeHandler) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, _ metav1.PatchOptions, subresources ...string) (*v1.Node, error) { … } // Apply applies a NodeApplyConfiguration to a Node in the fake store. func (m *FakeNodeHandler) Apply(ctx context.Context, node *v1apply.NodeApplyConfiguration, opts metav1.ApplyOptions) (*v1.Node, error) { … } // ApplyStatus applies a status of a Node in the fake store. func (m *FakeNodeHandler) ApplyStatus(ctx context.Context, node *v1apply.NodeApplyConfiguration, opts metav1.ApplyOptions) (*v1.Node, error) { … } type FakeRecorder … // Event emits a fake event to the fake recorder func (f *FakeRecorder) Event(obj runtime.Object, eventtype, reason, message string) { … } // Eventf emits a fake formatted event to the fake recorder func (f *FakeRecorder) Eventf(obj runtime.Object, eventtype, reason, messageFmt string, args ...interface{ … } // AnnotatedEventf emits a fake formatted event to the fake recorder func (f *FakeRecorder) AnnotatedEventf(obj runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{ … } func (f *FakeRecorder) generateEvent(obj runtime.Object, timestamp metav1.Time, eventtype, reason, message string) { … } func (f *FakeRecorder) makeEvent(ref *v1.ObjectReference, eventtype, reason, message string) *v1.Event { … } // NewFakeRecorder returns a pointer to a newly constructed FakeRecorder. func NewFakeRecorder() *FakeRecorder { … } // NewNode is a helper function for creating Nodes for testing. func NewNode(name string) *v1.Node { … } // NewPod is a helper function for creating Pods for testing. func NewPod(name, host string) *v1.Pod { … } func contains(node *v1.Node, nodes []*v1.Node) bool { … } // GetZones returns list of zones for all Nodes stored in FakeNodeHandler func GetZones(nodeHandler *FakeNodeHandler) []string { … } // CreateZoneID returns a single zoneID for a given region and zone. func CreateZoneID(region, zone string) string { … } // GetKey is a helper function used by controllers unit tests to get the // key for a given kubernetes resource. func GetKey(obj interface{ … }
Codebase Browser
kubernetes