choperator

Documentation

Index

• Variables
• type ChOperator
  • func NewChOperator(shards [][]string) (ChOperator, error)
• type ChProxyOperator
  • func (cpo *ChProxyOperator) BatchInsert(insertData [][]interface{}, insertQuery string, arr []util.DataType, ...) error
  • func (cpo *ChProxyOperator) ObtainClickHouseKV(targetDB, targetTable string) (map[string]string, error)
• type CkGroupOperator
  • func (cgo *CkGroupOperator) BatchInsert(insertData [][]interface{}, insertQuery string, indexOfPrimKey int) error
  • func (cgo *CkGroupOperator) MysqlBatchInsert(insertData [][]interface{}, insertQuery string, arr []util.DataType, ...) error
  • func (cgo *CkGroupOperator) ObtainClickHouseKV(targetDB, targetTable string) (map[string]string, error)
• type ClickHouseDescType

Variables

var ShangHaiLocation = time.FixedZone("Asia/Shanghai", int((time.Hour * 8).Seconds()))

Types

type ChOperator

type ChOperator interface {
	MysqlBatchInsert(insertData [][]interface{}, insertQuery string, arr []util.DataType, indexOfFlag, indexOfInsertID, indexOfPrimKeys int) error
	ObtainClickHouseKV(targetDB, targetTable string) (map[string]string, error)
	BatchInsert(insertData [][]interface{}, insertQuery string, indexOfPrimKey int) error
}

func NewChOperator

func NewChOperator(shards [][]string) (ChOperator, error)

type ChProxyOperator

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

func (*ChProxyOperator) BatchInsert

func (cpo *ChProxyOperator) BatchInsert(insertData [][]interface{}, insertQuery string, arr []util.DataType, indexOfFlag, indexOfInsertID int) error

func (*ChProxyOperator) ObtainClickHouseKV

func (cpo *ChProxyOperator) ObtainClickHouseKV(targetDB, targetTable string) (map[string]string, error)

type CkGroupOperator

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

func (*CkGroupOperator) BatchInsert

func (cgo *CkGroupOperator) BatchInsert(insertData [][]interface{}, insertQuery string, indexOfPrimKey int) error

func (*CkGroupOperator) MysqlBatchInsert

func (cgo *CkGroupOperator) MysqlBatchInsert(insertData [][]interface{}, insertQuery string, arr []util.DataType, indexOfFlag, indexOfInsertID, indexOfPrimKey int) error

func (*CkGroupOperator) ObtainClickHouseKV

func (cgo *CkGroupOperator) ObtainClickHouseKV(targetDB, targetTable string) (map[string]string, error)

type ClickHouseDescType

type ClickHouseDescType struct {
	Name              string `db:"name"`
	Type              string `db:"type"`
	DefaultType       string `db:"default_type"`
	DefaultExpression string `db:"default_expression"`
	Comment           string `db:"comment"`
	CodecExpression   string `db:"codec_expression"`
	TTLExpression     string `db:"ttl_expression"`
}