(key string, m *v1.Message)
| 212 | } |
| 213 | |
| 214 | func (h *handlerDownside) nodeLabel(key string, m *v1.Message) error { |
| 215 | nodeName, ok := m.Metadata["subName"] |
| 216 | if !ok { |
| 217 | h.publishFailedMsg(key, ErrSubNodeName, m) |
| 218 | return errors.New(ErrSubNodeName) |
| 219 | } |
| 220 | labels := new(map[string]string) |
| 221 | err := m.Content.Unmarshal(labels) |
| 222 | if err != nil { |
| 223 | h.publishFailedMsg(key, err.Error(), m) |
| 224 | return errors.Trace(err) |
| 225 | } |
| 226 | err = h.ami.UpdateNodeLabels(nodeName, *labels) |
| 227 | if err != nil { |
| 228 | h.publishFailedMsg(key, err.Error(), m) |
| 229 | return errors.Trace(err) |
| 230 | } |
| 231 | h.publishSuccessMsg(key, m) |
| 232 | return nil |
| 233 | } |
| 234 | |
| 235 | func (h *handlerDownside) labelMultiNodes(key string, m *v1.Message) error { |
| 236 | var nodesLabels map[string]map[string]string |
no test coverage detected