Method cmdMGET

IceFireDB-PubSub/pkg/router/redisCluster/strings.go:27–49

(s *router.Context)

)

func (r *Router) cmdMGET(s *router.Context) error {
	batch := r.redisCluster.NewBatch()
	argLen := len(s.Args)
	for i := 1; i < argLen; i++ {
		err := batch.Put("GET", s.Args[i])
		if err != nil {
			return err
		}
	}
	var err error
	reply, err := rediscluster.Values(r.redisCluster.RunBatch(batch))
	if err != nil && err != rediscluster.ErrNil {
		return router.WriteError(s.Writer, err)
	}

	if len(reply) == 1 {
		if err, ok := reply[0].(error); ok {
			return router.WriteError(s.Writer, err)
		}
	}
	s.Reply = reply
	return router.RecursivelyWriteObjects(s.Writer, reply...)
}

func (r *Router) cmdDEL(s *router.Context) error {
	argLen := len(s.Args)