database

Documentation

Index

• type Configure
  • func NewConfigure(dsn string, maxIdleConns, maxOpenConns, connMaxIdleTime, connMaxLifetime int, ...) Configure
• type DBConfig
  • func (e *DBConfig) Init(config *gorm.Config, open func(string) gorm.Dialector) (*gorm.DB, error)
• type DBResolverConfig
  • func (e *DBResolverConfig) Init(register *dbresolver.DBResolver, open func(string) gorm.Dialector) *dbresolver.DBResolver
• type ResolverConfigure
  • func NewResolverConfigure(sources, replicas []string, policy string, tables []string) ResolverConfigure

Types

type Configure

type Configure interface {
	Init(*gorm.Config, func(string) gorm.Dialector) (*gorm.DB, error)
}

func NewConfigure

func NewConfigure(
	dsn string,
	maxIdleConns,
	maxOpenConns,
	connMaxIdleTime,
	connMaxLifetime int,
	registers []ResolverConfigure) Configure

NewConfigure 初始化 Configure

type DBConfig

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

func (*DBConfig) Init

func (e *DBConfig) Init(config *gorm.Config, open func(string) gorm.Dialector) (*gorm.DB, error)

Init 获取db，⚠️注意：读写分离只能配置一组

type DBResolverConfig

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

func (*DBResolverConfig) Init

func (e *DBResolverConfig) Init(
	register *dbresolver.DBResolver,
	open func(string) gorm.Dialector) *dbresolver.DBResolver

type ResolverConfigure

type ResolverConfigure interface {
	Init(*dbresolver.DBResolver, func(string) gorm.Dialector) *dbresolver.DBResolver
}

func NewResolverConfigure

func NewResolverConfigure(sources, replicas []string, policy string, tables []string) ResolverConfigure

NewResolverConfigure 初始化 ResolverConfigure