var podKind … var nodeName … var node2Name … var node3Name … var driver … var podName … var podUID … var resourceName … var resourceName2 … var claimName … var claimName2 … var className … var namespace … var attrName … var deviceClass … var podWithClaimName … var podWithClaimTemplate … var podWithClaimTemplateInStatus … var podWithTwoClaimNames … var podWithTwoClaimTemplates … var workerNode … var workerNodeSlice … var workerNode2 … var workerNode2Slice … var workerNode3 … var workerNode3Slice … var brokenSelector … var claim … var deleteClaim … var pendingClaim … var pendingClaim2 … var allocationResult … var inUseClaim … var allocatedClaim … var allocatedClaimWithWrongTopology … var allocatedClaimWithGoodTopology … var otherClaim … var otherAllocatedClaim … var resourceSlice … var resourceSliceUpdated … func reserve(claim *resourceapi.ResourceClaim, pod *v1.Pod) *resourceapi.ResourceClaim { … } func breakCELInClaim(claim *resourceapi.ResourceClaim) *resourceapi.ResourceClaim { … } func breakCELInClass(class *resourceapi.DeviceClass) *resourceapi.DeviceClass { … } type result … type change … type perNodeResult … func (p perNodeResult) forNode(nodeName string) result { … } type want … type prepare … func TestPlugin(t *testing.T) { … } type testContext … func (tc *testContext) verify(t *testing.T, expected result, initialObjects []metav1.Object, result interface{ … } func (tc *testContext) listAll(t *testing.T) (objects []metav1.Object) { … } func (tc *testContext) listAssumedClaims() []metav1.Object { … } func (tc *testContext) listInFlightClaims() []metav1.Object { … } // updateAPIServer modifies objects and stores any changed object in the API server. func (tc *testContext) updateAPIServer(t *testing.T, objects []metav1.Object, updates change) []metav1.Object { … } func sortObjects(objects []metav1.Object) { … } // update walks through all existing objects, finds the corresponding update // function based on name and kind, and replaces those objects that have an // update function. The rest is left unchanged. func update(t *testing.T, objects []metav1.Object, updates change) []metav1.Object { … } func setup(t *testing.T, nodes []*v1.Node, claims []*resourceapi.ResourceClaim, classes []*resourceapi.DeviceClass, objs []apiruntime.Object, features feature.Features) (result *testContext) { … } // createReactor implements the logic required for the UID and ResourceVersion // fields to work when using the fake client. Add it with client.PrependReactor // to your fake client. ResourceVersion handling is required for conflict // detection during updates, which is covered by some scenarios. func createReactor(tracker cgotesting.ObjectTracker) func(action cgotesting.Action) (handled bool, ret apiruntime.Object, err error) { … } func Test_isSchedulableAfterClaimChange(t *testing.T) { … } func Test_isSchedulableAfterPodChange(t *testing.T) { … } func Test_isSchedulableAfterResourceSliceChange(t *testing.T) { … }
Codebase Browser
kubernetes