store

package

v0.0.0-...-9cf7771 Latest Latest Go to latest Published: Nov 30, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

func InitMockRedis() *redis.Client

func InitRedis(conf RedisConf) (*redis.Client, error)

type DB struct {
	*sqlx.DB
}

func InitDB(driverName, dataSourceName string, driver driver.Driver, opt ...DatabaseOption) (*DB, error)

func InitMockMysql(sqlDir string) (*DB, error)

func InitMysql(conf MysqlConf, opt ...DatabaseOption) (*DB, error)

func (db *DB) Transact(fn func(*sqlx.Tx) error) (err error)

type DatabaseOption struct {
	RegisterHookDriver bool
}

type Hooks struct{}

func (h *Hooks) After(ctx context.Context, query string, args ...interface{}) (context.Context, error)

func (h *Hooks) Before(ctx context.Context, _ string, _ ...interface{}) (context.Context, error)

type MysqlConf struct {
	DataSourceName     string
	RegisterHookDriver bool
}

type RedisConf struct {
	Addr               string
	Password           string
	DB                 int
	RegisterHookDriver bool
}

type RedisHook struct{}

func (*RedisHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*RedisHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*RedisHook) BeforeProcess(ctx context.Context, _ redis.Cmder) (context.Context, error)

func (*RedisHook) BeforeProcessPipeline(ctx context.Context, _ []redis.Cmder) (context.Context, error)