Method loadJsonConfigV3

cmd/admin/admin.go:293–352

(file string)

}

func (t *cmdAdmin) loadJsonConfigV3(file string) *ConfigV3 {
	b, err := ioutil.ReadFile(file)
	if err != nil {
		log.PanicErrorf(err, "read file '%s' failed", file)
	}

	config := &ConfigV3{}
	if err := json.Unmarshal(b, config); err != nil {
		log.PanicErrorf(err, "json unmarshal failed")
	}

	var proxy = make(map[string]*models.Proxy)
	for _, p := range config.Proxy {
		if proxy[p.Token] != nil {
			log.Panicf("proxy-%s already exists", p.Token)
		}
		proxy[p.Token] = p
	}

	var group = make(map[int]*models.Group)
	var maddr = make(map[string]bool)
	for _, g := range config.Group {
		if g.Id <= 0 || g.Id > models.MaxGroupId {
			log.Panicf("invalid group id = %d", g.Id)
		}
		if group[g.Id] != nil {
			log.Panicf("group-%04d already exists", g.Id)
		}
		if g.Promoting.State != models.ActionNothing {
			log.Panicf("gorup-%04d is promoting", g.Id)
		}
		for _, x := range g.Servers {
			addr := x.Addr
			if maddr[addr] {
				log.Panicf("server %s already exists", addr)
			}
			maddr[addr] = true
		}
		group[g.Id] = g
	}

	var slots = make(map[int]*models.SlotMapping)
	for _, s := range config.Slots {
		if s.Id < 0 || s.Id >= models.MaxSlotNum {
			log.Panicf("invalid slot id = %d", s.Id)
		}
		if slots[s.Id] != nil {
			log.Panicf("slot-%04d already exists", s.Id)
		}
		if s.Action.State != models.ActionNothing {
			log.Panicf("slot-%04d action is not empty", s.Id)
		}
		if g := group[s.GroupId]; g == nil || len(g.Servers) == 0 {
			log.Panicf("slot-%04d with group-%04d doesn't exist or empty", s.Id, s.GroupId)
		}
		slots[s.Id] = s
	}