- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 93 for gvr (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
func (h *peerProxyHandler) findServiceableByServers(gvr schema.GroupVersionResource, localAPIServerId string, reconciler reconcilers.PeerEndpointLeaseReconciler) (serviceableByResponse, error) { apiserversi, ok := h.svMap.Load(gvr) // no value found for the requested gvr in svMap if !ok || apiserversi == nil { return serviceableByResponse{}, fmt.Errorf("no StorageVersions found for the GVR: %v", gvr) } apiservers := apiserversi.(*sync.Map)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kube/kclient/client.go
} return newDelayedInformer[T](gvr, inf, delay, filter) } // NewUntypedInformer returns an untyped client for a given GVR. This is read-only. func NewUntypedInformer(c kube.Client, gvr schema.GroupVersionResource, filter Filter) Untyped { inf := kubeclient.GetInformerFilteredFromGVR(c, ToOpts(c, gvr, filter), gvr) return newInformerClient[controllers.Object](gvr, inf, filter) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/schema/group_version.go
Resource string } func (gvr GroupVersionResource) Empty() bool { return len(gvr.Group) == 0 && len(gvr.Version) == 0 && len(gvr.Resource) == 0 } func (gvr GroupVersionResource) GroupResource() GroupResource { return GroupResource{Group: gvr.Group, Resource: gvr.Resource} } func (gvr GroupVersionResource) GroupVersion() GroupVersion { return GroupVersion{Group: gvr.Group, Version: gvr.Version} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 30 09:08:59 UTC 2023 - 10.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
mapperGVRs, err := rv.mapper.ResourcesFor(gvr) if err != nil { return false, err } for _, mapperGVR := range mapperGVRs { if mapperGVR.Group == gvr.Group && mapperGVR.Version == gvr.Version && mapperGVR.Resource == gvr.Resource { return true, nil } } return false, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler_test.go
if testDataExists(svdata.gvr) { ppI.addToStorageVersionMap(svdata.gvr, svdata.serverId) } return ppI, nil } func (h *peerProxyHandler) addToStorageVersionMap(gvr schema.GroupVersionResource, serverId string) { apiserversi, _ := h.svMap.LoadOrStore(gvr, &sync.Map{}) apiservers := apiserversi.(*sync.Map) if serverId != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/registry.go
NewServiceEvaluator(f), NewPersistentVolumeClaimEvaluator(f), } // these evaluators require an alias for backwards compatibility for gvr, alias := range legacyObjectCountAliases { result = append(result, generic.NewObjectCountEvaluator(gvr.GroupResource(), generic.ListResourceUsingListerFunc(f, gvr), alias)) } return result
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 09:42:32 UTC 2021 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/schema/group_version_test.go
} for i, test := range tests { gvr, gr := ParseResourceArg(test.input) if (gvr != nil && test.gvr == nil) || (gvr == nil && test.gvr != nil) || (test.gvr != nil && *gvr != *test.gvr) { t.Errorf("%d: unexpected output: %#v", i, gvr) } if gr != test.gr { t.Errorf("%d: unexpected output: %#v", i, gr) } } } func TestKindForGroupVersionKinds(t *testing.T) { gvks := GroupVersions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 15 01:46:00 UTC 2022 - 7.2K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
meta: metav1.ObjectMeta{Namespace: namespaceName, Name: configMapName}, expectedActions: []ktesting.Action{ ktesting.NewGetAction(gvr, namespaceName, configMapName), ktesting.NewGetAction(gvr, namespaceName, configMapName), ktesting.NewCreateAction(gvr, namespaceName, createConfigMap(namespaceName, configMapName, map[string]string{dataName: "test-data"})), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
} fc := k.Dynamic().(*dynamicfake.FakeDynamicClient) fc.PrependWatchReactor("*", func(action clienttesting.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource() ns := action.GetNamespace() watch, err := fc.Tracker().Watch(gvr, ns) if err != nil { return false, nil, err } // Kubernetes Fake watches do not add initial state, but real server does
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 08:28:50 UTC 2024 - 6.8K bytes - Viewed (0) -
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)