fake-clientのRESTClientをIndexerInformerに渡すとpanicする

Kubernetes client-goのIndexerInformerを使った実装で、以下のようにclientsetからRESTClientを取得してcacheを作成しようとしたところ、go testでfake clientを渡した際にclient内部でパニックが発生していた。

	cachedLw := cache.NewListWatchFromClient(clientset.CoreV1().RESTClient(), resource, "", fields.Everything())
	indexer, informer := cache.NewIndexerInformer(cachedLw, &v1.Pod{}, 0, cache.ResourceEventHandlerFuncs{
		AddFunc: func(obj interface{}) {
      // on create...
    },
    UpdateFunc: func(old interface{}, new interface{}) {
      // on update...
    },
		DeleteFunc: func(obj interface{}) {
      // on delete...
    },
  }, cache.Indexers{})

↓

E0119 10:17:45.953340   57221 runtime.go:79] Observed a panic: "invalid memory address or nil pointer dereference" (runtime error: invalid memory address or nil pointer dereference)

fake clientではなく実際のkubernetesに接続すると問題なく動作していた。原因を調べてみると古いissueが見つかった。
どうもfake-clientのRESTClient()メソッドは動作する形では実装されていない模様。以下のような実装で、RESTClient()は常にnilを返す。

• https://github.com/kubernetes/client-go/blob/v0.29.1/kubernetes/typed/core/v1/fake/fake_core_client.go#L97-L99

// RESTClient returns a RESTClient that is used to communicate
// with API server by this client implementation.
func (c *FakeCoreV1) RESTClient() rest.Interface {
	var ret *rest.RESTClient
	return ret
}

go testでcacheは必要ないので、cache.ListerWatcherをmockにする形で解決した。

import (
	"context"
	"testing"

	v1 "k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/watch"
	k "k8s.io/client-go/kubernetes"
	"k8s.io/client-go/kubernetes/fake"
	"k8s.io/client-go/tools/cache"
)

type podListWatcher struct {
	clientset k.Interface
}

// ListFunc knows how to list resources
func (w *podListWatcher) List(options metav1.ListOptions) (runtime.Object, error) {
	return w.clientset.CoreV1().Pods("").List(context.TODO(), options)
}

// WatchFunc knows how to watch resources
func (w *podListWatcher) Watch(options metav1.ListOptions) (watch.Interface, error) {
	return w.clientset.CoreV1().Pods("").Watch(context.TODO(), options)
}

func Test(t *testing.T) {
	clientset := fake.NewSimpleClientset()
	// prepare fake client...

	lw := &podListWatcher{clientset: clientset}
	indexer, informer := cache.NewIndexerInformer(lw, &v1.Pod{}, 0, cache.ResourceEventHandlerFuncs{
		AddFunc: func(obj interface{}) {
			// on create...
		},
		UpdateFunc: func(old interface{}, new interface{}) {
			// on update...
		},
		DeleteFunc: func(obj interface{}) {
			// on delete...
		},
	}, cache.Indexers{})
}