ndb

Documentation

Index

• func MustNewDB(dbConfig *nconf.DbConfig, opt ...DBOption) *gorm.DB
• func NewDB(dbConfig *nconf.DbConfig, opt ...DBOption) (*gorm.DB, error)
• type DBOper
  • func NewDBOper(db *gorm.DB) DBOper
• type DBOption
  • func DialectorOption(dialector gorm.Dialector) DBOption
• type RedisOper
  • func NewRedisOper(redisPool RedisPool) RedisOper
• type RedisPool
  • func MustNewRedisPool(redisConfig *nconf.RedisConfig) RedisPool
  • func NewRedisPool(redisConfig *nconf.RedisConfig) (RedisPool, error)
• type Transactional

Functions

func MustNewDB

func MustNewDB(dbConfig *nconf.DbConfig, opt ...DBOption) *gorm.DB

MustNewDB -

func NewDB

func NewDB(dbConfig *nconf.DbConfig, opt ...DBOption) (*gorm.DB, error)

NewDB -

Types

type DBOper

type DBOper interface {
	DB(ctx context.Context) *gorm.DB
	Transactional(ctx context.Context, fn func(ctx context.Context) error) error
}

DBOper -

func NewDBOper

func NewDBOper(db *gorm.DB) DBOper

NewDBOper -

type DBOption

type DBOption func(*dbOptions)

DBOption -

func DialectorOption

func DialectorOption(dialector gorm.Dialector) DBOption

DialectorOption -

type RedisOper

type RedisOper interface {
	// Conn - Get a redis connection from the pool.
	// The application must close the returned connection.
	Conn() redis.Conn
	GetString(key string) (string, error)
	SetString(key, value string) error
	SetStringOpts(key, value string, setnx bool, setxx bool, ttl time.Duration) error

	GetObject(key string, model interface{}) (interface{}, error)
	SetObject(key string, value interface{}) error
	SetObjectOpts(key string, value interface{}, setnx bool, setxx bool, ttl time.Duration) error

	Unlink(key string) error
	Unlinks(keys ...string) error

	Delete(key string) error
	Deletes(keys ...string) error
	DeleteByKeyValue(key string, val string) error
}

RedisOper -

func NewRedisOper

func NewRedisOper(redisPool RedisPool) RedisOper

NewRedisOper -

type RedisPool

type RedisPool interface {
	Get() redis.Conn
	Close() error
}

RedisPool -

func MustNewRedisPool

func MustNewRedisPool(redisConfig *nconf.RedisConfig) RedisPool

MustNewRedisPool -

func NewRedisPool

func NewRedisPool(redisConfig *nconf.RedisConfig) (RedisPool, error)

NewRedisPool -

type Transactional

type Transactional func(ctx context.Context, fn func(ctx context.Context) error) error

Transactional -