func()

in watcher/handlerConfigmap.go [37:61]


func (c *CMHandler) update(newObj interface{}) {
	cm, ok := newObj.(*v1.ConfigMap)
	if !ok {
		log.Println("In ConfigMapHandler Update; cannot cast to *v1.ConfigMap")
		return
	}

	annotations := cm.GetAnnotations()
	if val, ok := annotations["ats-configmap"]; ok {
		if val != "true" {
			return
		}
	} else {
		return
	}

	for currKey, currVal := range cm.Data {
		msg, err := c.Ep.ATSManager.ConfigSet(currKey, currVal) // update ATS
		if err != nil {
			log.Println(err)
		} else {
			log.Println(msg)
		}
	}
}