- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 63 for gvr (0.09 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter.go
// Attempting to use same logic as webhook for constructing resource // GVK, GVR, subresource // Use the GVK, GVR that the matcher decided was equivalent to that of the request // https://github.com/kubernetes/kubernetes/blob/90c362b3430bcbbf8f245fadbcd521dab39f1d7c/staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go#L182-L210 gvk := equivalentKind gvr := equivalentGVR subresource := attr.GetSubresource()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 14:46:11 UTC 2023 - 12.1K bytes - Viewed (0) -
tests/integration/operator/uninstall_test.go
} } func checkIopExist(cs istiokube.CLIClient, iopName string) (bool, error) { scopes.Framework.Infof("checking IstioOperator CR status") gvr := iopv1alpha1.IstioOperatorGVR _, err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).Get(context.TODO(), iopName, metav1.GetOptions{}) if errors.IsNotFound(err) { return false, nil } else if err == nil { return true, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7.7K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
scopes.Framework.Info("cleaning up in-cluster CRs") gvr := iopv1alpha1.IstioOperatorGVR crList, err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).List(context.TODO(), metav1.ListOptions{}) if err == nil { for _, obj := range crList.Items { t.Logf("deleting CR %v", obj.GetName()) if err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).Delete(context.TODO(), obj.GetName(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/config/schema/collection/schemas.go
} } } return nil, false } // FindByGroupVersionResource searches and returns the first schema with the given GVR func (s Schemas) FindByGroupVersionResource(gvr schema.GroupVersionResource) (resource.Schema, bool) { for _, rs := range s.byAddOrder { if rs.GroupVersionResource() == gvr { return rs, true } } return nil, false } // All returns all known Schemas
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 01 08:10:15 UTC 2023 - 6K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingadmissionpolicybinding/authz.go
// we only need to authorize the parsed group/version apiGroup = gv.Group apiVersion = gv.Version if gvr, err := v.resourceResolver.Resolve(gv.WithKind(paramKind.Kind)); err == nil { // we only need to authorize the resolved resource resource = gvr.Resource } } } var attrs authorizer.AttributesRecord paramRef := binding.Spec.ParamRef verb := "get"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 12:19:03 UTC 2024 - 3.7K bytes - Viewed (0)