data

Documentation

Index

• func GetTypeID(s string) (interface{}, error)
• type IDType
• type Mongo2ClickHouseModel
  • func NewMongo2ClickHouseModel(mongoConn *mongo.Client, chOperator *choperator.ChOperator, ...) *Mongo2ClickHouseModel
  • func (mg *Mongo2ClickHouseModel) MongoInertIntoClickHouse(job *config.Job, tableName, idType string, batchSize int) (string, error)
• type Mysql2ClickHouse
  • func NewMysql2ClickHouseModel(mysqlConn *sql.DB, chOperator *choperator.ChOperator, controller *chan bool, ...) *Mysql2ClickHouse
  • func (mc *Mysql2ClickHouse) MysqlInertIntoClickHouse(job *config.Job) (string, error)

Functions

func GetTypeID

func GetTypeID(s string) (interface{}, error)

Types

type IDType

type IDType struct {
	Type string `json:"type"`
	ID   string `json:"id"`
}

type Mongo2ClickHouseModel

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

func NewMongo2ClickHouseModel

func NewMongo2ClickHouseModel(mongoConn *mongo.Client, chOperator *choperator.ChOperator, controller *chan bool, etcdHosts []string) *Mongo2ClickHouseModel

func (*Mongo2ClickHouseModel) MongoInertIntoClickHouse

func (mg *Mongo2ClickHouseModel) MongoInertIntoClickHouse(job *config.Job, tableName, idType string, batchSize int) (string, error)

type Mysql2ClickHouse

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

func NewMysql2ClickHouseModel

func NewMysql2ClickHouseModel(mysqlConn *sql.DB, chOperator *choperator.ChOperator, controller *chan bool, etcdHosts []string) *Mysql2ClickHouse

func (*Mysql2ClickHouse) MysqlInertIntoClickHouse

func (mc *Mysql2ClickHouse) MysqlInertIntoClickHouse(job *config.Job) (string, error)