lock

Documentation

Overview

Package lock 一个基于 redis 的分布式锁实现。

Index

• Variables
• type Lock
  • func New(key, value string, client *redis.Client) *Lock
  • func (l *Lock) Lock(ctx context.Context, expire time.Duration) error
  • func (l *Lock) Release(ctx context.Context) error
  • func (l *Lock) Renew(ctx context.Context, expire time.Duration) error
  • func (l *Lock) StartRenew(ctx context.Context, expire time.Duration)
  • func (l *Lock) StopRenew()

Variables

var ErrorNotOk = errors.New("redis write not ok")

ErrorNotOk redis 写失败

Types

type Lock

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

Lock 一个基于redis的锁实现

func New

func New(key, value string, client *redis.Client) *Lock

New 创建一个锁

func (*Lock) Lock

func (l *Lock) Lock(ctx context.Context, expire time.Duration) error

Lock 加锁

func (*Lock) Release

func (l *Lock) Release(ctx context.Context) error

Release 释放锁

func (*Lock) Renew

func (l *Lock) Renew(ctx context.Context, expire time.Duration) error

Renew 续期锁

func (*Lock) StartRenew

func (l *Lock) StartRenew(ctx context.Context, expire time.Duration)

StartRenew 开始续期任务，需要放到 goroutine 中执行

func (*Lock) StopRenew

func (l *Lock) StopRenew()

StopRenew 停掉续期