lockserver

Documentation

Index

• type LockServer
  • func NewLockServer(config configs.LockServerSection) (*LockServer, error)
  • func (ls *LockServer) Close()
  • func (ls *LockServer) Lock(node string) error
  • func (ls *LockServer) Locks() []string
  • func (ls *LockServer) Unlock(node string) error
  • func (ls *LockServer) Watch(node string) (<-chan zookeeper.Event, error)

Types

type LockServer

type LockServer struct {
	Zk      *zookeeper.Conn
	Session <-chan zookeeper.Event

	configs.LockServerSection
	// contains filtered or unexported fields
}

func NewLockServer

func NewLockServer(config configs.LockServerSection) (*LockServer, error)

func (*LockServer) Close

func (ls *LockServer) Close()

func (*LockServer) Lock

func (ls *LockServer) Lock(node string) error

func (*LockServer) Locks

func (ls *LockServer) Locks() []string

func (*LockServer) Unlock

func (ls *LockServer) Unlock(node string) error

func (*LockServer) Watch

func (ls *LockServer) Watch(node string) (<-chan zookeeper.Event, error)