distributed

Documentation

Index

• Variables
• type Locker
  • func NewLocker(client redis.Cmdable, times ...time.Duration) *Locker
  • func (p *Locker) AutoExpire()
  • func (p *Locker) Lock(key string, call func() error) error

Variables

var ErrLock = errors.New("is lock")

Types

type Locker

type Locker struct {
	// contains filtered or unexported fields
}

Locker 分布式锁.

func NewLocker

func NewLocker(client redis.Cmdable, times ...time.Duration) *Locker

NewLocker 新建分布式锁. times[0] 锁时间, times[1] 续期间隔.

func (*Locker) AutoExpire

func (p *Locker) AutoExpire()

AutoExpire 自动续期.

func (*Locker) Lock

func (p *Locker) Lock(key string, call func() error) error

Lock 锁成功则执行，执行完毕解锁.