INNER CODE UNIT · Go

func

getseabird/seabird · api/cluster.go:215

func (c *Cluster) GetInformer(gvr schema.GroupVersionResource) informers.GenericInformer {
	if informer, ok := c.sharedInformers[gvr]; ok {
		return informer
	}
	var informer informers.GenericInformer
	informer, err := c.informerFactory.ForResource(gvr)
	if err != nil {
		informer = c.dynamicInformerFactory.ForResource(gvr)
	}
	informer.Informer().SetWatchErrorHandler(func(r *cache.Reflector, err error) {
		if apierrors.IsMethodNotSupported(err) {
			return
		}
		klog.Errorf("%s informer: %s", gvr.Resource, err)
	})
	informer.Informer().SetTransform(func(obj interface{}) (interface{}, error) {
		switch obj := obj.(type) {
		case *unstructured.Unstructured:

View source record →