Versions in this module Expand all Collapse all v1 v1.0.0 Dec 5, 2022 Changes in this version + var ErrFull = errors.New("channel full") + type Config struct + Buffer int + Interval xtime.Duration + MaxSize int + Name string + Worker int + type Pipeline struct + Do func(c context.Context, index int, values map[string][]interface{}) + Split func(key string) int + func NewPipeline(config *Config) (res *Pipeline) + func (p *Pipeline) Add(c context.Context, key string, value interface{}) (err error) + func (p *Pipeline) Close() (err error) + func (p *Pipeline) Start() + func (p *Pipeline) SyncAdd(c context.Context, key string, value interface{}) (err error)
Go to main page