Merge pull request kcp-dev#42 from xrstf/kcp-1.28

✨ Rebase kcp modifications onto v0.16.2

Author: kcp-ci-bot

.prow.yaml

@@ -0,0 +1,13 @@
+presubmits:
+ - name: pull-controller-runtime-everything
+ always_run: true
+ decorate: true
+ clone_uri: "ssh://git@github.com/kcp-dev/controller-runtime.git"
+ labels:
+ preset-goproxy: "true"
+ spec:
+ containers:
+ - image: ghcr.io/kcp-dev/infra/build:1.20.9-1
+ command:
+ - make
+ - test

DOWNSTREAM_OWNERS

@@ -0,0 +1,8 @@
+approvers:
+ - davidfestal
+ - ncdc
+ - stevekuznetsov
+ - sttts
+reviewers:
+ - fabianvf
+ - varshaprasad96

DOWNSTREAM_OWNERS_ALIASES

@@ -73,10 +73,11 @@ $(GO_APIDIFF): $(TOOLS_DIR)/go.mod # Build go-apidiff from tools folder.
 $(CONTROLLER_GEN): $(TOOLS_DIR)/go.mod # Build controller-gen from tools folder.
 cd $(TOOLS_DIR) && go build -tags=tools -o bin/controller-gen sigs.k8s.io/controller-tools/cmd/controller-gen
 
-$(GOLANGCI_LINT): .github/workflows/golangci-lint.yml # Download golanci-lint using hack script into tools folder.
-hack/ensure-golangci-lint.sh \
--b $(TOOLS_BIN_DIR) \
-$(shell cat .github/workflows/golangci-lint.yml | grep "version: v" | sed 's/.*version: //')
+$(GOLANGCI_LINT): .github/workflows/golangci-lint.yml # Download golangci-lint using hack script into tools folder.
+GOBIN=$(abspath $(TOOLS_BIN_DIR)) go install github.com/golangci/golangci-lint/cmd/golangci-lint@$(shell cat .github/workflows/golangci-lint.yml | grep "version: v" | sed 's/.*version: //')
+
+.PHONY: tools
+tools: $(GO_APIDIFF) $(CONTROLLER_GEN) $(GOLANGCI_LINT)
 
 ## --------------------------------------
 ## Linting

Makefile

@@ -936,6 +936,10 @@ github.com/julienschmidt/httprouter v1.3.0/go.mod h1:JR6WtHb+2LUe8TCKY3cZOxFyyO8
 github.com/jung-kurt/gofpdf v1.0.0/go.mod h1:7Id9E/uU8ce6rXgefFLlgrJj/GYY22cpxn+r32jIOes=
 github.com/jung-kurt/gofpdf v1.0.3-0.20190309125859-24315acbbda5/go.mod h1:7Id9E/uU8ce6rXgefFLlgrJj/GYY22cpxn+r32jIOes=
 github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51/go.mod h1:CzGEWj7cYgsdH8dAjBGEr58BoE7ScuLd+fwFZ44+/x8=
+github.com/kcp-dev/apimachinery/v2 v2.0.0-alpha.0.0.20230926071920-57d168bcbe34 h1:tom0JX5OmAeOOmkGv8LaYHDtA1xAKDiQL5U0vhYYgdM=
+github.com/kcp-dev/apimachinery/v2 v2.0.0-alpha.0.0.20230926071920-57d168bcbe34/go.mod h1:cWoaYGHl1nlzdEM2xvMzIASkEZJZLSf5nhe17M7wDhw=
+github.com/kcp-dev/logicalcluster/v3 v3.0.4 h1:q7KngML/QM7sWl8aVzmfZF0TPMnBwYNxsPKfwUvvBvU=
+github.com/kcp-dev/logicalcluster/v3 v3.0.4/go.mod h1:EWBUBxdr49fUB1cLMO4nOdBWmYifLbP1LfoL20KkXYY=
 github.com/kisielk/errcheck v1.1.0/go.mod h1:EZBBE59ingxPouuu3KfxchcWSUPOHkagtvWXihfKN4Q=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=

examples/scratch-env/go.sum

@@ -10,6 +10,8 @@ require (
 github.com/go-logr/zapr v1.2.4
 github.com/google/go-cmp v0.5.9
 github.com/google/gofuzz v1.2.0
+github.com/kcp-dev/apimachinery/v2 v2.0.0-alpha.0.0.20230926071920-57d168bcbe34
+github.com/kcp-dev/logicalcluster/v3 v3.0.4
 github.com/onsi/ginkgo/v2 v2.11.0
 github.com/onsi/gomega v1.27.10
 github.com/prometheus/client_golang v1.16.0

go.mod

@@ -214,6 +214,10 @@ github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnr
 github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
 github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024/go.mod h1:6v2b51hI/fHJwM22ozAgKL4VKDeJcHhJFhtBdhmNjmU=
 github.com/jstemmer/go-junit-report v0.9.1/go.mod h1:Brl9GWCQeLvo8nXZwPNNblvFj/XSXhF0NWZEnDohbsk=
+github.com/kcp-dev/apimachinery/v2 v2.0.0-alpha.0.0.20230926071920-57d168bcbe34 h1:tom0JX5OmAeOOmkGv8LaYHDtA1xAKDiQL5U0vhYYgdM=
+github.com/kcp-dev/apimachinery/v2 v2.0.0-alpha.0.0.20230926071920-57d168bcbe34/go.mod h1:cWoaYGHl1nlzdEM2xvMzIASkEZJZLSf5nhe17M7wDhw=
+github.com/kcp-dev/logicalcluster/v3 v3.0.4 h1:q7KngML/QM7sWl8aVzmfZF0TPMnBwYNxsPKfwUvvBvU=
+github.com/kcp-dev/logicalcluster/v3 v3.0.4/go.mod h1:EWBUBxdr49fUB1cLMO4nOdBWmYifLbP1LfoL20KkXYY=
 github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
 github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
 github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=

go.sum

@@ -22,6 +22,7 @@ import (
 "net/http"
 "time"
 
+"github.com/kcp-dev/apimachinery/v2/third_party/informers"
 corev1 "k8s.io/api/core/v1"
 "k8s.io/apimachinery/pkg/api/meta"
 "k8s.io/apimachinery/pkg/fields"
@@ -159,6 +160,14 @@ type Options struct {
 // instead of `reconcile.Result{}`.
 SyncPeriod *time.Duration
 
+// NewInformerFunc is a function that is used to create SharedIndexInformers.
+// Defaults to cache.NewSharedIndexInformer from client-go
+NewInformerFunc client.NewInformerFunc
+
+// Indexers is the indexers that the informers will be configured to use.
+// Will always have the standard NamespaceIndex.
+Indexers toolscache.Indexers
+
 // ReaderFailOnMissingInformer configures the cache to return a ErrResourceNotCached error when a user
 // requests, using Get() and List(), a resource the cache does not already have an informer for.
 //
@@ -201,9 +210,6 @@ type Options struct {
 // ByObject restricts the cache's ListWatch to the desired fields per GVK at the specified object.
 // object, this will fall through to Default* settings.
 ByObject map[client.Object]ByObject
-
-// newInformer allows overriding of NewSharedIndexInformer for testing.
-newInformer *func(toolscache.ListerWatcher, runtime.Object, time.Duration, toolscache.Indexers) toolscache.SharedIndexInformer
 }
 
 // ByObject offers more fine-grained control over the cache's ListWatch by object.
@@ -354,7 +360,7 @@ func newCache(restConfig *rest.Config, opts Options) newCacheFunc {
 },
 Transform: config.Transform,
 UnsafeDisableDeepCopy: pointer.BoolDeref(config.UnsafeDisableDeepCopy, false),
-NewInformer: opts.newInformer,
+NewInformer: opts.NewInformerFunc,
 }),
 readerFailOnMissingInformer: opts.ReaderFailOnMissingInformer,
 }
@@ -438,6 +444,10 @@ func defaultOpts(config *rest.Config, opts Options) (Options, error) {
 if opts.SyncPeriod == nil {
 opts.SyncPeriod = &defaultSyncPeriod
 }
+
+if opts.NewInformerFunc == nil {
+opts.NewInformerFunc = informers.NewSharedIndexInformer
+}
 return opts, nil
 }
 

pkg/cache/cache.go

@@ -26,6 +26,7 @@ import (
 "strings"
 "time"
 
+kcpcache "github.com/kcp-dev/apimachinery/v2/pkg/cache"
 . "github.com/onsi/ginkgo/v2"
 . "github.com/onsi/gomega"
 corev1 "k8s.io/api/core/v1"
@@ -545,13 +546,13 @@ func NonBlockingGetTest(createCacheFunc func(config *rest.Config, opts cache.Opt
 
 By("creating the informer cache")
 v := reflect.ValueOf(&opts).Elem()
-newInformerField := v.FieldByName("newInformer")
-newFakeInformer := func(_ kcache.ListerWatcher, _ runtime.Object, _ time.Duration, _ kcache.Indexers) kcache.SharedIndexInformer {
+newInformerField := v.FieldByName("NewInformerFunc")
+newFakeInformer := func(_ kcache.ListerWatcher, _ runtime.Object, _ time.Duration, _ kcache.Indexers) kcpcache.ScopeableSharedIndexInformer {
 return &controllertest.FakeInformer{Synced: false}
 }
 reflect.NewAt(newInformerField.Type(), newInformerField.Addr().UnsafePointer()).
 Elem().
-Set(reflect.ValueOf(&newFakeInformer))
+Set(reflect.ValueOf(newFakeInformer))
 informerCache, err = createCacheFunc(cfg, opts)
 Expect(err).NotTo(HaveOccurred())
 By("running the cache and waiting for it to sync")

pkg/cache/cache_test.go

@@ -31,6 +31,8 @@ import (
 "sigs.k8s.io/controller-runtime/pkg/cache/internal"
 "sigs.k8s.io/controller-runtime/pkg/client"
 "sigs.k8s.io/controller-runtime/pkg/client/apiutil"
+
+"github.com/kcp-dev/logicalcluster/v3"
 )
 
 var (
@@ -222,6 +224,13 @@ func indexByField(informer Informer, field string, extractValue client.IndexerFu
 }
 ns := meta.GetNamespace()
 
+keyFunc := internal.KeyToNamespacedKey
+if clusterName := logicalcluster.From(obj); !clusterName.Empty() {
+keyFunc = func(ns, val string) string {
+return internal.KeyToClusteredKey(clusterName.String(), ns, val)
+}
+}
+
 rawVals := extractValue(obj)
 var vals []string
 if ns == "" {
@@ -231,14 +240,15 @@ func indexByField(informer Informer, field string, extractValue client.IndexerFu
 // 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)
+vals[i] = keyFunc(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)
+vals[i+len(rawVals)] = keyFunc("", rawVal)
 }
 }