- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for IsAlreadyExists (0.18 sec)
-
pkg/kube/kclient/clienttest/crd.go
if !ok { return } obj := &metav1.PartialObjectMetadata{ TypeMeta: crd.TypeMeta, ObjectMeta: crd.ObjectMeta, } if _, err := fmd.CreateFake(obj, metav1.CreateOptions{}); err != nil { if kerrors.IsAlreadyExists(err) { _, err = fmd.UpdateFake(obj, metav1.UpdateOptions{}) if err != nil { t.Fatal(err) } } else { t.Fatal(err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 2K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
ObjectMeta: metav1.ObjectMeta{ Name: ns, Namespace: "", }, } _, err := c.client.CoreV1().Namespaces().Create(context.TODO(), newNs, metav1.CreateOptions{}) if err != nil && errors.IsAlreadyExists(err) { err = nil } return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/serviceaccount/util.go
klog.Warningf("create non-exist namespace %s failed:%v", namespace, err) } } // Create the service account sa, err = coreClient.ServiceAccounts(namespace).Create(context.TODO(), &v1.ServiceAccount{ObjectMeta: metav1.ObjectMeta{Namespace: namespace, Name: name}}, metav1.CreateOptions{}) if apierrors.IsAlreadyExists(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 8.1K bytes - Viewed (0) -
security/pkg/k8s/configutil.go
// Namespace may be deleted between now... and our previous check. Just skip this, we cannot create into deleted ns // And don't retry a create if the namespace is terminating if errors.IsAlreadyExists(err) || errors.HasStatusCause(err, v1.NamespaceTerminatingCause) { return nil } if errors.IsForbidden(err) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 3K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
Data: map[string]string{ConfigMapDataKey: now.UTC().Format(dateFormat)}, }, metav1.CreateOptions{}); err != nil { if apierrors.IsAlreadyExists(err) { return nil } // don't consume the creationRatelimiter for an unsuccessful attempt r.CancelAt(now) return err } } else { configMap := obj.(*corev1.ConfigMap)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
if _, err = c.client.Dynamic().Resource(mcs.ServiceExportGVR).Namespace(serviceExport.Namespace).Create( context.TODO(), &unstructured.Unstructured{Object: u}, metav1.CreateOptions{}); err != nil { switch { case errors.IsAlreadyExists(err): // The ServiceExport already exists. Nothing to do. return nil case errors.IsNotFound(err): log.Warnf("%s ServiceExport CRD Not found. Shutting down MCS ServiceExport sync. "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
sa.Namespace = ns.Name if _, err := c.client.CoreV1().ServiceAccounts(ns.Name).Create(ctx, &sa, metav1.CreateOptions{}); err != nil && !apierrors.IsAlreadyExists(err) { // we can safely ignore terminating namespace errors if !apierrors.HasStatusCause(err, v1.NamespaceTerminatingCause) { createFailures = append(createFailures, err) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go
CIDRs: c.cidrs, }, } serviceCIDR, err = c.client.NetworkingV1alpha1().ServiceCIDRs().Create(context.Background(), serviceCIDR, metav1.CreateOptions{}) if err != nil && !apierrors.IsAlreadyExists(err) { c.eventRecorder.Eventf(serviceCIDR, v1.EventTypeWarning, "KubernetesDefaultServiceCIDRError", "The default ServiceCIDR can not be created") return err } c.syncStatus(serviceCIDR) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 7.5K bytes - Viewed (0)