/* Copyright 2018 The Kubernetes Authors. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package cache import ( "context" "fmt" "reflect" "strings" apimeta "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/tools/cache" "sigs.k8s.io/controller-runtime/pkg/cache/internal" "sigs.k8s.io/controller-runtime/pkg/client" "sigs.k8s.io/controller-runtime/pkg/client/apiutil" ) var ( _ Informers = &informerCache{} _ client.Reader = &informerCache{} _ Cache = &informerCache{} ) // informerCache is a Kubernetes Object cache populated from InformersMap. informerCache wraps an InformersMap. type informerCache struct { *internal.InformersMap } // Get implements Reader func (ip *informerCache) Get(ctx context.Context, key client.ObjectKey, out runtime.Object) error { gvk, err := apiutil.GVKForObject(out, ip.Scheme) if err != nil { return err } cache, err := ip.InformersMap.Get(gvk, out) if err != nil { return err } return cache.Reader.Get(ctx, key, out) } // List implements Reader func (ip *informerCache) List(ctx context.Context, opts *client.ListOptions, out runtime.Object) error { gvk, err := apiutil.GVKForObject(out, ip.Scheme) if err != nil { return err } if !strings.HasSuffix(gvk.Kind, "List") { return fmt.Errorf("non-list type %T (kind %q) passed as output", out, gvk) } // we need the non-list GVK, so chop off the "List" from the end of the kind gvk.Kind = gvk.Kind[:len(gvk.Kind)-4] _, isUnstructured := out.(*unstructured.UnstructuredList) var cacheTypeObj runtime.Object if isUnstructured { u := &unstructured.Unstructured{} u.SetGroupVersionKind(gvk) cacheTypeObj = u } else { itemsPtr, err := apimeta.GetItemsPtr(out) if err != nil { return nil } // http://knowyourmeme.com/memes/this-is-fine elemType := reflect.Indirect(reflect.ValueOf(itemsPtr)).Type().Elem() cacheTypeValue := reflect.Zero(reflect.PtrTo(elemType)) var ok bool cacheTypeObj, ok = cacheTypeValue.Interface().(runtime.Object) if !ok { return fmt.Errorf("cannot get cache for %T, its element %T is not a runtime.Object", out, cacheTypeValue.Interface()) } } cache, err := ip.InformersMap.Get(gvk, cacheTypeObj) if err != nil { return err } return cache.Reader.List(ctx, opts, out) } // GetInformerForKind returns the informer for the GroupVersionKind func (ip *informerCache) GetInformerForKind(gvk schema.GroupVersionKind) (cache.SharedIndexInformer, error) { // Map the gvk to an object obj, err := ip.Scheme.New(gvk) if err != nil { return nil, err } i, err := ip.InformersMap.Get(gvk, obj) if err != nil { return nil, err } return i.Informer, err } // GetInformer returns the informer for the obj func (ip *informerCache) GetInformer(obj runtime.Object) (cache.SharedIndexInformer, error) { gvk, err := apiutil.GVKForObject(obj, ip.Scheme) if err != nil { return nil, err } i, err := ip.InformersMap.Get(gvk, obj) if err != nil { return nil, err } return i.Informer, err } // IndexField adds an indexer to the underlying cache, using extraction function to get // value(s) from the given field. This index can then be used by passing a field selector // to List. For one-to-one compatibility with "normal" field selectors, only return one value. // The values may be anything. They will automatically be prefixed with the namespace of the // given object, if present. The objects passed are guaranteed to be objects of the correct type. func (ip *informerCache) IndexField(obj runtime.Object, field string, extractValue client.IndexerFunc) error { informer, err := ip.GetInformer(obj) if err != nil { return err } return indexByField(informer.GetIndexer(), field, extractValue) } func indexByField(indexer cache.Indexer, field string, extractor client.IndexerFunc) error { indexFunc := func(objRaw interface{}) ([]string, error) { // TODO(directxman12): check if this is the correct type? obj, isObj := objRaw.(runtime.Object) if !isObj { return nil, fmt.Errorf("object of type %T is not an Object", objRaw) } meta, err := apimeta.Accessor(obj) if err != nil { return nil, err } ns := meta.GetNamespace() rawVals := extractor(obj) var vals []string if ns == "" { // if we're not doubling the keys for the namespaced case, just re-use what was returned to us vals = rawVals } else { // if we need to add non-namespaced versions too, double the length vals = make([]string, len(rawVals)*2) } for i, rawVal := range rawVals { // save a namespaced variant, so that we can ask // "what are all the object matching a given index *in a given namespace*" vals[i] = internal.KeyToNamespacedKey(ns, rawVal) if ns != "" { // if we have a namespace, also inject a special index key for listing // regardless of the object namespace vals[i+len(rawVals)] = internal.KeyToNamespacedKey("", rawVal) } } return vals, nil } return indexer.AddIndexers(cache.Indexers{internal.FieldIndexName(field): indexFunc}) }