- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 93 for gvr (0.02 sec)
-
tests/integration/operator/uninstall_test.go
} } func checkIopExist(cs istiokube.CLIClient, iopName string) (bool, error) { scopes.Framework.Infof("checking IstioOperator CR status") gvr := iopv1alpha1.IstioOperatorGVR _, err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).Get(context.TODO(), iopName, metav1.GetOptions{}) if errors.IsNotFound(err) { return false, nil } else if err == nil { return true, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/registry/admissionregistration/validatingadmissionpolicy/authz.go
// we only need to authorize the parsed group/version apiGroup = gv.Group apiVersion = gv.Version if gvr, err := v.resourceResolver.Resolve(gv.WithKind(paramKind.Kind)); err == nil { // we only need to authorize the resolved resource resource = gvr.Resource } } // require that the user can read (verb "get") the referred kind. attrs := authorizer.AttributesRecord{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 21:29:56 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
import ( "fmt" "runtime/debug" "sync" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/tools/cache" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube/kubetypes" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/sets" ) // NewInformerFunc returns a SharedIndexInformer. type NewInformerFunc func() cache.SharedIndexInformer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/clientset_generated.go
cs.AddReactor("*", "*", testing.ObjectReaction(o)) cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource() ns := action.GetNamespace() watch, err := o.Watch(gvr, ns) if err != nil { return false, nil, err } return true, watch, nil }) return cs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 09 06:03:32 UTC 2021 - 2.7K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
scopes.Framework.Info("cleaning up in-cluster CRs") gvr := iopv1alpha1.IstioOperatorGVR crList, err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).List(context.TODO(), metav1.ListOptions{}) if err == nil { for _, obj := range crList.Items { t.Logf("deleting CR %v", obj.GetName()) if err := cs.Dynamic().Resource(gvr).Namespace(IstioNamespace).Delete(context.TODO(), obj.GetName(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pilot/pkg/status/resource.go
Generation: strconv.FormatInt(i.Generation, 10), } } func ResourceFromModelConfig(c config.Config) Resource { gvr, ok := gvk.ToGVR(c.GroupVersionKind) if !ok { return Resource{} } return Resource{ GroupVersionResource: gvr, Namespace: c.Namespace, Name: c.Name, Generation: strconv.FormatInt(c.Generation, 10), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 30 16:13:59 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go
cs.AddReactor("*", "*", testing.ObjectReaction(o)) cs.AddWatchReactor("*", func(action testing.Action) (handled bool, ret watch.Interface, err error) { gvr := action.GetResource() ns := action.GetNamespace() watch, err := o.Watch(gvr, ns) if err != nil { return false, nil, err } return true, watch, nil }) return cs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 3.2K bytes - Viewed (0) -
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) -
pkg/config/schema/collection/schemas.go
} } } return nil, false } // FindByGroupVersionResource searches and returns the first schema with the given GVR func (s Schemas) FindByGroupVersionResource(gvr schema.GroupVersionResource) (resource.Schema, bool) { for _, rs := range s.byAddOrder { if rs.GroupVersionResource() == gvr { return rs, true } } return nil, false } // All returns all known Schemas
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 01 08:10:15 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/helpers.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 30 11:46:49 UTC 2021 - 7.2K bytes - Viewed (0)