- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 93 for gvr (0.02 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/request/admissionreview.go
UID: uid, Kind: metav1.GroupVersionKind{ Group: gvk.Group, Kind: gvk.Kind, Version: gvk.Version, }, Resource: metav1.GroupVersionResource{ Group: gvr.Group, Resource: gvr.Resource, Version: gvr.Version, }, SubResource: subresource, RequestKind: &metav1.GroupVersionKind{ Group: requestGVK.Group, Kind: requestGVK.Kind, Version: requestGVK.Version,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 16:56:12 UTC 2023 - 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) -
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) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/group_version.go
Resource string `json:"resource" protobuf:"bytes,3,opt,name=resource"` } func (gvr *GroupVersionResource) String() string { if gvr == nil { return "<nil>" } return strings.Join([]string{gvr.Group, "/", gvr.Version, ", Resource=", gvr.Resource}, "") } // GroupKind specifies a Group and a Kind, but does not force a version. This is useful for identifying
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 04 09:55:26 UTC 2021 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/priority.go
remainingGVRs := append([]schema.GroupVersionResource{}, originalGVRs...) for _, pattern := range m.ResourcePriority { matchedGVRs := []schema.GroupVersionResource{} for _, gvr := range remainingGVRs { if resourceMatches(pattern, gvr) { matchedGVRs = append(matchedGVRs, gvr) } } switch len(matchedGVRs) { case 0: // if you have no matches, then nothing matched this pattern just move to the next continue case 1:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 23:44:02 UTC 2021 - 7.6K 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/server/storage/resource_config.go
} } } // resourceMatcherForVersion matches resources in the specified version func resourceMatcherForVersion(gv schema.GroupVersion) func(gvr schema.GroupVersionResource) bool { return func(gvr schema.GroupVersionResource) bool { return gv == gvr.GroupVersion() } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 5.1K bytes - Viewed (0)