- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 42 for gvr (0.02 sec)
-
pkg/scheduler/eventhandlers.go
continue } // Fall back to try dynamic informers. gvr, _ := schema.ParseResourceArg(string(gvk)) dynInformer := dynInformerFactory.ForResource(*gvr).Informer() if handlerRegistration, err = dynInformer.AddEventHandler( buildEvtResHandler(at, gvk, strings.Title(gvr.Resource)), ); err != nil { return err } handlers = append(handlers, handlerRegistration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
"istio.io/istio/pilot/pkg/status/distribution" "istio.io/istio/pkg/adsc" "istio.io/istio/pkg/config/analysis/incluster" "istio.io/istio/pkg/config/schema/collections" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/log" "istio.io/istio/pkg/revisions" ) // URL schemes supported by the config store type ConfigSourceAddressScheme string const (
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
"istio.io/istio/pkg/config/labels" "istio.io/istio/pkg/config/schema/collection" "istio.io/istio/pkg/config/schema/collections" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kubetypes" istiolog "istio.io/istio/pkg/log"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
"istio.io/istio/pilot/pkg/serviceregistry/kube" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/host" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/network" "istio.io/istio/pkg/slices" ) type networkManager struct { sync.RWMutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go
Body(subjectAccessReview). Do(ctx) restResult.StatusCode(&statusCode) err = restResult.Into(result) return } // subjectAccessReviewV1ClientGW used by the generic webhook, doesn't specify GVR. type subjectAccessReviewV1ClientGW struct { client rest.Interface }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/config/schema/gvr/resources.gen.go
// Code generated by pkg/config/schema/codegen/tools/collections.main.go. DO NOT EDIT. package gvr import "k8s.io/apimachinery/pkg/runtime/schema" var ( ServiceExport = schema.GroupVersionResource{Group: "multicluster.x-k8s.io", Version: "v1alpha1", Resource: "serviceexports"} ServiceImport = schema.GroupVersionResource{Group: "multicluster.x-k8s.io", Version: "v1alpha1", Resource: "serviceimports"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
} func (dc *DisruptionController) implementsScale(gvr schema.GroupVersionResource) (bool, error) { resourceList, err := dc.discoveryClient.ServerResourcesForGroupVersion(gvr.GroupVersion().String()) if err != nil { return false, err } scaleSubresourceName := fmt.Sprintf("%s/scale", gvr.Resource) for _, resource := range resourceList.APIResources {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/conversion/conversion_test.go
func (c *conversionTestContext) versionedClient(ns string, version string) dynamic.ResourceInterface { gvr := schema.GroupVersionResource{Group: c.crd.Spec.Group, Version: version, Resource: c.crd.Spec.Names.Plural} if c.crd.Spec.Scope != apiextensionsv1.ClusterScoped { return c.dynamicClient.Resource(gvr).Namespace(ns) } return c.dynamicClient.Resource(gvr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 05:32:34 UTC 2023 - 47.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
} return selectors } func (e *quotaEvaluator) Evaluate(a admission.Attributes) error { e.init.Do(e.start) // is this resource ignored? gvr := a.GetResource() gr := gvr.GroupResource() if _, ok := e.ignoredResources[gr]; ok { return nil } // if we do not know how to evaluate use for this resource, create an evaluator evaluator := e.registry.Get(gr)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/filter_test.go
}, }, } gvk := schema.GroupVersionKind{Group: "", Version: "v1", Kind: "Endpoints"} gvr := schema.GroupVersionResource{Group: "", Version: "v1", Resource: "endpoints"} return admission.NewAttributesRecord(object, oldObject, gvk, namespace, name, gvr, "", admission.Create, &metav1.CreateOptions{}, false, nil) } func endpointStatusUpdateAttributes() admission.Attributes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 40.4K bytes - Viewed (0)