Versions in this module Expand all Collapse all v1 v1.8.7 May 20, 2022 Changes in this version + const Cancel + const CkSource + const Error + const MysqlSource + const Running + const Success + var DataSourceMap = map[string]func(data request.DataxInfoTestLinkReq) Datasource + type Clickhouse struct + func (this *Clickhouse) GetTableColumns(tableName string) (interface{}, error) + func (this *Clickhouse) GetTables() ([]string, error) + func (this *Clickhouse) Ping() error + func (this *Clickhouse) Transfer(id int, transferReq *request.TransferReq) (err error) + type Datasource interface + GetTableColumns func(tableName string) (interface{}, error) + GetTables func() ([]string, error) + Ping func() error + Transfer func(id int, transferReq *request.TransferReq) (err error) + func NewClickhouse(data request.DataxInfoTestLinkReq) Datasource + func NewDataSource(data request.DataxInfoTestLinkReq) (i Datasource, err error) + func NewMysql(data request.DataxInfoTestLinkReq) Datasource + type Es6 struct + type Es7 struct + type Mysql struct + func (this *Mysql) GetTableColumns(tableName string) (interface{}, error) + func (this *Mysql) GetTables() ([]string, error) + func (this *Mysql) Ping() error + func (this *Mysql) Transfer(id int, transferReq *request.TransferReq) (err error) + type RealTimeWarehousingV6 struct + func NewRealTimeWarehousingV6(batchSize, flushInterval int, conn *elasticV6.Client, ctx context.Context, ...) *RealTimeWarehousingV6 + func (this *RealTimeWarehousingV6) Add(data *elasticV6.BulkIndexRequest) (err error) + func (this *RealTimeWarehousingV6) Flush() (err error) + func (this *RealTimeWarehousingV6) FlushAll() error + func (this *RealTimeWarehousingV6) RegularFlushing() + type RealTimeWarehousingV7 struct + func NewRealTimeWarehousingV7(batchSize, flushInterval int, conn *elasticV7.Client, ctx context.Context, ...) *RealTimeWarehousingV7 + func (this *RealTimeWarehousingV7) Add(data *elasticV7.BulkIndexRequest) (err error) + func (this *RealTimeWarehousingV7) Flush() (err error) + func (this *RealTimeWarehousingV7) FlushAll() error + func (this *RealTimeWarehousingV7) RegularFlushing() + type Task struct + var TS *Task + func GetTaskInstance() *Task + func (this *Task) CancelById(id int) (err error) + func (this *Task) SetCancelFunc(id int, cancel context.CancelFunc)
Go to main page