- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for gvr (0.18 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook_test.go
mapper.RegisterKindFor(gvr("apps", "v1", "deployments"), "scale", gvk("autoscaling", "v1", "Scale")) mapper.RegisterKindFor(gvr("apps", "v1beta1", "deployments"), "scale", gvk("apps", "v1beta1", "Scale")) mapper.RegisterKindFor(gvr("apps", "v1alpha1", "deployments"), "scale", gvk("apps", "v1alpha1", "Scale"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 28 19:30:04 UTC 2023 - 32K bytes - Viewed (0) -
pkg/config/schema/gvk/resources.gen.go
case gvr.DaemonSet: return DaemonSet, true case gvr.Deployment: return Deployment, true case gvr.DestinationRule: return DestinationRule, true case gvr.EndpointSlice: return EndpointSlice, true case gvr.Endpoints: return Endpoints, true case gvr.EnvoyFilter: return EnvoyFilter, true case gvr.GRPCRoute: return GRPCRoute, true case gvr.Gateway: return Gateway, true case gvr.GatewayClass:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/config/schema/kubeclient/resources.gen.go
case gvr.DaemonSet: return &k8sioapiappsv1.DaemonSet{} case gvr.Deployment: return &k8sioapiappsv1.Deployment{} case gvr.DestinationRule: return &apiistioioapinetworkingv1alpha3.DestinationRule{} case gvr.EndpointSlice: return &k8sioapidiscoveryv1.EndpointSlice{} case gvr.Endpoints: return &k8sioapicorev1.Endpoints{} case gvr.EnvoyFilter: return &apiistioioapinetworkingv1alpha3.EnvoyFilter{} case gvr.GRPCRoute:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/matching/matching_test.go
mapper.RegisterKindFor(gvr("apps", "v1", "deployments"), "scale", gvk("autoscaling", "v1", "Scale")) mapper.RegisterKindFor(gvr("apps", "v1beta1", "deployments"), "scale", gvk("apps", "v1beta1", "Scale")) mapper.RegisterKindFor(gvr("apps", "v1alpha1", "deployments"), "scale", gvk("apps", "v1alpha1", "Scale"))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 38.2K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
}, }, { name: "watch pods in the InformerWatchNamespace", gvr: gvr.Pod, want: kubetypes.InformerOptions{ Namespace: features.InformerWatchNamespace, Cluster: c.ClusterID(), }, }, { name: "watch namespaces", gvr: gvr.Namespace, want: kubetypes.InformerOptions{ Namespace: "", Cluster: c.ClusterID(), }, }, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/controller/namespace/deletion/namespaced_resources_deleter.go
func (d *namespacedResourcesDeleter) deleteCollection(ctx context.Context, gvr schema.GroupVersionResource, namespace string) (bool, error) { logger := klog.FromContext(ctx) logger.V(5).Info("Namespace controller - deleteCollection", "namespace", namespace, "resource", gvr) key := operationKey{operation: operationDeleteCollection, gvr: gvr} if !d.opCache.isSupported(key) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 25.2K bytes - Viewed (0) -
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) -
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)