Method SetPubList

internal/repository/cache/post.go:298–323

SetPubList 设置已发布帖子列表缓存

(ctx context.Context, page int, size int, posts []domain.Post)

// SetPubList 设置已发布帖子列表缓存
func (c *postCache) SetPubList(ctx context.Context, page int, size int, posts []domain.Post) error {
	if page <= 0 || size <= 0 {
		return fmt.Errorf("无效的分页参数: page=%d, size=%d", page, size)
	}

	// 获取分布式锁
	key := fmt.Sprintf("%d_%d", page, size)
	lockKey := c.lockKey("publist:" + key)
	success, err := c.acquireLock(ctx, lockKey, 5*time.Second)
	if err != nil {
		return fmt.Errorf("获取分布式锁失败: %v", err)
	}
	if !success {
		return fmt.Errorf("获取分布式锁失败: 锁已被占用")
	}
	defer c.releaseLock(ctx, lockKey)

	data, err := json.Marshal(posts)
	if err != nil {
		return fmt.Errorf("序列化已发布帖子列表数据失败: %v", err)
	}

	// 列表缓存使用随机过期时间
	randomExpiration := c.expiration + time.Duration(rand.Int63n(300))*time.Second
	return c.client.Set(ctx, c.pubListKey(key), data, randomExpiration).Err()
}

// DelPubList 删除已发布帖子列表缓存
func (c *postCache) DelPubList(ctx context.Context, key string) error {