- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 166 for GetOptions (0.32 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/defaulting_test.go
var err error for retry := 0; retry < 10; retry++ { var obj *apiextensionsv1.CustomResourceDefinition obj, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Get(context.TODO(), crd.Name, metav1.GetOptions{}) if err != nil { t.Fatal(err) } update(obj) obj, err = apiExtensionClient.ApiextensionsV1().CustomResourceDefinitions().Update(context.TODO(), obj, metav1.UpdateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 05:32:34 UTC 2023 - 21.2K bytes - Viewed (0) -
pkg/serviceaccount/jwt_test.go
return tc.Client.CoreV1().Secrets(namespace).Get(context.TODO(), name, metav1.GetOptions{}) })), v1listers.NewServiceAccountLister(newIndexer(func(namespace, name string) (interface{}, error) { return tc.Client.CoreV1().ServiceAccounts(namespace).Get(context.TODO(), name, metav1.GetOptions{}) })), v1listers.NewPodLister(newIndexer(func(namespace, name string) (interface{}, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 22:16:08 UTC 2024 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/dryrun_test.go
err := s.Create(context.Background(), "key", obj, out, 0, true) if err != nil { t.Fatalf("Failed to create new dry-run object: %v", err) } err = s.Get(context.Background(), "key", storage.GetOptions{}, out) if e, ok := err.(*storage.StorageError); !ok || e.Code != storage.ErrCodeKeyNotFound { t.Errorf("Expected key to be not found, error: %v", err) } } func TestDryRunCreateReturnsObject(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 9.9K bytes - Viewed (0) -
pkg/registry/rbac/rest/storage_rbac.go
_, err := clusterRoleClient.ClusterRoles().Get(context.TODO(), newName, metav1.GetOptions{}) if err == nil { continue } if !apierrors.IsNotFound(err) { return err } existingRole, err := clusterRoleClient.ClusterRoles().Get(context.TODO(), oldName, metav1.GetOptions{}) if apierrors.IsNotFound(err) { continue } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
if kubeClient == nil { return fmt.Errorf("error getting kube client") } nodeClient := kubeClient.CoreV1().Nodes() originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{}) if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false for _, update := range updateFuncs { newNode, updated, err := update(node) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
return true } func (c *Controller) processDeletedLease(ctx context.Context, name string) error { _, err := c.kubeclientset.CoordinationV1().Leases(metav1.NamespaceSystem).Get(ctx, name, metav1.GetOptions{}) // the lease isn't deleted, nothing we need to do here if err == nil { return nil } if !apierrors.IsNotFound(err) { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/registry/core/namespace/storage/storage.go
return r.store.Update(ctx, name, objInfo, createValidation, updateValidation, forceAllowCreate, options) } func (r *REST) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { return r.store.Get(ctx, name, options) } func (r *REST) Watch(ctx context.Context, options *metainternalversion.ListOptions) (watch.Interface, error) { return r.store.Watch(ctx, options)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 13.4K bytes - Viewed (0) -
platforms/jvm/plugins-java-base/src/main/java/org/gradle/api/plugins/JavaBasePlugin.java
if (compile instanceof JavaCompile) { JavaCompile javaCompile = (JavaCompile) compile; if (javaCompile.getOptions().getRelease().isPresent()) { return JavaVersion.toVersion(javaCompile.getOptions().getRelease().get()); } if (rawConvention != null) { return rawConvention; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 19 22:14:22 UTC 2023 - 28.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency.go
func mutateConfigMap(client clientset.Interface, meta metav1.ObjectMeta, mutator ConfigMapMutator) error { ctx := context.Background() configMap, err := client.CoreV1().ConfigMaps(meta.Namespace).Get(ctx, meta.Name, metav1.GetOptions{}) if err != nil { return errors.Wrap(err, "unable to get ConfigMap") } if err = mutator(configMap); err != nil { return errors.Wrap(err, "unable to mutate ConfigMap") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0) -
platforms/jvm/language-groovy/src/main/java/org/gradle/api/tasks/compile/GroovyCompile.java
spec.setCompileOptions(compileOptions); spec.setGroovyCompileOptions(new MinimalGroovyCompileOptions(groovyCompileOptions)); spec.getCompileOptions().setSupportsCompilerApi(true); if (getOptions().isIncremental()) { validateIncrementalCompilationOptions(sourceRoots, spec.annotationProcessingConfigured()); spec.getCompileOptions().setPreviousCompilationDataFile(getPreviousCompilationData());
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.6K bytes - Viewed (0)