datasource_bak

Documentation

Index

• func LoadByType(p reflect.Type) (interface{}, bool)
• func SaveByType(p reflect.Type, db interface{})
• func UseDataBaseHandler(typ string, handler DataBaseConnectionHandler)
• type Config
  • func (c *Config) Prefix() string
• type DataBaseConnectionHandler
• type Datasource
• type Helper
  • func NewHelper() *Helper
  • func (d *Helper) CreateDatasource() (Datasource, error)
  • func (d *Helper) SetDatasourceTag(datasource string) *Helper
  • func (d *Helper) SetPropertiesPrefix(prefix string) *Helper
• type ORMUpgrader
• type Starter
  • func NewStarter() *Starter
  • func (s *Starter) Init() error
• type Wrapper

Functions

func LoadByType

func LoadByType(p reflect.Type) (interface{}, bool)

func SaveByType

func SaveByType(p reflect.Type, db interface{})

func UseDataBaseHandler

func UseDataBaseHandler(typ string, handler DataBaseConnectionHandler)

Types

type Config

type Config struct {
	types.Component

	Type            string `yaml:"type"`
	Host            string `yaml:"host"`
	Database        string `yaml:"database"`
	Username        string `yaml:"username"`
	Password        string `yaml:"password"`
	Tunnel          string `yaml:"tunnel"`
	ConnMaxLifeTime int64  `yaml:"max_life_time"`
	ConnMaxIdleTime int64  `yaml:"max_idle_time"`
	MaxIdleConns    int    `yaml:"max_idle_conn"`
	MaxOpenConns    int    `yaml:"max_open_conn"`
	LazyFetch       bool   `yaml:"lazy_fetch"`
	// contains filtered or unexported fields
}

func (*Config) Prefix

func (c *Config) Prefix() string

type DataBaseConnectionHandler

type DataBaseConnectionHandler func(d *Starter, configure Datasource) (*sql.DB, error)

type Datasource

type Datasource interface {
	bean.Bean
	Tag() string
	GetType() string
	GetHost() string
	GetDatabase() string
	GetUsername() string
	GetPassword() string
	GetTunnel() string

	GetConnMaxLifeTime() int64
	GetConnMaxIdleTime() int64
	GetMaxIdleConns() int
	GetMaxOpenConns() int
	IsLazyFetch() bool
}

type Helper

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

func NewHelper

func NewHelper() *Helper

func (*Helper) CreateDatasource

func (d *Helper) CreateDatasource() (Datasource, error)

func (*Helper) SetDatasourceTag

func (d *Helper) SetDatasourceTag(datasource string) *Helper

func (*Helper) SetPropertiesPrefix

func (d *Helper) SetPropertiesPrefix(prefix string) *Helper

type ORMUpgrader

type ORMUpgrader interface {
	bean.Bean
	UpgradeType() reflect.Type
	Upgrade(wrapper Wrapper) (interface{}, error)
}

type Starter

type Starter struct {
	types.Component
	Config     ssh.Config        `value:"ssh"`
	Log        log.Logger        `wire:""`
	Datasource []Datasource      `wire:""`
	Repos      []data.Repository `wire:""`
	Upgraders  []ORMUpgrader     `wire:""`
	TCPDialer  *tcp.Dialer
	SSHDialer  *ssh.Dialer
	// contains filtered or unexported fields
}

func NewStarter

func NewStarter() *Starter

func (*Starter) Init

func (s *Starter) Init() error

type Wrapper

type Wrapper interface {
	DB() *sql.DB
	Configure() Datasource
}