handle

Documentation

Index

• Constants
• Variables
• func GetClickhouseTableColumn(db *sql.DB, dbName, table, pk, dbType string) (*model.SQLTable, error)
• func QueryRows(db *sql.DB, types map[string]model.DataType, query string, args ...interface{}) ([]*model.Data, error)
• func Run(exit chan struct{}, wg *sync.WaitGroup)
• func SetConfig(config *config.Config)

Constants

const (
	TIMEOUT = 60
)

Variables

var (
	CkgroupStore ckgroupStore
)

var ErrPrimarykeyMiss = errors.New("primarikey is required, but not found")

ErrPrimarykeyMiss 主键不存在

Functions

func GetClickhouseTableColumn

func GetClickhouseTableColumn(db *sql.DB, dbName, table, pk, dbType string) (*model.SQLTable, error)

GetClickhouseTableColumn 获取 clickhouse 列信息

func QueryRows

func QueryRows(db *sql.DB, types map[string]model.DataType, query string, args ...interface{}) ([]*model.Data, error)

QueryRows 关系型数据库多行查询

func Run

func Run(exit chan struct{}, wg *sync.WaitGroup)

Run 运行核心逻辑

func SetConfig

func SetConfig(config *config.Config)

SetConfig 设置 conf 到 handle 全局变量