exclusive_locks

Documentation

Index

• Constants
• type ExclusiveLocker
  • func NewExclusiveLocker(masterClient *wdclient.MasterClient) *ExclusiveLocker
  • func (l *ExclusiveLocker) GetToken() (token int64, lockTsNs int64)
  • func (l *ExclusiveLocker) IsLocking() bool
  • func (l *ExclusiveLocker) ReleaseLock()
  • func (l *ExclusiveLocker) RequestLock()

Constants

const (
	RenewInteval     = 4 * time.Second
	SafeRenewInteval = 3 * time.Second
	InitLockInteval  = 1 * time.Second
	AdminLockName    = "admin"
)

Types

type ExclusiveLocker

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

func NewExclusiveLocker

func NewExclusiveLocker(masterClient *wdclient.MasterClient) *ExclusiveLocker

func (*ExclusiveLocker) GetToken

func (l *ExclusiveLocker) GetToken() (token int64, lockTsNs int64)

func (*ExclusiveLocker) IsLocking

func (l *ExclusiveLocker) IsLocking() bool

func (*ExclusiveLocker) ReleaseLock

func (l *ExclusiveLocker) ReleaseLock()

func (*ExclusiveLocker) RequestLock

func (l *ExclusiveLocker) RequestLock()