- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 44 for gvr (1.7 sec)
-
pkg/controller/volume/persistentvolume/testing/testing.go
func (r *VolumeReactor) Watch(gvr schema.GroupVersionResource, ns string) (watch.Interface, error) { r.lock.Lock() defer r.lock.Unlock() fakewatcher := watch.NewRaceFreeFake() if _, exists := r.watchers[gvr]; !exists { r.watchers[gvr] = make(map[string][]*watch.RaceFreeFakeWatcher) } r.watchers[gvr][ns] = append(r.watchers[gvr][ns], fakewatcher) return fakewatcher, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
pilot/test/xds/fake.go
MeshWatcher: mesh.NewFixedWatcher(m), CRDs: []schema.GroupVersionResource{ // Install all CRDs used (mostly in Ambient) gvr.AuthorizationPolicy, gvr.PeerAuthentication, gvr.KubernetesGateway, gvr.KubernetesGateway, gvr.WorkloadEntry, gvr.ServiceEntry, }, }) stop := test.NewStop(t) // start default client informers after creating ingress/secret controllers
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go
return func(gvr schema.GroupVersionResource) (cache.GenericLister, error) { informer, err := f(gvr) if err != nil { return nil, err } return &protectedLister{ hasSynced: cachedHasSynced(informer.Informer().HasSynced), notReadyErr: fmt.Errorf("%v not yet synced", gvr), delegate: informer.Lister(), }, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 11.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
} d.patcher = func(g schema.GroupVersionResource, name string, namespace string, data []byte, subresources ...string) error { if g == gvr.Service { reconciles.Inc() } if g == gvr.KubernetesGateway { b, err := yaml.JSONToYAML(data) if err != nil { return err } writes <- string(b) } return nil } stop := test.NewStop(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods_test.go
}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { gvr := corev1.SchemeGroupVersion.WithResource("pods") listerForPod := map[schema.GroupVersionResource]cache.GenericLister{ gvr: newGenericLister(gvr.GroupResource(), tt.objs), } evaluator := NewPodEvaluator(mockListerForResourceFunc(listerForPod), testingclock.NewFakeClock(time.Now()))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
func RecordWatchListLatency(ctx context.Context, gvr schema.GroupVersionResource, metricsScope string) { requestReceivedTimestamp, ok := request.ReceivedTimestampFrom(ctx) if !ok { utilruntime.HandleError(fmt.Errorf("unable to measure watchlist latency because no received ts found in the ctx, gvr: %s", gvr)) return } elapsedSeconds := time.Since(requestReceivedTimestamp).Seconds()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
var kc kclient.Untyped if s.IsBuiltin() { kc = kclient.NewUntypedInformer(cl.client, gvr, filter) } else { kc = kclient.NewDelayedInformer[controllers.Object]( cl.client, gvr, kubetypes.StandardInformer, filter, ) } kind := s.Kind() kc.AddEventHandler(controllers.EventHandler[controllers.Object]{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking.go
count := 0 for _, group := range groups { for _, version := range versions { for _, resource := range resources { gvr := schema.GroupVersionResource{ Group: group, Version: version, Resource: resource, } resolved, err := c.RestMapper.KindsFor(gvr) if err != nil { if restMapperRefreshAttempted { // RESTMapper refresh happens at most once per policy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 15.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kclient" "istio.io/istio/pkg/kube/kclient/clienttest" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/util/assert"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go
Body(tokenReview). Do(ctx) restResult.StatusCode(&statusCode) err = restResult.Into(result) return } // tokenReviewV1ClientGW used by the generic webhook, doesn't specify GVR. type tokenReviewV1ClientGW struct { client rest.Interface }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 00:47:42 UTC 2022 - 11.5K bytes - Viewed (0)