zklock

README

This package is copied and modified from https://github.com/nladuo/go-zk-lock

Documentation

Index

• Variables
• func Close()
• func Connect(_hosts []string, zkTimeOut time.Duration) error
• func PConnect(_hosts []string, zkTimeOut time.Duration) error
• type Dlocker
  • func NewLocker(path string, timeout time.Duration) (*Dlocker, error)
  • func (d *Dlocker) Lock() error
  • func (d *Dlocker) TryLock() error
  • func (d *Dlocker) Unlock() error

Variables

var ErrAcquireLock = errors.New("lock is already acquired by another client")

Functions

func Close

func Close()

Close close connection

func Connect

func Connect(_hosts []string, zkTimeOut time.Duration) error

Connect conncet to ZK cluster

func PConnect

func PConnect(_hosts []string, zkTimeOut time.Duration) error

PConnect connect to ZK cluster

Types

type Dlocker

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

Dlocker distributed locker

func NewLocker

func NewLocker(path string, timeout time.Duration) (*Dlocker, error)

NewLocker create instance of ZK lock

func (*Dlocker) Lock

func (d *Dlocker) Lock() error

Lock just list mutex.Lock()

func (*Dlocker) TryLock

func (d *Dlocker) TryLock() error

TryLock try lock and return error immediately if fail

func (*Dlocker) Unlock

func (d *Dlocker) Unlock() error

Unlock just list mutex.Unlock(), return false when zookeeper connection error or locker timeout