datasource

Documentation

Index

• Constants
• type DataSource
  • func NewDataSource(name ...string) DataSource
• type DataSourceDriver
• type DataSourceImpl
  • func (d *DataSourceImpl) Bean() string
  • func (d *DataSourceImpl) Build(properties *DataSourceProperties) (DataSource, error)
  • func (d *DataSourceImpl) DB() interface{}
• type DataSourceProperties
• type DataSourceStarter
  • func NewStarter() *DataSourceStarter
  • func (d *DataSourceStarter) AfterInit()
• type MySqlDriver
  • func (d *MySqlDriver) Open(properties *DataSourceProperties) (interface{}, error)

Constants

const PropertiesPath = "application.datasource"

Types

type DataSource

type DataSource interface {
	bean.Bean
	Build(properties *DataSourceProperties) (DataSource, error)
	DB() interface{}
}

func NewDataSource

func NewDataSource(name ...string) DataSource

type DataSourceDriver

type DataSourceDriver interface {
	bean.Bean
	Type() string
	Driver() string
	Open(properties *DataSourceProperties) (interface{}, error)
}

type DataSourceImpl

type DataSourceImpl struct {
	types.Component
	Drivers []DataSourceDriver `wire:""`
	// contains filtered or unexported fields
}

func (*DataSourceImpl) Bean

func (d *DataSourceImpl) Bean() string

func (*DataSourceImpl) Build

func (d *DataSourceImpl) Build(properties *DataSourceProperties) (DataSource, error)

func (*DataSourceImpl) DB

func (d *DataSourceImpl) DB() interface{}

type DataSourceProperties

type DataSourceProperties struct {
	types.AutoConfigure `name:"datasource_properties" prefix:"application.datasource"`
	Type                string `yaml:"type"`
	Driver              string `yaml:"driver"`
	ConnMaxLifeTime     int64  `yaml:"max_life_time"`
	ConnMaxIdleTime     int64  `yaml:"max_idle_time"`
	MaxIdleConns        int    `yaml:"max_idle_conn"`
	MaxOpenConns        int    `yaml:"max_open_conn"`
	Url                 string `yaml:"url"`
	Username            string `yaml:"username"`
	Password            string `yaml:"password"`
}

type DataSourceStarter

type DataSourceStarter struct {
	types.Component `name:"datasource_starter"`
	DataSources     []DataSource `wire:""`
}

func NewStarter

func NewStarter() *DataSourceStarter

func (*DataSourceStarter) AfterInit

func (d *DataSourceStarter) AfterInit()

type MySqlDriver

type MySqlDriver struct {
	types.DataSourceDriver `name:"datasource_driver:mysql" type:"database/sql" driver:"github.com/go-sql-driver/mysql"`
}

func (*MySqlDriver) Open

func (d *MySqlDriver) Open(properties *DataSourceProperties) (interface{}, error)