resolver.go

Documentation: k8s.io/kubernetes/pkg/registry/admissionregistration/resolver

     1  /*
     2  Copyright 2022 The Kubernetes Authors.
     3  
     4  Licensed under the Apache License, Version 2.0 (the "License");
     5  you may not use this file except in compliance with the License.
     6  You may obtain a copy of the License at
     7  
     8      http://www.apache.org/licenses/LICENSE-2.0
     9  
    10  Unless required by applicable law or agreed to in writing, software
    11  distributed under the License is distributed on an "AS IS" BASIS,
    12  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    13  See the License for the specific language governing permissions and
    14  limitations under the License.
    15  */
    16  
    17  package resolver
    18  
    19  import (
    20  	"strings"
    21  
    22  	"k8s.io/apimachinery/pkg/api/meta"
    23  	"k8s.io/apimachinery/pkg/runtime/schema"
    24  	"k8s.io/client-go/discovery"
    25  )
    26  
    27  type ResourceResolver interface {
    28  	Resolve(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error)
    29  }
    30  
    31  type discoveryResourceResolver struct {
    32  	client discovery.DiscoveryInterface
    33  }
    34  
    35  func (d *discoveryResourceResolver) Resolve(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error) {
    36  	gv := gvk.GroupVersion()
    37  	// TODO: refactor this into an efficient gvk --> gvr resolver that remembers hits and re-resolves group/version info on misses
    38  	resources, err := d.client.ServerResourcesForGroupVersion(gv.String())
    39  	if err != nil {
    40  		return schema.GroupVersionResource{}, err
    41  	}
    42  	for _, resource := range resources.APIResources {
    43  		if resource.Kind != gvk.Kind {
    44  			// ignore unrelated kinds
    45  			continue
    46  		}
    47  		if strings.Contains(resource.Name, "/") {
    48  			// ignore subresources
    49  			continue
    50  		}
    51  		if resource.Group != "" && resource.Group != gvk.Group {
    52  			// group didn't match
    53  			continue
    54  		}
    55  		if resource.Version != "" && resource.Version != gvk.Version {
    56  			// version didn't match
    57  			continue
    58  		}
    59  		return gv.WithResource(resource.Name), nil
    60  	}
    61  	return schema.GroupVersionResource{}, &meta.NoKindMatchError{GroupKind: gvk.GroupKind(), SearchedVersions: []string{gvk.Version}}
    62  }
    63  
    64  func NewDiscoveryResourceResolver(client discovery.DiscoveryInterface) (ResourceResolver, error) {
    65  	return &discoveryResourceResolver{client: client}, nil
    66  }
    67  
    68  type ResourceResolverFunc func(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error)
    69  
    70  func (f ResourceResolverFunc) Resolve(gvk schema.GroupVersionKind) (schema.GroupVersionResource, error) {
    71  	return f(gvk)
    72  }
    73
View as plain text