5
का उपयोग कर कुबेरनेट सेवा पर ईवेंट कैसे देखें I क्लाइंट-गो का उपयोग करके कुबर्नेट्स पर कभी भी सेवा बदलते समय सूचित किया जाना चाहूंगा।अपने जाने वाले क्लाइंट
का उपयोग कर कुबेरनेट सेवा पर ईवेंट कैसे देखें I क्लाइंट-गो का उपयोग करके कुबर्नेट्स पर कभी भी सेवा बदलते समय सूचित किया जाना चाहूंगा।अपने जाने वाले क्लाइंट
इस इस तरह किया जा सकता है:
package main
import (
"fmt"
"flag"
"time"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/pkg/api/v1"
"k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/tools/cache"
"k8s.io/client-go/pkg/fields"
)
var (
kubeconfig = flag.String("kubeconfig", "./config", "absolute path to the kubeconfig file")
)
func main() {
flag.Parse()
config, err := clientcmd.BuildConfigFromFlags("", *kubeconfig)
if err != nil {
panic(err.Error())
}
clientset, err := kubernetes.NewForConfig(config)
if err != nil {
panic(err.Error())
}
watchlist := cache.NewListWatchFromClient(clientset.Core().RESTClient(), "services", v1.NamespaceDefault,
fields.Everything())
_, controller := cache.NewInformer(
watchlist,
&v1.Service{},
time.Second * 0,
cache.ResourceEventHandlerFuncs{
AddFunc: func(obj interface{}) {
fmt.Printf("service added: %s \n", obj)
},
DeleteFunc: func(obj interface{}) {
fmt.Printf("service deleted: %s \n", obj)
},
UpdateFunc:func(oldObj, newObj interface{}) {
fmt.Printf("service changed \n")
},
},
)
stop := make(chan struct{})
go controller.Run(stop)
for{
time.Sleep(time.Second)
}
}
इस वजह आयात का संकलन नहीं है। क्या आप इसे अपडेट कर सकते हैं? – orkun1675