(s *router.Context)
| 49 | } |
| 50 | |
| 51 | func (r *Router) cmdDEL(s *router.Context) error { |
| 52 | argLen := len(s.Args) |
| 53 | |
| 54 | if argLen == 2 { |
| 55 | reply, err := rediscluster.Int64(r.redisCluster.Do(s.Cmd, s.Args[1])) |
| 56 | if err != nil { |
| 57 | return router.WriteError(s.Writer, err) |
| 58 | } |
| 59 | return router.WriteInt(s.Writer, reply) |
| 60 | } |
| 61 | |
| 62 | batch := r.redisCluster.NewBatch() |
| 63 | for i := 1; i < argLen; i++ { |
| 64 | err := batch.Put("DEL", s.Args[i]) |
| 65 | if err != nil { |
| 66 | return err |
| 67 | } |
| 68 | } |
| 69 | reply, err := rediscluster.Values(r.redisCluster.RunBatch(batch)) |
| 70 | if err != nil && err != rediscluster.ErrNil { |
| 71 | return router.WriteError(s.Writer, err) |
| 72 | } |
| 73 | |
| 74 | var delCount int64 |
| 75 | for _, valInterface := range reply { |
| 76 | if count, ok := valInterface.(int64); ok { |
| 77 | delCount += count |
| 78 | } |
| 79 | } |
| 80 | s.Reply = delCount |
| 81 | return router.WriteInt(s.Writer, delCount) |
| 82 | } |
| 83 | |
| 84 | func (r *Router) cmdEXISTS(s *router.Context) error { |
| 85 | argLen := len(s.Args) |
nothing calls this directly
no test coverage detected