(group map[int]*models.Group, v interface{})
| 222 | } |
| 223 | |
| 224 | func (t *cmdAdmin) convertGroupV1(group map[int]*models.Group, v interface{}) { |
| 225 | m := v.(map[string]interface{}) |
| 226 | |
| 227 | var addr = m["addr"].(string) |
| 228 | var gid = int(m["group_id"].(float64)) |
| 229 | var master = m["type"].(string) == "master" |
| 230 | |
| 231 | log.Debugf("found group-%04d %s is master = %t", gid, addr, master) |
| 232 | |
| 233 | if gid <= 0 || gid > models.MaxGroupId { |
| 234 | log.Panicf("invalid group = %d", gid) |
| 235 | } |
| 236 | |
| 237 | if group[gid] == nil { |
| 238 | group[gid] = &models.Group{Id: gid} |
| 239 | } |
| 240 | g := group[gid] |
| 241 | |
| 242 | servers := []*models.GroupServer{} |
| 243 | if master { |
| 244 | servers = append(servers, &models.GroupServer{Addr: addr}) |
| 245 | servers = append(servers, g.Servers...) |
| 246 | } else { |
| 247 | servers = append(servers, g.Servers...) |
| 248 | servers = append(servers, &models.GroupServer{Addr: addr}) |
| 249 | } |
| 250 | g.Servers = servers |
| 251 | } |
| 252 | |
| 253 | func (t *cmdAdmin) handleConfigConvert(d map[string]interface{}) { |
| 254 | defer func() { |
no test coverage detected