locks

Documentation

Index

• type LockManager
• type RedisLockManager
  • func NewRedisLockManager(redisNClient *redis.Client) *RedisLockManager
  • func (r *RedisLockManager) Lock(ctx context.Context, key string) error
  • func (r *RedisLockManager) Unlock(ctx context.Context) error

Types

type LockManager

type LockManager interface {
	Lock(context.Context, string) error
	Unlock(context.Context) error
}

type RedisLockManager

type RedisLockManager struct {
	RNonClusteredClient *redis.Client
	RedisLockClient     *redislock.Client
	RedisLock           *redislock.Lock
}

func NewRedisLockManager

func NewRedisLockManager(redisNClient *redis.Client) *RedisLockManager

func (*RedisLockManager) Lock

func (r *RedisLockManager) Lock(ctx context.Context, key string) error

func (*RedisLockManager) Unlock

func (r *RedisLockManager) Unlock(ctx context.Context) error