【发布时间】：2020-10-30 17:49:38
【问题描述】：
我正在开发一个动态 kubernetes 通知器来监视我的 kubernetes 集群中的事件和所有 kubernetes 组件的发现。
但是，当我尝试通过InClusterConfig 方法访问KUBECONFIG 时，我收到以下错误：
// go run main.go
FATA[0000] could not get config error="unable to load in-cluster configuration, KUBERNETES_SERVICE_HOST and KUBERNETES_SERVICE_PORT must be defined"
exit status 1
我在 github 上的 kubernetes repo 以及 stackoverflow 上发现了与此相关的各种类似问题，但找不到任何解决方案或解决方法。 [kubernetes issue，kubernetes issue，stackoverflow similar question，stackoverflow similar question]
以下是go代码和go.mod文件
转码：
package main
import (
"os"
"os/signal"
"github.com/sirupsen/logrus"
v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/client-go/dynamic"
"k8s.io/client-go/dynamic/dynamicinformer"
"k8s.io/client-go/rest"
"k8s.io/client-go/tools/cache"
"k8s.io/client-go/tools/clientcmd"
)
func main() {
cfg, err := restConfig()
if err != nil {
logrus.WithError(err).Fatal("could not get config")
}
// Grab a dynamic interface that we can create informers from
dc, err := dynamic.NewForConfig(cfg)
if err != nil {
logrus.WithError(err).Fatal("could not generate dynamic client for config")
}
// Create a factory object that we can say "hey, I need to watch this resource"
// and it will give us back an informer for it
f := dynamicinformer.NewFilteredDynamicSharedInformerFactory(dc, 0, v1.NamespaceAll, nil)
// Retrieve a "GroupVersionResource" type that we need when generating our informer from our dynamic factory
gvr, _ := schema.ParseResourceArg("deployments.v1.apps")
// Finally, create our informer for deployments!
i := f.ForResource(*gvr)
stopCh := make(chan struct{})
go startWatching(stopCh, i.Informer())
sigCh := make(chan os.Signal, 0)
signal.Notify(sigCh, os.Kill, os.Interrupt)
<-sigCh
close(stopCh)
}
func restConfig() (*rest.Config, error) {
kubeCfg, err := rest.InClusterConfig()
if kubeconfig := os.Getenv("KUBECONFIG"); kubeconfig != "" {
kubeCfg, err = clientcmd.BuildConfigFromFlags("", kubeconfig)
}
// var kubeCfg *string
// if home := homedir.HomeDir(); home != "" {
// kubeCfg = flag.String("kubeconfig", filepath.Join(home, ".kube", "config"), "(optional) absolute path to the kubeconfig file")
// } else {
// kubeCfg = flag.String("kubeconfig", "", "absolute path to the kubeconfig file")
// }
// flag.Parse()
// kubeCfg, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
//testing-ends
if err != nil {
return nil, err
}
return kubeCfg, nil
}
func startWatching(stopCh <-chan struct{}, s cache.SharedIndexInformer) {
handlers := cache.ResourceEventHandlerFuncs{
AddFunc: func(obj interface{}) {
u := obj.(*unstructured.Unstructured)
logrus.WithFields(logrus.Fields{
"name": u.GetName(),
"namespace": u.GetNamespace(),
"labels": u.GetLabels(),
}).Info("received add event!")
},
UpdateFunc: func(oldObj, obj interface{}) {
logrus.Info("received update event!")
},
DeleteFunc: func(obj interface{}) {
logrus.Info("received update event!")
},
}
s.AddEventHandler(handlers)
s.Run(stopCh)
}
go.mod 文件：
module discovery-test
go 1.15
require (
github.com/googleapis/gnostic v0.5.3 // indirect
github.com/gregjones/httpcache v0.0.0-20190611155906-901d90724c79 // indirect
github.com/imdario/mergo v0.3.11 // indirect
github.com/peterbourgon/diskv v2.0.1+incompatible // indirect
github.com/sirupsen/logrus v1.7.0
golang.org/x/crypto v0.0.0-20201016220609-9e8e0b390897 // indirect
golang.org/x/net v0.0.0-20201029055024-942e2f445f3c // indirect
golang.org/x/oauth2 v0.0.0-20200902213428-5d25da1a8d43 // indirect
golang.org/x/time v0.0.0-20200630173020-3af7569d3a1e // indirect
k8s.io/apimachinery v0.17.0
k8s.io/client-go v0.17.0
k8s.io/klog v1.0.0 // indirect
k8s.io/utils v0.0.0-20201027101359-01387209bb0d // indirect
)
【问题讨论】：
-
这是因为您试图从集群外部获取集群配置。当您运行
go run main.go时，您正在本地计算机 (127.0.0.1) 上运行您的程序，您无法从该计算机访问集群。如果您构建二进制文件和容器镜像并通过任何 K8s 工作负载（Pod、Deployment、StatefulSet 等）部署它，该程序应该可以工作。在这种情况下，该程序将轻松发现服务主机和端口，从而获得集群配置。 -
@ShudiptaSharma 如果我构建一个容器映像并将其部署为 Pod，那么在部署后我将如何通过这个动态通知器监视事件？
-
看来你想写一个部署控制器。在这种情况下，请参阅关于开源的示例控制器存储库。
-
@ShudiptaSharma 我曾与控制器/操作员合作过，但我打算用它来发现 Kubernetes 资源。有没有更好的替代方法来发现 Kubernetes 资源而不是使用控制器？
-
据我了解，当我们想要观察并对某些资源上的添加/更新/删除事件采取行动时，我们只需编写一个控制器或操作符（如果需要）。在这种情况下，我们定义了通知者、列表者、kubeclient/crdclient 并从协调方法中使用它们。由于您有一个动态的告密者，您可以将它用于这样的控制器/操作员。我想你已经知道如何处理这种情况了。
标签： go kubernetes client-go