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)
}
}
}