type testcase … type nodeIDMap … type topologyKeyMap … type labelMap … // TestInstallCSIDriver tests InstallCSIDriver with various existing Node and/or CSINode objects. // The node IDs in all test cases below are the same between the Node annotation and CSINode. func TestInstallCSIDriver(t *testing.T) { … } func generateVolumeLimits(i int32) *storage.VolumeNodeResources { … } // TestUninstallCSIDriver tests UninstallCSIDriver with various existing Node and/or CSINode objects. func TestUninstallCSIDriver(t *testing.T) { … } func TestSetMigrationAnnotation(t *testing.T) { … } func TestInstallCSIDriverExistingAnnotation(t *testing.T) { … } func getClientSet(existingNode *v1.Node, existingCSINode *storage.CSINode) *fake.Clientset { … } func test(t *testing.T, addNodeInfo bool, testcases []testcase) { … } func generateNode(nodeIDs, labels map[string]string, capacity map[v1.ResourceName]resource.Quantity) *v1.Node { … } func marshall(nodeIDs nodeIDMap) string { … } func generateCSINode(nodeIDs nodeIDMap, volumeLimits *storage.VolumeNodeResources, topologyKeys topologyKeyMap) *storage.CSINode { … } func getCSINodeObjectMeta() metav1.ObjectMeta { … } func applyNodeStatusPatch(originalNode *v1.Node, patch []byte) (*v1.Node, error) { … } func hasPatchAction(actions []clienttesting.Action) clienttesting.Action { … }
Codebase Browser
kubernetes