- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 79 for gvr (0.04 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/storageversion/manager.go
} } func (s *defaultManager) addPendingManagedStatusLocked(r *ResourceInfo) { gvrs := r.EquivalentResourceMapper.EquivalentResourcesFor(r.GroupResource.WithVersion(""), "") for _, gvr := range gvrs { gr := gvr.GroupResource() if _, ok := s.managedStatus[gr]; !ok { s.managedStatus[gr] = &updateStatus{} } } } // UpdateStorageVersions tries to update the StorageVersions of the recorded resources
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:47:19 UTC 2023 - 10.5K 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) -
pkg/controller/resourcequota/resource_quota_controller_test.go
} } } } func TestAddQuota(t *testing.T) { kubeClient := fake.NewSimpleClientset() gvr := v1.SchemeGroupVersion.WithResource("pods") listersForResourceConfig := map[schema.GroupVersionResource]cache.GenericLister{ gvr: newGenericLister(gvr.GroupResource(), newTestPods()), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K 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) -
staging/src/k8s.io/apiserver/pkg/audit/request.go
ae.ObjectRef.ResourceVersion = meta.GetResourceVersion() } } if len(ae.ObjectRef.APIVersion) == 0 { ae.ObjectRef.APIGroup = gvr.Group ae.ObjectRef.APIVersion = gvr.Version } if len(ae.ObjectRef.Resource) == 0 { ae.ObjectRef.Resource = gvr.Resource } if len(ae.ObjectRef.Subresource) == 0 { ae.ObjectRef.Subresource = subresource } if ae.Level.Less(auditinternal.LevelRequest) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 9K 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)