cfg

Documentation

Index

• Variables
• func Loadini(filename string, data interface{}) (err error)
• func ParseAge(u *User)
• type Config
  • func (c *Config) HostData(dbHost *sqlx.DB, dataChanel chan<- *[]*User, parse ...func(*User)) (err error)
  • func (c *Config) InitDB() (dbHost, dbSlave *sqlx.DB, err error)
  • func (c *Config) SlaveBak(dbSlave *sqlx.DB, dataChanel <-chan *[]*User) (err error)
• type MysqlconfigHost
• type MysqlconfigSlave
• type SqlSyntax
• type User

Variables

var DataChan = make(chan *[]*User, 64)

Functions

func Loadini

func Loadini(filename string, data interface{}) (err error)

解析配置文件

func ParseAge

func ParseAge(u *User)

对age列数据进行清洗

Types

type Config

type Config struct {
	MysqlconfigHost  `ini:"mysql_host"`
	MysqlconfigSlave `ini:"mysql_slave"`
	SqlSyntax        `ini:"sql_syntax"`
}

func (*Config) HostData

func (c *Config) HostData(dbHost *sqlx.DB, dataChanel chan<- *[]*User, parse ...func(*User)) (err error)

查询主库

func (*Config) InitDB

func (c *Config) InitDB() (dbHost, dbSlave *sqlx.DB, err error)

func (*Config) SlaveBak

func (c *Config) SlaveBak(dbSlave *sqlx.DB, dataChanel <-chan *[]*User) (err error)

type MysqlconfigHost

type MysqlconfigHost struct {
	Address  string `ini:"address"`
	Port     int    `ini:"port"`
	Username string `ini:"username"`
	Password string `ini:"password"`
	DB       string `ini:"db"`
	Table    string `ini:"table"`
}

type MysqlconfigSlave

type MysqlconfigSlave struct {
	Address  string `ini:"address"`
	Port     int    `ini:"port"`
	Username string `ini:"username"`
	Password string `ini:"password"`
	DB       string `ini:"db"`
	Table    string `ini:"table"`
}

type SqlSyntax

type SqlSyntax struct {
	HostSelcet  string `ini:"host_selcet"`
	SlaveUpdate string `ini:"slave_update"`
	UpdateTime  int    `ini:"update_time"`
	HostCount   string `ini:"host_count"`
	SendCount   int    `ini:"send_count"`
}

type User

type User struct {
	ID   int           `db:"id"`
	Name string        `db:"names"`
	Age  sql.NullInt64 `db:"age"`
	Src  string        `db:"src"`
}