Method handleProxyCommand

cmd/admin/dashboard.go:358–469

(d map[string]interface{})

}

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

	switch {

	case d["--create-proxy"].(bool):

		addr := utils.ArgumentMust(d, "--addr")

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

	case d["--online-proxy"].(bool):

		addr := utils.ArgumentMust(d, "--addr")

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

	case d["--remove-proxy"].(bool):

		force := d["--force"].(bool)

		for _, token := range t.parseProxyTokens(d) {
			log.Debugf("call rpc remove-proxy to dashboard %s", t.addr)
			if err := c.RemoveProxy(token, force); err != nil {
				log.PanicErrorf(err, "call rpc remove-proxy to dashboard %s failed", t.addr)
			}
			log.Debugf("call rpc remove-proxy OK")
		}

	case d["--reinit-proxy"].(bool):

		switch {

		default:

			for _, token := range t.parseProxyTokens(d) {
				log.Debugf("call rpc reinit-proxy to dashboard %s", t.addr)
				if err := c.ReinitProxy(token); err != nil {
					log.PanicErrorf(err, "call rpc reinit-proxy to dashboard %s failed", t.addr)
				}
				log.Debugf("call rpc reinit-proxy OK")
			}

		case d["--all"].(bool):

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