У меня сейчас есть функция, которая дает мне объект kubernetes.Interface
, который я активно использую.
func getClusterHandle(restConfig *rest.Config) (kubernetes.Interface, error) {
clientset, err := kubernetes.NewForConfig(restConfig)
if err != nil {
return nil, errors.Wrap(err, "Could not create kubernetes clientset")
}
return clientset, nil
}
Я хочу как-то использовать k8s.io/client-go/tools/cache
, но я немного растерялся.
Кажется, я могу использовать NewFilteredListWatchFromClient
и создать Informer через NewSharedInformer
.
kubernetes.New
принимает rest.Interface
в качестве аргумента и, по-видимому, если бы я мог получить что-то совместимое изInformer
, все это может сработать.Но вот где я выбегаю из дороги.
Мысли?
Примеры?