Method DelList

internal/repository/cache/post.go:234–270

DelList 删除帖子列表缓存

(ctx context.Context, key string)

// DelList 删除帖子列表缓存
func (c *postCache) DelList(ctx context.Context, key string) error {
	if key == "*" {
		pattern := c.listPrefix + key
		// 使用SCAN命令批量删除,每次扫描100个key
		var cursor uint64
		var keys []string

		for {
			var scanKeys []string
			var err error
			scanKeys, cursor, err = c.client.Scan(ctx, cursor, pattern, 100).Result()
			if err != nil {
				return fmt.Errorf("扫描缓存键失败: %v", err)
			}

			keys = append(keys, scanKeys...)

			if cursor == 0 {
				break
			}
		}

		// 如果有key需要删除,则使用pipeline批量删除
		if len(keys) > 0 {
			pipe := c.client.Pipeline()
			for _, key := range keys {
				pipe.Del(ctx, key)
			}
			if _, err := pipe.Exec(ctx); err != nil {
				return fmt.Errorf("批量删除缓存键失败: %v", err)
			}
		}

		return nil
	}
	return c.client.Del(ctx, c.listKey(key)).Err()
}

// GetPubList 获取已发布帖子列表缓存
func (c *postCache) GetPubList(ctx context.Context, page int, size int) ([]domain.Post, error) {