locker

Jun 6, 2018

Changes in this version

+ var FileLockMgr = NewFileLocker()

+ var IndexLockMgr = NewIndexLocker()

+ var NodeLockMgr = NewNodeLocker()

+ type FileLocker struct

+ func NewFileLocker() *FileLocker

+ func (f *FileLocker) Add(id string) *LockInfo

+ func (f *FileLocker) Error(id string, err error)

+ func (f *FileLocker) Get(id string) *LockInfo

+ func (f *FileLocker) GetAll() map[string]*LockInfo

+ func (f *FileLocker) Remove(id string)

+ func (f *FileLocker) RemoveOld(hours int)

+ type IndexLocker struct

+ func NewIndexLocker() *IndexLocker

+ func (i *IndexLocker) Add(id string, name string) *LockInfo

+ func (i *IndexLocker) Error(id string, name string, err error)

+ func (i *IndexLocker) Get(id string, name string) *LockInfo

+ func (i *IndexLocker) GetAll() map[string]map[string]*LockInfo

+ func (i *IndexLocker) Remove(id string, name string)

+ func (i *IndexLocker) RemoveOld(hours int)

+ type LockInfo struct

+ CreatedOn time.Time

+ Error string

+ func NewLockInfo() *LockInfo

+ type NodeLock struct

+ Id string

+ IsLocked bool

+ Updated time.Time

+ func NewNodeLock(id string) (n *NodeLock)

+ type NodeLocker struct

+ func NewNodeLocker() *NodeLocker

+ func (l *NodeLocker) Add(id string)

+ func (l *NodeLocker) GetAll() (nodes []*NodeLock)

+ func (l *NodeLocker) GetLocked() (nodes []*NodeLock)

+ func (l *NodeLocker) LockNode(id string) (err error)

+ func (l *NodeLocker) Remove(id string)

+ func (l *NodeLocker) RemoveOld(hours int)

+ func (l *NodeLocker) UnlockNode(id string)