Documentation
¶
Overview ¶
MySql引擎层
Index ¶
- Variables
- func CreateLike(column string) string
- func CreatePage(page, limit uint64) uint64
- func NewKafkaAsyncProduce(host []string, username, pwd string) (conn sarama.AsyncProducer, err error)
- func NewKafkaSyncProduce(host []string, username, pwd string) (conn sarama.SyncProducer, err error)
- func NewRedisPool(addr, passwd string, db, maxIdle, MaxActive int) *redis.Pool
- func NewSQLX(driverName, dbSource string, maxOpenConns, maxIdleConns int) (db *sqlx.DB, err error)
- type And
- type Eq
- type Gt
- type GtOrEq
- type Gte
- type InsertBuilder
- type Like
- type Lt
- type LtOrEq
- type Lte
- type NotEq
- type Or
- type SelectBuilder
- type UpdateBuilder
Constants ¶
This section is empty.
Variables ¶
View Source
var ClickHouseSqlx *sqlx.DB
View Source
var KafkaASyncProducer sarama.AsyncProducer
View Source
var KafkaClient sarama.Client
View Source
var KafkaSyncProducer sarama.SyncProducer
View Source
var RedisPool *redis.Pool
View Source
var SqlBuilder = squirrel.StatementBuilder
用squirrel生成sql语句
View Source
var Sqlx *sqlx.DB
sqlx 全局变量
Functions ¶
func NewKafkaAsyncProduce ¶
func NewKafkaAsyncProduce(host []string, username, pwd string) (conn sarama.AsyncProducer, err error)
func NewKafkaSyncProduce ¶
func NewKafkaSyncProduce(host []string, username, pwd string) (conn sarama.SyncProducer, err error)
func NewRedisPool ¶
NewRedisPool 新建一个Redis连接池 URL优先
Types ¶
type InsertBuilder ¶
type InsertBuilder = squirrel.InsertBuilder
type SelectBuilder ¶
type SelectBuilder = squirrel.SelectBuilder
type UpdateBuilder ¶
type UpdateBuilder = squirrel.UpdateBuilder
Source Files
Click to show internal directories.
Click to hide internal directories.