Method handleConfigRestore

cmd/admin/admin.go:354–399

(d map[string]interface{})

}

func (t *cmdAdmin) handleConfigRestore(d map[string]interface{}) {
	store := t.newTopomStore(d)
	defer store.Close()

	config := t.loadJsonConfigV3(utils.ArgumentMust(d, "--config-restore"))

	if !d["--confirm"].(bool) {
		b, err := json.MarshalIndent(config, "", "    ")
		if err != nil {
			log.PanicErrorf(err, "json marshal failed")
		}
		fmt.Println(string(b))
		return
	}

	proxy, err := store.ListProxy()
	if err != nil {
		log.PanicErrorf(err, "list proxy failed")
	}
	group, err := store.ListGroup()
	if err != nil {
		log.PanicErrorf(err, "list group failed")
	}

	if len(group) != 0 || len(proxy) != 0 {
		log.Panicf("product %s is not empty", t.product)
	}

	for _, s := range config.Slots {
		if err := store.UpdateSlotMapping(s); err != nil {
			log.PanicErrorf(err, "restore slot-%04d failed", s.Id)
		}
	}

	for _, g := range config.Group {
		if err := store.UpdateGroup(g); err != nil {
			log.PanicErrorf(err, "restore group-%04d failed", g.Id)
		}
	}

	for _, p := range config.Proxy {
		if err := store.UpdateProxy(p); err != nil {
			log.PanicErrorf(err, "restore proxy-%s failed", p.Token)
		}
	}
}

func (t *cmdAdmin) handleDashboardList(d map[string]interface{}) {
	client := t.newTopomClient(d)