Versions in this module Expand all Collapse all v0 v0.1.4 Jun 20, 2022 v0.1.3 Jun 20, 2022 Changes in this version + func GetBatchNum() string + type CollectionAccumulator struct + CollectionGroupData map[string]*ProductBatch + func (collectionAccumulator *CollectionAccumulator) AddCollectionBatch(project, setName string, kv interface{}) + type IoWorker struct + type IoWorkerPool struct + type Mover struct + type Product struct + func InitProduct(productConfig *ProductConfig, engine string, ...) *Product + func (p *Product) Start() + func (producer *Product) SafeClose() + func (producer *Product) SendCollection(project, setName string, collection interface{}) + type ProductBatch struct + CollectionGroup *Kv.CollectionGroup + TotalNum int64 + type ProductConfig struct + ExtMap map[string]string + IsInjectionEngine bool + LingerMs int64 + MaxBatchCount int + MaxIoWorkerCount int64 + func GetDefaultProductConfig() *ProductConfig