ICode9
精准搜索请尝试： 精确搜索
首页
编程语言>
数据库
系统相关
互联网
其他分享
Python
Java
JavaScript
android
PHP
首页 > 其他分享> 文章详细

kubernetes-handbook informer

2021-07-08 11:05:34  阅读：207  来源： 互联网

标签：kubernetes I0708 handbook 28135 go informer kube POD


 

cat<<EOF >informer.go
package main

import (
    "flag"
    "fmt"
    "time"

    "k8s.io/client-go/informers"
    coreinformers "k8s.io/client-go/informers/core/v1"
    "k8s.io/client-go/kubernetes"
    klog "k8s.io/klog/v2"
    //"k8s.io/client-go/pkg/api/v1"
    "k8s.io/api/core/v1"
    "k8s.io/client-go/tools/cache"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/kubectl/pkg/util/logs"
)

// PodLoggingController logs the name and namespace of pods that are added,
// deleted, or updated
type PodLoggingController struct {
    informerFactory informers.SharedInformerFactory
    podInformer     coreinformers.PodInformer
}

// Run starts shared informers and waits for the shared informer cache to
// synchronize.
func (c *PodLoggingController) Run(stopCh chan struct{}) error {
    // Starts all the shared informers that have been created by the factory so
    // far.
    c.informerFactory.Start(stopCh)
    // wait for the initial synchronization of the local cache.
    if !cache.WaitForCacheSync(stopCh, c.podInformer.Informer().HasSynced) {
        return fmt.Errorf("Failed to sync")
    }
    return nil
}

func (c *PodLoggingController) podAdd(obj interface{}) {
    pod := obj.(*v1.Pod)
    klog.Infof("POD CREATED: %s/%s", pod.Namespace, pod.Name)
}

func (c *PodLoggingController) podUpdate(old, new interface{}) {
    oldPod := old.(*v1.Pod)
    newPod := new.(*v1.Pod)
    klog.Infof(
        "POD UPDATED. %s/%s %s",
        oldPod.Namespace, oldPod.Name, newPod.Status.Phase,
    )
}

func (c *PodLoggingController) podDelete(obj interface{}) {
    pod := obj.(*v1.Pod)
    klog.Infof("POD DELETED: %s/%s", pod.Namespace, pod.Name)
}

// NewPodLoggingController creates a PodLoggingController
func NewPodLoggingController(informerFactory informers.SharedInformerFactory) *PodLoggingController {
    podInformer := informerFactory.Core().V1().Pods()

    c := &PodLoggingController{
        informerFactory: informerFactory,
        podInformer:     podInformer,
    }
    podInformer.Informer().AddEventHandler(
        // Your custom resource event handlers.
        cache.ResourceEventHandlerFuncs{
            // Called on creation
            AddFunc: c.podAdd,
            // Called on resource update and every resyncPeriod on existing resources.
            UpdateFunc: c.podUpdate,
            // Called on resource deletion.
            DeleteFunc: c.podDelete,
        },
    )
    return c
}

var kubeconfig string

func init() {
    flag.StringVar(&kubeconfig, "kubeconfig", "", "absolute path to the kubeconfig file")
}

func main() {
    flag.Parse()
    logs.InitLogs()
    defer logs.FlushLogs()

    config, err := clientcmd.BuildConfigFromFlags("", kubeconfig)
    if err != nil {
        panic(err.Error())
    }

    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        klog.Fatal(err)
    }

    factory := informers.NewSharedInformerFactory(clientset, time.Hour*24)
    controller := NewPodLoggingController(factory)
    stop := make(chan struct{})
    defer close(stop)
    err = controller.Run(stop)
    if err != nil {
        klog.Fatal(err)
    }
    select {}
}
EOF

 

 

 

 

root@ubuntu:~/go_learn/informer# go mod init informer
go: creating new go.mod: module informer
root@ubuntu:~/go_learn/informer# ls
go.mod  informer.go
root@ubuntu:~/go_learn/informer# go mod vendor

 

root@ubuntu:~/go_learn/informer# go mod vendor
go: finding module for package k8s.io/client-go/kubernetes
go: finding module for package k8s.io/client-go/tools/clientcmd
go: finding module for package k8s.io/klog/v2
go: finding module for package k8s.io/client-go/informers/core/v1
go: finding module for package k8s.io/api/core/v1
go: finding module for package k8s.io/client-go/tools/cache
go: finding module for package k8s.io/kubectl/pkg/util/logs
go: finding module for package k8s.io/client-go/informers
go: downloading k8s.io/client-go v1.5.2
go: downloading k8s.io/api v0.21.2
go: downloading k8s.io/kubectl v0.21.2
go: found k8s.io/api/core/v1 in k8s.io/api v0.21.2
go: found k8s.io/klog/v2 in k8s.io/klog/v2 v2.9.0
go: found k8s.io/kubectl/pkg/util/logs in k8s.io/kubectl v0.21.2
go: downloading k8s.io/client-go v0.21.2
go: downloading github.com/googleapis/gnostic v0.4.1
go: downloading k8s.io/utils v0.0.0-20201110183641-67b214c5f920
go: downloading github.com/golang/protobuf v1.4.3
go: downloading google.golang.org/appengine v1.6.5
go: downloading google.golang.org/protobuf v1.25.0

 

 

root@ubuntu:~/go_learn/informer# go build ./ -o informer
can't load package: package -o: cannot find package "." in:
        /root/go_learn/informer/vendor/-o
root@ubuntu:~/go_learn/informer# go build . -o informer
can't load package: package -o: cannot find package "." in:
        /root/go_learn/informer/vendor/-o
root@ubuntu:~/go_learn/informer# go build  -o informer .
root@ubuntu:~/go_learn/informer#

 

 

root@ubuntu:~/go_learn/informer# ./informer    -kubeconfig=$HOME/.kube/config
I0708 10:46:09.094719   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-xbdlt
I0708 10:46:09.094890   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-dpwh6
I0708 10:46:09.094907   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-wvdkr
I0708 10:46:09.094919   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-cloud
I0708 10:46:09.094934   28135 informer.go:41] POD CREATED: kube-system/calico-kube-controllers-5978c5f6b5-xk6cq
I0708 10:46:09.094949   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-ubuntu
I0708 10:46:09.094961   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-0
I0708 10:46:09.094975   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-1
I0708 10:46:09.094987   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-ubuntu
I0708 10:46:09.095000   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-centos7
I0708 10:46:09.095012   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-centos7
I0708 10:46:09.095027   28135 informer.go:41] POD CREATED: kube-system/kube-batch-7bfddfb67c-9l8pw
I0708 10:46:09.095039   28135 informer.go:41] POD CREATED: volcano-system/volcano-scheduler-7f48dddb8f-8g6b5
I0708 10:46:09.095052   28135 informer.go:41] POD CREATED: volcano-system/volcano-admission-6cc49fdc5-5zgzs
I0708 10:46:09.095064   28135 informer.go:41] POD CREATED: default/job-1-nginx-0
I0708 10:46:09.095077   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-cloud
I0708 10:46:09.095089   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-cloud
I0708 10:46:09.095112   28135 informer.go:41] POD CREATED: kube-system/calico-node-nwpfl
I0708 10:46:09.095134   28135 informer.go:41] POD CREATED: kube-system/calico-node-blvrv
I0708 10:46:09.095157   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-3
I0708 10:46:09.095179   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-4
I0708 10:46:09.095197   28135 informer.go:41] POD CREATED: volcano-system/volcano-admission-init-qgh9b
I0708 10:46:09.095210   28135 informer.go:41] POD CREATED: default/example-foo-54dc4db9fc-88nd7
I0708 10:46:09.095230   28135 informer.go:41] POD CREATED: kube-system/coredns-546565776c-82jfw
I0708 10:46:09.095246   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-centos7
I0708 10:46:09.095266   28135 informer.go:41] POD CREATED: kube-system/calico-node-6tc54
I0708 10:46:09.095283   28135 informer.go:41] POD CREATED: kube-system/calico-node-rswtj
I0708 10:46:09.095299   28135 informer.go:41] POD CREATED: volcano-system/volcano-controllers-5f5c4f4785-8dbgl
I0708 10:46:09.095311   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-2
I0708 10:46:09.095326   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-5
I0708 10:46:09.095338   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-ubuntu
I0708 10:46:09.095354   28135 informer.go:41] POD CREATED: kube-system/coredns-546565776c-px8bd
I0708 10:46:09.095368   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-6jk97

 

删掉一个deploy

 

root@ubuntu:~# kubectl get deploy
NAME          READY   UP-TO-DATE   AVAILABLE   AGE
example-foo   1/1     1            1           46h
root@ubuntu:~# kubectl delete deploy example-foo
deployment.apps "example-foo" deleted
root@ubuntu:~# kubectl delete deploy example-foo

 

root@ubuntu:~/go_learn/informer# ./informer    -kubeconfig=$HOME/.kube/config
I0708 10:46:09.094719   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-xbdlt
I0708 10:46:09.094890   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-dpwh6
I0708 10:46:09.094907   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-wvdkr
I0708 10:46:09.094919   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-cloud
I0708 10:46:09.094934   28135 informer.go:41] POD CREATED: kube-system/calico-kube-controllers-5978c5f6b5-xk6cq
I0708 10:46:09.094949   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-ubuntu
I0708 10:46:09.094961   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-0
I0708 10:46:09.094975   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-1
I0708 10:46:09.094987   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-ubuntu
I0708 10:46:09.095000   28135 informer.go:41] POD CREATED: kube-system/kube-controller-manager-centos7
I0708 10:46:09.095012   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-centos7
I0708 10:46:09.095027   28135 informer.go:41] POD CREATED: kube-system/kube-batch-7bfddfb67c-9l8pw
I0708 10:46:09.095039   28135 informer.go:41] POD CREATED: volcano-system/volcano-scheduler-7f48dddb8f-8g6b5
I0708 10:46:09.095052   28135 informer.go:41] POD CREATED: volcano-system/volcano-admission-6cc49fdc5-5zgzs
I0708 10:46:09.095064   28135 informer.go:41] POD CREATED: default/job-1-nginx-0
I0708 10:46:09.095077   28135 informer.go:41] POD CREATED: kube-system/kube-scheduler-cloud
I0708 10:46:09.095089   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-cloud
I0708 10:46:09.095112   28135 informer.go:41] POD CREATED: kube-system/calico-node-nwpfl
I0708 10:46:09.095134   28135 informer.go:41] POD CREATED: kube-system/calico-node-blvrv
I0708 10:46:09.095157   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-3
I0708 10:46:09.095179   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-4
I0708 10:46:09.095197   28135 informer.go:41] POD CREATED: volcano-system/volcano-admission-init-qgh9b
I0708 10:46:09.095210   28135 informer.go:41] POD CREATED: default/example-foo-54dc4db9fc-88nd7
I0708 10:46:09.095230   28135 informer.go:41] POD CREATED: kube-system/coredns-546565776c-82jfw
I0708 10:46:09.095246   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-centos7
I0708 10:46:09.095266   28135 informer.go:41] POD CREATED: kube-system/calico-node-6tc54
I0708 10:46:09.095283   28135 informer.go:41] POD CREATED: kube-system/calico-node-rswtj
I0708 10:46:09.095299   28135 informer.go:41] POD CREATED: volcano-system/volcano-controllers-5f5c4f4785-8dbgl
I0708 10:46:09.095311   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-2
I0708 10:46:09.095326   28135 informer.go:41] POD CREATED: default/test-job-default-nginx-5
I0708 10:46:09.095338   28135 informer.go:41] POD CREATED: kube-system/kube-apiserver-ubuntu
I0708 10:46:09.095354   28135 informer.go:41] POD CREATED: kube-system/coredns-546565776c-px8bd
I0708 10:46:09.095368   28135 informer.go:41] POD CREATED: kube-system/kube-proxy-6jk97
I0708 10:49:26.530314   28135 informer.go:47] POD UPDATED. default/example-foo-54dc4db9fc-88nd7 Running
I0708 10:49:27.076371   28135 informer.go:47] POD UPDATED. default/example-foo-54dc4db9fc-88nd7 Running
I0708 10:49:28.845567   28135 informer.go:47] POD UPDATED. default/example-foo-54dc4db9fc-88nd7 Pending
I0708 10:49:29.856741   28135 informer.go:47] POD UPDATED. default/example-foo-54dc4db9fc-88nd7 Pending
I0708 10:49:29.858950   28135 informer.go:55] POD DELETED: default/example-foo-54dc4db9fc-88nd7
I0708 10:49:47.069494   28135 informer.go:47] POD UPDATED. kube-system/kube-batch-7bfddfb67c-9l8pw Running
I0708 10:50:00.168341   28135 informer.go:47] POD UPDATED. kube-system/kube-batch-7bfddfb67c-9l8pw Running

 

 

kubernetes-handbook 

标签：kubernetes,I0708,handbook,28135,go,informer,kube,POD
来源： https://www.cnblogs.com/dream397/p/14985097.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

关于我们 | 联系我们 | 留言反馈

专注分享技术，共同学习，共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有