- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for gvr (0.03 sec)
-
pkg/controller/storageversionmigrator/storageversionmigrator.go
return err } logger.V(4).Error(err, "Failed to migrate the resource", "name", gvrKey, "gvr", gvr.String(), "reason", apierrors.ReasonForError(err)) return nil // Todo: add retry for scenarios where API server returns rate limiting error } logger.V(4).Info("Successfully migrated the resource", "name", gvrKey, "gvr", gvr.String()) } _, err = svmc.kubeClient.StoragemigrationV1alpha1().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
if _, ok := object.(*unstructured.Unstructured); ok { if err := p.unstructuredTracker.Create(gvr, object, objectMeta.GetNamespace()); err != nil { if errors.IsAlreadyExists(err) { return p.unstructuredTracker.Update(gvr, object, objectMeta.GetNamespace()) } return err } return nil } else if err := p.nativeTracker.Create(gvr, object, objectMeta.GetNamespace()); err != nil { if errors.IsAlreadyExists(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pkg/config/schema/kubeclient/common.go
// store to enable dynamic object translation func Register[T runtime.Object]( gvr schema.GroupVersionResource, gvk schema.GroupVersionKind, list func(c ClientGetter, namespace string, o metav1.ListOptions) (runtime.Object, error), watch func(c ClientGetter, namespace string, o metav1.ListOptions) (watch.Interface, error), ) { reg := &internalTypeReg[T]{ gvr: gvr, gvk: config.FromKubernetesGVK(gvk), list: list, watch: watch,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
func (d *DeploymentController) canManage(gvr schema.GroupVersionResource, name, namespace string) (bool, string) { store, f := d.clients[gvr] if !f { log.Warnf("unknown GVR %v", gvr) // Even though we don't know what it is, allow users to put the resource. We won't be able to // protect against overwrites though. return true, ""
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0) -
tests/integration/pilot/revisions/uninstall_test.go
var reItemList []unstructured.Unstructured for _, gvk := range gvkResources { resources := strings.ToLower(gvk.Kind) + "s" gvr := schema.GroupVersionResource{Group: gvk.Group, Version: gvk.Version, Resource: resources} reList, reStr := getRemainingResourcesCluster(cs, gvr, label) reItemList = append(reItemList, reList...) reStrlist = append(reStrlist, reStr...) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.8K bytes - Viewed (0) -
pkg/config/schema/codegen/templates/clients.go.tmpl
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/watch" "k8s.io/client-go/tools/cache" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube/informerfactory" ktypes "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/ptr" apiistioioapiextensionsv1alpha1 "istio.io/client-go/pkg/apis/extensions/v1alpha1"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/controlplane/instance_test.go
for gvr, enable := range config.ResourceConfigs { if !strings.Contains(gvr.Version, "beta") { continue // only check beta things } if !enable { continue // only check things that are enabled } if legacyEnabledBetaResources[gvr] { continue // this is a legacy beta resource } if legacyBetaResourcesWithoutStableEquivalents[gvr.GroupResource()] {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/crd.go
kerrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime/schema" metadatafake "k8s.io/client-go/metadata/fake" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test" ) func MakeCRD(t test.Failer, c kube.Client, g schema.GroupVersionResource) { t.Helper() MakeCRDWithAnnotations(t, c, g, nil) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
gvr.AuthorizationPolicy, kubetypes.StandardInformer, filter) AuthzPolicies := krt.WrapClient[*securityclient.AuthorizationPolicy](authzPolicies, krt.WithName("AuthorizationPolicies")) peerAuths := kclient.NewDelayedInformer[*securityclient.PeerAuthentication](options.Client, gvr.PeerAuthentication, kubetypes.StandardInformer, filter)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
return true } klog.FromContext(ctx).V(4).Info("QuotaMonitor process object", "resource", event.gvr.String(), "namespace", accessor.GetNamespace(), "name", accessor.GetName(), "uid", string(accessor.GetUID()), "eventType", event.eventType, ) qm.replenishmentFunc(ctx, event.gvr.GroupResource(), accessor.GetNamespace()) return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0)