- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 92 for createActions (0.49 sec)
-
pkg/registry/core/service/ipallocator/cidrallocator_test.go
} if _, err := r.AllocateNext(); err == nil { t.Error(err) } cidr := newServiceCIDR("test", "192.168.0.0/28") _, err = r.client.ServiceCIDRs().Create(context.Background(), cidr, metav1.CreateOptions{}) if err != nil { t.Fatal(err) } r.addServiceCIDR(cidr) // wait for the cidr to be processed and set the informer synced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/matching/matching_test.go
attrs: admission.NewAttributesRecord(nil, nil, gvk("apps", "v1", "Deployment"), "ns", "name", gvr("apps", "v1", "deployments"), "", admission.Create, &metav1.CreateOptions{}, false, nil), expectMatches: false, }, { name: "wildcard rule, match as requested", criteria: &v1.MatchResources{ NamespaceSelector: &metav1.LabelSelector{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
} _, err = bindingStorage.Create(ctx, binding.Name, &binding, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}) if err != nil { t.Fatalf("unexpected error: %v", err) } _, err = bindingStorage.Create(ctx, binding.Name, &binding, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}) if err == nil || !errors.IsConflict(err) { t.Fatalf("expected resource conflict error, not: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
plugin/pkg/admission/serviceaccount/admission_test.go
pod := &api.Pod{} attrs := admission.NewAttributesRecord(pod, nil, api.Kind("Pod").WithVersion("version"), "myns", "myname", api.Resource("CustomResource").WithVersion("version"), "", admission.Create, &metav1.CreateOptions{}, false, nil) handler := admissiontesting.WithReinvocationTesting(t, NewServiceAccount()) err := handler.Admit(context.TODO(), attrs, nil) if err != nil { t.Errorf("Expected non-pod resource allowed, got err: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
return true, obj, nil }) fakeClient.AddReactor("create", "pods", func(action core.Action) (handled bool, ret runtime.Object, err error) { createAction := action.(core.CreateAction) pod := createAction.GetObject().(*v1.Pod) extraPods.Items = append(extraPods.Items, *pod) return true, createAction.GetObject(), nil }) fakeClient.AddReactor("list", "csinodes", func(action core.Action) (handled bool, ret runtime.Object, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
if err != nil { t.Error(err) } } // TestAdmissionNamespaceDoesNotExist verifies pod is not admitted if namespace does not exist.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/cli/DefaultCommandLineActionFactoryTest.groovy
and: 1 * actionFactory1.createAction(!null, !null) >> { def action1 = { println "action1" } action1Intermediary ? action1 as ContinuingAction<ExecutionListener> : action1 as Action<ExecutionListener> } action2Called * actionFactory2.createAction(!null, !null) >> { { println "action2" } as Action<ExecutionListener> }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 11.6K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency.go
true, func(_ context.Context) (bool, error) { ctx := context.Background() if _, err := client.CoreV1().ConfigMaps(cm.ObjectMeta.Namespace).Create(ctx, cm, metav1.CreateOptions{}); err != nil { if !apierrors.IsAlreadyExists(err) { lastError = errors.Wrap(err, "unable to create ConfigMap") return false, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller_test.go
env, ctx := setup(t) env.runFunc() defer env.cleanFunc() env.Interface.ApiextensionsV1().CustomResourceDefinitions().Create(ctx, coolFooCRD, metav1.CreateOptions{}) env.Interface.ApiextensionsV1().CustomResourceDefinitions().Create(ctx, coolBarCRD, metav1.CreateOptions{}) env.pollForPathExists("/apis/stable.example.com/v1/coolfoos") env.pollForPathExists("/apis/stable.example.com/v1/coolbars") s := env.fetchOpenAPIOrDie()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 22 17:10:53 UTC 2023 - 12.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/cli/DefaultCommandLineActionFactory.java
@Override public Action<? super ExecutionListener> createAction(CommandLineParser parser, ParsedCommandLine commandLine) { List<Action<? super ExecutionListener>> actions = new ArrayList<>(2); for (CommandLineActionCreator actionCreator : actionCreators) { Action<? super ExecutionListener> action = actionCreator.createAction(parser, commandLine); if (action != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 16.7K bytes - Viewed (0)