Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 63 for gvr (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pilot/pkg/status/manager.go

    		scope.Debugf("retrieving config for status update: %s/%s", resource.Namespace, resource.Name)
    		k, ok := gvk.FromGVR(resource.GroupVersionResource)
    		if !ok {
    			scope.Warnf("GVR %v could not be identified", resource.GroupVersionResource)
    			return nil
    		}
    
    		current := store.Get(k, resource.Name, resource.Namespace)
    		return current
    	}
    	return &Manager{
    		store:   store,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 24 04:04:42 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  5. 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)
  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