Method handleSlotsCommand

cmd/admin/dashboard.go:204–280

(d map[string]interface{})

}

func (t *cmdDashboard) handleSlotsCommand(d map[string]interface{}) {
	c := t.newTopomClient()

	switch {

	case d["--slots-status"].(bool):

		log.Debugf("call rpc slots to dashboard %s", t.addr)
		o, err := c.Slots()
		if err != nil {
			log.PanicErrorf(err, "call rpc slots to dashboard %s failed", t.addr)
		}
		log.Debugf("call rpc slots OK")

		b, err := json.MarshalIndent(o, "", "    ")
		if err != nil {
			log.PanicErrorf(err, "json marshal failed")
		}
		fmt.Println(string(b))

	case d["--slots-assign"].(bool) && d["--offline"].(bool):

		beg := utils.ArgumentIntegerMust(d, "--beg")
		end := utils.ArgumentIntegerMust(d, "--end")

		slots := []*models.SlotMapping{}
		for i := beg; i <= end; i++ {
			slots = append(slots, &models.SlotMapping{
				Id: i,
			})
		}

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

		log.Debugf("call rpc slots-assign to dashboard %s", t.addr)
		if err := c.SlotsAssignOffline(slots); err != nil {
			log.PanicErrorf(err, "call rpc slots-assign to dashboard %s failed", t.addr)
		}
		log.Debugf("call rpc slots-assign OK")

	case d["--slots-assign"].(bool) && !d["--offline"].(bool):

		beg := utils.ArgumentIntegerMust(d, "--beg")
		end := utils.ArgumentIntegerMust(d, "--end")
		gid := utils.ArgumentIntegerMust(d, "--gid")

		slots := []*models.SlotMapping{}
		for i := beg; i <= end; i++ {
			slots = append(slots, &models.SlotMapping{
				Id: i, GroupId: gid,
			})