lock

README

mysql-lock

a simple distributed lock based on mysql

Documentation

Index

• func InitMySQL(dsn string, debug bool) *gorm.DB
• type LockStore
  • func (LockStore) TableName() string
• type MySQLLock
  • func NewMySQLLock(dsn string, debug bool) *MySQLLock
  • func (l *MySQLLock) Acquire(lockName string, wait time.Duration) error
  • func (l *MySQLLock) Init(lockNameList []string)
  • func (l *MySQLLock) Release(lockName string) error

Functions

func InitMySQL

func InitMySQL(dsn string, debug bool) *gorm.DB

Types

type LockStore

type LockStore struct {
	Name      string    `gorm:"column:name;size:100;index:uni_name,unique" json:"name"`
	CreatedAt time.Time `gorm:"column:created_at" json:"createdAt"`
	// other
	ID int `gorm:"column:id" json:"id"`
}

func (LockStore) TableName

func (LockStore) TableName() string

type MySQLLock

type MySQLLock struct {
	MySQLClient *gorm.DB
	TXMap       map[string]*gorm.DB
}

func NewMySQLLock

func NewMySQLLock(dsn string, debug bool) *MySQLLock

func (*MySQLLock) Acquire

func (l *MySQLLock) Acquire(lockName string, wait time.Duration) error

Lock :If the lock cannot be obtained, it will keep blocking

func (*MySQLLock) Init

func (l *MySQLLock) Init(lockNameList []string)

Init :Create tables Create row record

func (*MySQLLock) Release

func (l *MySQLLock) Release(lockName string) error