beego_locks

README

go get -u github.com/storage-lock/go-beego-locks

Documentation

Index

• func CreateStorageForBeego(db *orm.DB, connectionManager storage.ConnectionManager[*sql.DB]) (storage.Storage, error)
• func InitGlobalBeegoLockFactory(db *orm.DB) error
• type BeegoLockFactory
  • func NewBeegoLockFactory(db *orm.DB) (*BeegoLockFactory, error)
• type BeegoOrmConnectionManager
  • func NewBeegoConnectionManager(db *orm.DB) *BeegoOrmConnectionManager
  • func (x *BeegoOrmConnectionManager) Name() string
  • func (x *BeegoOrmConnectionManager) Return(ctx context.Context, db *sql.DB) error
  • func (x *BeegoOrmConnectionManager) Shutdown(ctx context.Context) error
  • func (x *BeegoOrmConnectionManager) Take(ctx context.Context) (*sql.DB, error)

Functions

func CreateStorageForBeego

func CreateStorageForBeego(db *orm.DB, connectionManager storage.ConnectionManager[*sql.DB]) (storage.Storage, error)

CreateStorageForBeego 尝试从beego orm创建Storage

func InitGlobalBeegoLockFactory

func InitGlobalBeegoLockFactory(db *orm.DB) error

Types

type BeegoLockFactory

type BeegoLockFactory struct {
	*storage_lock_factory.StorageLockFactory[*sql.DB]
	// contains filtered or unexported fields
}

var GlobalBeegoLockFactory *BeegoLockFactory

func NewBeegoLockFactory

func NewBeegoLockFactory(db *orm.DB) (*BeegoLockFactory, error)

type BeegoOrmConnectionManager

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

BeegoOrmConnectionManager 用来复用beego orm（https://github.com/beego/beego）的连接 TODO 2023-8-4 01:31:00 单元测试

func NewBeegoConnectionManager

func NewBeegoConnectionManager(db *orm.DB) *BeegoOrmConnectionManager

func (*BeegoOrmConnectionManager) Name

func (x *BeegoOrmConnectionManager) Name() string

func (*BeegoOrmConnectionManager) Return

func (x *BeegoOrmConnectionManager) Return(ctx context.Context, db *sql.DB) error

func (*BeegoOrmConnectionManager) Shutdown

func (x *BeegoOrmConnectionManager) Shutdown(ctx context.Context) error

func (*BeegoOrmConnectionManager) Take

func (x *BeegoOrmConnectionManager) Take(ctx context.Context) (*sql.DB, error)