- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 63 for gvr (0.04 sec)
-
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/kube/krt/informer.go
}() return h } // NewInformer creates a Collection[I] sourced from // the results of kube.Client querying resources of type I // from the API Server. // // Resources must have their GVR and GVK registered in the // kube.Client before this method is called, otherwise // NewInformer will panic. func NewInformer[I controllers.ComparableObject](c kube.Client, opts ...CollectionOption) Collection[I] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
up.SplitEvents = true cl := kubeclient.NewFakeClient() t.Cleanup(cl.Shutdown) for _, crd := range []schema.GroupVersionResource{ gvr.AuthorizationPolicy, gvr.PeerAuthentication, gvr.KubernetesGateway, gvr.GatewayClass, gvr.WorkloadEntry, gvr.ServiceEntry, } { clienttest.MakeCRD(t, cl, crd) } idx := New(Options{ Client: cl, SystemNamespace: systemNS,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K 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/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) -
pkg/controller/garbagecollector/garbagecollector_test.go
} gvr := schema.GroupVersionResource{Group: group, Version: version, Resource: resource} var c fakemetadata.MetadataClient if namespace == "" { c = ctx.metadataClient.Resource(gvr).(fakemetadata.MetadataClient) } else { c = ctx.metadataClient.Resource(gvr).Namespace(namespace).(fakemetadata.MetadataClient) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/kube/client.go
return func(action clienttesting.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource() ns := action.GetNamespace() watch, err := tracker.Watch(gvr, ns) if err != nil { return false, nil, err } c.informerWatchesPending.Dec() return true, watch, nil } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0)