Watcher snippet for k8

go-cient.go

var stopCh <- chan struct{}
	watcher := cache.NewListWatchFromClient(k8Client.RESTClient(),"nodes", metaV1.NamespaceAll,fields.Everything())
	_, controller := cache.NewInformer(
		watcher,
		&coreV1.Node{},
		time.Second * 10,
		cache.ResourceEventHandlerFuncs{
			AddFunc: func(obj interface{}) {
				node, ok := obj.(*coreV1.Node)
				if !ok {
					log.Fatal().
						Str("object_type",fmt.Sprintf("%T",node)).
						Msg("list/watch returned non-node object")
				}
				log.Info().Str("node_name",node.Name)

				//annotations := node.GetAnnotations()
				//if val,ok := annotations["flannel.alpha.coreos.com/public-ip-overwrite"]; ok {
				//
				//}
				time.Sleep(time.Second * 5)
				log.Printf("handling node %s", node.GetName())
			},
		},
	)

	controller.Run(stopCh)