product

Documentation

Index

• func GetBatchNum() string
• type CollectionAccumulator
  • func (collectionAccumulator *CollectionAccumulator) AddCollectionBatch(project, setName string, kv interface{})
• type IoWorker
• type IoWorkerPool
• type Mover
• type Product
  • func InitProduct(productConfig *ProductConfig, engine string, ...) *Product
  • func (producer *Product) SafeClose()
  • func (producer *Product) SendCollection(project, setName string, collection interface{})
  • func (p *Product) Start()
• type ProductBatch
• type ProductConfig
  • func GetDefaultProductConfig() *ProductConfig

Functions

func GetBatchNum

func GetBatchNum() string

Types

type CollectionAccumulator

type CollectionAccumulator struct {
	CollectionGroupData map[string]*ProductBatch `json:"collectionGroupData"`
	// contains filtered or unexported fields
}

func (*CollectionAccumulator) AddCollectionBatch

func (collectionAccumulator *CollectionAccumulator) AddCollectionBatch(project, setName string, kv interface{})

type IoWorker

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

type IoWorkerPool

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

type Mover

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

type Product

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

func InitProduct

func InitProduct(productConfig *ProductConfig, engine string, injectionEngine jkinterface.ProductClientInterface) *Product

injectionEngine used to open to developers to implement their own engine, it is not required To use, enable the injection engine in the producer's configuration

func (*Product) SafeClose

func (producer *Product) SafeClose()

func (*Product) SendCollection

func (producer *Product) SendCollection(project, setName string, collection interface{})

func (*Product) Start

func (p *Product) Start()

type ProductBatch

type ProductBatch struct {
	CollectionGroup *Kv.CollectionGroup `json:"collection_group"`
	TotalNum        int64               //最多10个
	// contains filtered or unexported fields
}

type ProductConfig

type ProductConfig struct {
	MaxBatchCount     int
	MaxIoWorkerCount  int64
	LingerMs          int64
	ExtMap            map[string]string
	IsInjectionEngine bool //是否注入引擎
}

func GetDefaultProductConfig

func GetDefaultProductConfig() *ProductConfig