- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 79 for gvr (0.03 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) -
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) -
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)