Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 52 for gvr (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kube/controllers/common.go

    type ComparableObject interface {
    	comparable
    	Object
    }
    
    // IsNil works around comparing generic types
    func IsNil[O ComparableObject](o O) bool {
    	var t O
    	return o == t
    }
    
    // UnstructuredToGVR extracts the GVR of an unstructured resource. This is useful when using dynamic
    // clients.
    func UnstructuredToGVR(u unstructured.Unstructured) (schema.GroupVersionResource, error) {
    	res := schema.GroupVersionResource{}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test.go

    type applyPatchOperation struct {
    	description string
    	gvr         schema.GroupVersionResource
    	name        string
    	patch       interface{}
    }
    
    func (a applyPatchOperation) Do(ctx *ratchetingTestContext) error {
    	// Lookup GVK from discovery
    	kind, ok := fakeRESTMapper[a.gvr]
    	if !ok {
    		return fmt.Errorf("no mapping found for Gvr %v, add entry to fakeRESTMapper", a.gvr)
    	}
    
    	patch := &unstructured.Unstructured{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 59.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top