lock

Documentation

Index

• Variables
• func CreateLease(ctx context.Context, client *clientv3.Client, leaseTTL int64) (*clientv3.LeaseGrantResponse, clientv3.LeaseID, error)
• func GetFirstCrt(ctx context.Context, client *clientv3.Client, key string) (*clientv3.GetResponse, map[string]string, error)
• func GetRemoteLockState(ctx context.Context, client *clientv3.Client, lockName string) (bool, int64, error)
• func PutWithLease(ctx context.Context, client *clientv3.Client, key string, value string, ...) (*clientv3.PutResponse, error)
• type Locker
  • func NewLocker(c *clientv3.Client, owner string, lock string, ttl int) *Locker
  • func (l *Locker) Close()
  • func (l *Locker) GetLockID() string
  • func (l *Locker) GetLockRev() int64
  • func (l *Locker) Lock(ctx context.Context) error
  • func (l *Locker) Unlock(ctx context.Context) error

Variables

var (
	ErrLockerClosed           = errors.New("locker has closed")
	ErrLocked                 = errors.New("locked by another session")
	ErrSessionExpired         = errors.New("session is expired")
	ErrLockFailed             = errors.New("lock failed")
	ErrLockRemoteNoneNeedTodo = errors.New("remote lock is none, can try to grab")
)

Functions

func CreateLease

func CreateLease(ctx context.Context, client *clientv3.Client, leaseTTL int64) (*clientv3.LeaseGrantResponse, clientv3.LeaseID, error)

func GetFirstCrt

func GetFirstCrt(ctx context.Context, client *clientv3.Client, key string) (*clientv3.GetResponse, map[string]string, error)

func GetRemoteLockState

func GetRemoteLockState(ctx context.Context, client *clientv3.Client, lockName string) (bool, int64, error)

GetRemoteLockState 获取远程锁的状态

func PutWithLease

func PutWithLease(ctx context.Context, client *clientv3.Client, key string, value string, leaseID clientv3.LeaseID) (*clientv3.PutResponse, error)

Types

type Locker

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

func NewLocker

func NewLocker(c *clientv3.Client, owner string, lock string, ttl int) *Locker

NewLocker Create a new distributed lock instance, note that if it is no longer used, please call Close.

func (*Locker) Close

func (l *Locker) Close()

Close Close lock, no longer available

func (*Locker) GetLockID

func (l *Locker) GetLockID() string

func (*Locker) GetLockRev

func (l *Locker) GetLockRev() int64

func (*Locker) Lock

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

func (*Locker) Unlock

func (l *Locker) Unlock(ctx context.Context) error

Unlock Unlock, continue to Lock