Method ClearFollowCache

internal/repository/cache/relation.go:77–96

(ctx context.Context, followerID, followeeID int64)

}

func (c *relationCache) ClearFollowCache(ctx context.Context, followerID, followeeID int64) error {
	// 批量删除相关缓存
	keys := []string{
		c.GenerateCacheKey(followerID, "followers", domain.Pagination{}),
		c.GenerateCacheKey(followeeID, "followees", domain.Pagination{}),
		c.GenerateCountCacheKey(followerID, "followers"),
		c.GenerateCountCacheKey(followeeID, "followees"),
	}

	// 使用Pipeline进行批量删除
	pipe := c.client.Pipeline()

	for _, key := range keys {
		pipe.Del(ctx, key)
	}

	_, err := pipe.Exec(ctx)

	return err
}

func (c *relationCache) GenerateCacheKey(userID int64, relationType string, pagination domain.Pagination) string {
	// 生成缓存键