redis_scan.go

func (svc Service) clearCacheByMask(ctx context.Context, mask string) error {
   var (
      iter uint64
      keys []string
   )
   for {
      if arr, cursor, err := svc.redisCli.Scan(iter, mask, 100).Result(); err != nil {
         return err
      } else {
         keys = append(keys, arr...)
         iter = cursor
      }
      if iter == 0 {
         break
      }
   }
   if len(keys) > 0 {
      _, err := svc.redisCli.Del(keys...).Result()
      return err
   }
   return nil
}