辅助方法: 获取分布式锁
(ctx context.Context, lockKey string, expiration time.Duration)
| 445 | |
| 446 | // 辅助方法: 获取分布式锁 |
| 447 | func (c *postCache) acquireLock(ctx context.Context, lockKey string, expiration time.Duration) (bool, error) { |
| 448 | return c.client.SetNX(ctx, lockKey, "1", expiration).Result() |
| 449 | } |
| 450 | |
| 451 | // 辅助方法: 释放分布式锁 |
| 452 | func (c *postCache) releaseLock(ctx context.Context, lockKey string) { |
no test coverage detected