distributed

Documentation

Overview

Package distributed 分布式.

Locker 基于redis的分布式锁.

Index

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

Variables

var (
	ErrLock   = errors.New("is lock")
	ErrExpire = errors.New("expire time too long")
)

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) Lock

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

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