- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 93 for gvr (0.03 sec)
-
pkg/config/schema/codegen/collections.go
"istio.io/istio/pkg/config/schema/ast" "istio.io/istio/pkg/test/env" "istio.io/istio/pkg/util/sets" ) //go:embed templates/gvk.go.tmpl var gvkTemplate string //go:embed templates/gvr.go.tmpl var gvrTemplate string //go:embed templates/crdclient.go.tmpl var crdclientTemplate string //go:embed templates/types.go.tmpl var typesTemplate string //go:embed templates/clients.go.tmpl
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 07:19:43 UTC 2023 - 5.4K bytes - Viewed (0) -
operator/pkg/helmreconciler/reconciler.go
} var ogvr schema.GroupVersionResource if obj.GetKind() == name.MutatingWebhookConfigurationStr { ogvr = gvr.MutatingWebhookConfiguration } else if obj.GetKind() == name.ValidatingWebhookConfigurationStr { ogvr = gvr.ValidatingWebhookConfiguration } t := true _, err := kubeClient.Dynamic().Resource(ogvr).Namespace(obj.GetNamespace()).Patch(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
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) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
return func(action cgotesting.Action) (handled bool, ret apiruntime.Object, err error) { // listAction := action.(cgotesting.ListAction) gvr := action.GetResource() ns := action.GetNamespace() gvr.Resource += "es" list, err := tracker.List(gvr, schema.GroupVersionKind{Group: gvr.Group, Version: gvr.Version, Kind: kind}, ns) return true, list, err } } func Test_isSchedulableAfterClaimChange(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K 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/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)