Method cmdCMDEXEC

IceFireDB-PubSub/pkg/router/redisCluster/handle.go:42–74

(s *router.Context)

}

func (r *Router) cmdCMDEXEC(s *router.Context) error {
	var err error

	s.Reply, err = r.redisCluster.Do(s.Cmd, s.Args[1:]...)

	if err != nil && err != rediscluster.ErrNil {
		return err
	}

	if s.Reply == nil {
		return router.WriteBulk(s.Writer, nil)
	}

	switch val := s.Reply.(type) {
	case error:
		return router.WriteError(s.Writer, val)
	case int64:
		return router.WriteInt(s.Writer, val)
	case []byte:
		return router.WriteBulk(s.Writer, val)
	case string:
		return router.WriteSimpleString(s.Writer, val)
	case []interface{}:
		if len(val) == 1 {
			if err, ok := val[0].(error); ok {
				return router.WriteError(s.Writer, err)
			}
		}
		return router.RecursivelyWriteObjects(s.Writer, val...)
	default:
		return router.WriteObjects(s.Writer, s.Reply)
	}
}

func (r *Router) cmdQUIT(s *router.Context) error {
	s.Reply = okReply