- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for UpdateAction (0.23 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
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) -
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) -
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) -
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)