Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for ParseGroupVersion (0.3 sec)

  1. pkg/kube/controllers/common.go

    // clients.
    func UnstructuredToGVR(u unstructured.Unstructured) (schema.GroupVersionResource, error) {
    	res := schema.GroupVersionResource{}
    	gv, err := schema.ParseGroupVersion(u.GetAPIVersion())
    	if err != nil {
    		return res, err
    	}
    
    	gk := config.GroupVersionKind{
    		Group:   gv.Group,
    		Version: gv.Version,
    		Kind:    u.GetKind(),
    	}
    	found, ok := gvk.ToGVR(gk)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. pkg/registry/admissionregistration/validatingadmissionpolicybinding/authz.go

    	if policy, err := v.policyGetter.GetValidatingAdmissionPolicy(ctx, binding.Spec.PolicyName); err == nil && policy.Spec.ParamKind != nil {
    		paramKind := policy.Spec.ParamKind
    		if gv, err := schema.ParseGroupVersion(paramKind.APIVersion); err == nil {
    			// we only need to authorize the parsed group/version
    			apiGroup = gv.Group
    			apiVersion = gv.Version
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 12:19:03 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. pkg/apis/admissionregistration/validation/validation.go

    	}
    
    	return allErrors
    }
    
    type groupVersion struct {
    	Group   string
    	Version string
    }
    
    // parseGroupVersion turns "group/version" string into a groupVersion struct. It reports error
    // if it cannot parse the string.
    func parseGroupVersion(gv string) (groupVersion, error) {
    	if (len(gv) == 0) || (gv == "/") {
    		return groupVersion{}, nil
    	}
    
    	switch strings.Count(gv, "/") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 56.6K bytes
    - Viewed (0)
  4. pkg/controller/disruption/disruption.go

    }
    
    func (dc *DisruptionController) getScaleController(ctx context.Context, controllerRef *metav1.OwnerReference, namespace string) (*controllerAndScale, error) {
    	gv, err := schema.ParseGroupVersion(controllerRef.APIVersion)
    	if err != nil {
    		return nil, err
    	}
    
    	gk := schema.GroupKind{
    		Group: gv.Group,
    		Kind:  controllerRef.Kind,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/typechecking.go

    }
    
    func (c *TypeChecker) paramsGVK(policy *v1.ValidatingAdmissionPolicy) schema.GroupVersionKind {
    	if policy.Spec.ParamKind == nil {
    		return schema.GroupVersionKind{}
    	}
    	gv, err := schema.ParseGroupVersion(policy.Spec.ParamKind.APIVersion)
    	if err != nil {
    		return schema.GroupVersionKind{}
    	}
    	return gv.WithKind(policy.Spec.ParamKind.Kind)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 22:07:40 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. pkg/controller/garbagecollector/garbagecollector.go

    	deletableGroupVersionResources := map[schema.GroupVersionResource]struct{}{}
    	for _, rl := range deletableResources {
    		gv, err := schema.ParseGroupVersion(rl.GroupVersion)
    		if err != nil {
    			logger.Info("ignoring invalid discovered resource", "groupversion", rl.GroupVersion, "error", err)
    			continue
    		}
    		for i := range rl.APIResources {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  7. pkg/controller/garbagecollector/graph_builder.go

    // once it is determined they do not have backing objects in storage
    func (gb *GraphBuilder) enqueueVirtualDeleteEvent(ref objectReference) {
    	gv, _ := schema.ParseGroupVersion(ref.APIVersion)
    	gb.graphChanges.Add(&event{
    		virtual:   true,
    		eventType: deleteEvent,
    		gvk:       gv.WithKind(ref.Kind),
    		obj: &metaonly.MetadataOnlyObject{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/garbagecollector_test.go

    	for _, tweak := range tweaks {
    		n = tweak(n)
    	}
    	return n
    }
    
    func makeAddEvent(identity objectReference, owners ...objectReference) *event {
    	gv, err := schema.ParseGroupVersion(identity.APIVersion)
    	if err != nil {
    		panic(err)
    	}
    	return &event{
    		eventType: addEvent,
    		gvk:       gv.WithKind(identity.Kind),
    		obj:       makeObj(identity, owners...),
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  9. pkg/controller/podautoscaler/horizontal.go

    	hpa := hpaShared.DeepCopy()
    	hpaStatusOriginal := hpa.Status.DeepCopy()
    
    	reference := fmt.Sprintf("%s/%s/%s", hpa.Spec.ScaleTargetRef.Kind, hpa.Namespace, hpa.Spec.ScaleTargetRef.Name)
    
    	targetGV, err := schema.ParseGroupVersion(hpa.Spec.ScaleTargetRef.APIVersion)
    	if err != nil {
    		a.eventRecorder.Event(hpa, v1.EventTypeWarning, "FailedGetScale", err.Error())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 63.6K bytes
    - Viewed (0)
  10. pkg/printers/internalversion/printers.go

    		Object: runtime.RawExtension{Object: obj},
    	}
    
    	controllerRef := metav1.GetControllerOf(obj)
    	controllerName := "<none>"
    	if controllerRef != nil {
    		withKind := true
    		gv, err := schema.ParseGroupVersion(controllerRef.APIVersion)
    		if err != nil {
    			return nil, err
    		}
    		gvk := gv.WithKind(controllerRef.Kind)
    		controllerName = formatResourceName(gvk.GroupKind(), controllerRef.Name, withKind)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
Back to top