redlock

Documentation

Index

• Variables
• type Client
  • func NewClient(c *redis.Client) *Client
  • func (c *Client) NewMutex(key string) *Mutex
• type Mutex
  • func New(c *Client, key string) *Mutex
  • func (m *Mutex) Lock(d ...time.Duration) error
  • func (m *Mutex) Unlock() error
  • func (m *Mutex) WithContext(ctx context.Context) *Mutex

Variables

var (
	LockTime      = 3 * time.Second               //默认lock时间
	RetryInterval = 100 * time.Millisecond        //默认间隔时间
	Retries       = int(LockTime / RetryInterval) //默认重试次数
)

var ErrCanced = errors.New("canced")

Types

type Client

type Client struct {
	*redis.Client
}

func NewClient

func NewClient(c *redis.Client) *Client

func (*Client) NewMutex

func (c *Client) NewMutex(key string) *Mutex

type Mutex

type Mutex struct {
	*Client
	// contains filtered or unexported fields
}

Mutext定义

func New

func New(c *Client, key string) *Mutex

key name 不能为空

func (*Mutex) Lock

func (m *Mutex) Lock(d ...time.Duration) error

锁

func (*Mutex) Unlock

func (m *Mutex) Unlock() error

解锁

func (*Mutex) WithContext

func (m *Mutex) WithContext(ctx context.Context) *Mutex

设置context