Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for UpdateAction (0.23 sec)

  1. pkg/controller/deployment/rolling_test.go

    		// action for verification.
    		var updateAction core.UpdateAction
    		for _, action := range fakeClientset.Actions() {
    			switch a := action.(type) {
    			case core.UpdateAction:
    				if updateAction != nil {
    					t.Errorf("expected only 1 update action; had %v and found %v", updateAction, a)
    				} else {
    					updateAction = a
    				}
    			}
    		}
    		if updateAction == nil {
    			t.Errorf("expected an update action")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 11K bytes
    - Viewed (0)
  2. pkg/controller/certificates/signer/signer_test.go

    			approved:   true,
    			verify: func(t *testing.T, as []testclient.Action) {
    				if len(as) != 1 {
    					t.Errorf("expected one Update action but got %d", len(as))
    					return
    				}
    				csr := as[0].(testclient.UpdateAction).GetObject().(*capi.CertificateSigningRequest)
    				if len(csr.Status.Certificate) == 0 {
    					t.Errorf("expected certificate to be issued but it was not")
    				}
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 02 21:12:04 UTC 2022
    - 15K bytes
    - Viewed (0)
  3. platforms/native/language-native/src/test/groovy/org/gradle/language/nativeplatform/internal/incremental/IncrementalCompileProcessorTest.groovy

                this.compilationState = newValue
            }
    
            CompilationState update(ObjectHolder.UpdateAction<CompilationState> updateAction) {
                throw new UnsupportedOperationException()
            }
    
            @Override
            CompilationState maybeUpdate(ObjectHolder.UpdateAction<CompilationState> updateAction) {
                throw new UnsupportedOperationException()
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 15:31:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

    					},
    				},
    				{
    					verb:       "update",
    					objectType: primaryType,
    					reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
    						return true, action.(fakeclient.UpdateAction).GetObject(), nil
    					},
    				},
    				{
    					verb:       "get",
    					objectType: secondaryType,
    					reaction: func(action fakeclient.Action) (handled bool, ret runtime.Object, err error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 23 16:39:43 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_pod_control_test.go

    	fakeClient.AddReactor("update", "pods", func(action core.Action) (bool, runtime.Object, error) {
    		update := action.(core.UpdateAction)
    		return true, update.GetObject(), nil
    	})
    	fakeClient.AddReactor("create", "persistentvolumeclaims", func(action core.Action) (bool, runtime.Object, error) {
    		update := action.(core.UpdateAction)
    		return true, update.GetObject(), nil
    	})
    	var updated *v1.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/testing/testvolumespec.go

    		updateAction := action.(core.UpdateAction)
    		node := updateAction.GetObject().(*v1.Node)
    		for index, n := range nodes.Items {
    			if n.Name == node.Name {
    				nodes.Items[index] = *node
    			}
    		}
    		return true, updateAction.GetObject(), nil
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 17 08:48:30 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  7. pkg/controlplane/controller/kubernetesservice/controller_test.go

    			if err != nil {
    				t.Errorf("case %q: unexpected error: %v", test.testName, err)
    			}
    			updates := []core.UpdateAction{}
    			for _, action := range fakeClient.Actions() {
    				if action.GetVerb() == "update" {
    					updates = append(updates, action.(core.UpdateAction))
    				}
    			}
    			if test.expectUpdate != nil {
    				if len(updates) != 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 10:41:06 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  8. pkg/controller/volume/persistentvolume/testing/testing.go

    	if err != nil {
    		return true, nil, err
    	}
    
    	// Test did not request to inject an error, continue simulating API server.
    	switch {
    	case action.Matches("create", "persistentvolumes"):
    		obj := action.(core.UpdateAction).GetObject()
    		volume := obj.(*v1.PersistentVolume)
    
    		// check the volume does not exist
    		_, found := r.volumes[volume.Name]
    		if found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  9. pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller_test.go

    			created = true
    			obj := action.(clienttesting.CreateAction).GetObject().(*corev1.ConfigMap)
    			ret[obj.Name] = obj
    		}
    		if action.Matches("update", "configmaps") {
    			obj := action.(clienttesting.UpdateAction).GetObject().(*corev1.ConfigMap)
    			ret[obj.Name] = obj
    		}
    	}
    	return ret, created
    }
    
    func TestWriteConfigMapDeleted(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 14 00:05:53 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  10. pkg/controller/resourcequota/resource_quota_controller_test.go

    		}
    
    		var usage *v1.ResourceQuota
    		actions := kubeClient.Actions()
    		for i := len(actions) - 1; i >= 0; i-- {
    			if updateAction, ok := actions[i].(core.UpdateAction); ok {
    				usage = updateAction.GetObject().(*v1.ResourceQuota)
    				break
    			}
    		}
    		if usage == nil {
    			t.Fatalf("test: %s,\nExpected update action usage, got none: actions:\n%v", testName, actions)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 16:29:33 UTC 2023
    - 42.6K bytes
    - Viewed (0)
Back to top