distlock

Documentation

Index

• func InitConsul(centerAddr string)
• type ConsulLock
  • func NewConsulLock(key string, expire int) (*ConsulLock, error)
  • func (l *ConsulLock) Lock(ctx context.Context, timeout int) bool
  • func (l *ConsulLock) Unlock()
• type DistLock
• type RdsLuaLock
  • func NewRdsLuaLock(dbKey, key string, expire int) (*RdsLuaLock, error)
  • func (l *RdsLuaLock) Lock(ctx context.Context, timeout int) bool
  • func (l *RdsLuaLock) TryLock(ctx context.Context) bool
  • func (l *RdsLuaLock) Unlock(ctx context.Context)

Functions

func InitConsul

func InitConsul(centerAddr string)

Types

type ConsulLock

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

func NewConsulLock

func NewConsulLock(key string, expire int) (*ConsulLock, error)

func (*ConsulLock) Lock

func (l *ConsulLock) Lock(ctx context.Context, timeout int) bool

func (*ConsulLock) Unlock

func (l *ConsulLock) Unlock()

type DistLock

type DistLock interface {
	Lock(timeout int) bool
	Unlock()
}

type RdsLuaLock

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

func NewRdsLuaLock

func NewRdsLuaLock(dbKey, key string, expire int) (*RdsLuaLock, error)

func (*RdsLuaLock) Lock

func (l *RdsLuaLock) Lock(ctx context.Context, timeout int) bool

func (*RdsLuaLock) TryLock

func (l *RdsLuaLock) TryLock(ctx context.Context) bool

func (*RdsLuaLock) Unlock

func (l *RdsLuaLock) Unlock(ctx context.Context)