- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for gvr (0.03 sec)
-
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/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/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) -
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) -
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/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)