lock

type DataBaseLocker struct {
	LockStore LockStore
}

type LockManager interface {
	// AcquireLock Acquire lock boolean.
	AcquireLock(branchSession *session.BranchSession) bool

	// ReleaseLock Unlock boolean.
	ReleaseLock(branchSession *session.BranchSession) bool

	// GlobalSession 是没有锁的，所有的锁都在 BranchSession 上，因为
	// BranchSession 才持有资源，释放 GlobalSession 锁是指释放它所有
	// 的 BranchSession 上的锁.
	// ReleaseGlobalSessionLock Unlock boolean.
	ReleaseGlobalSessionLock(globalSession *session.GlobalSession) bool

	// IsLockable Is lockable boolean.
	IsLockable(xid string, resourceID string, lockKey string) bool

	// CleanAllLocks Clean all locks.
	CleanAllLocks()

	GetLockKeyCount() int64
}

type LockStore interface {
	AcquireLockByLockDO(lockDO *model.LockDO) bool
	AcquireLock(lockDOs []*model.LockDO) bool
	UnLockByLockDO(lockDO *model.LockDO) bool
	UnLock(lockDOs []*model.LockDO) bool
	UnLockByXIDAndBranchID(xid string, branchID int64) bool
	UnLockByXIDAndBranchIDs(xid string, branchIDs []int64) bool
	IsLockable(lockDOs []*model.LockDO) bool
	GetLockCount() int64
}

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

type MemoryLocker struct {
	LockMap *sync.Map
	// 高流量下，锁资源越多，BucketHolder 的性能越下降
	BucketHolder *sync.Map

	LockKeyCount int64
}

type RowLock struct {
	XID string

	TransactionID int64

	BranchID int64

	ResourceID string

	TableName string

	Pk string

	RowKey string

	Feature string
}