Versions in this module Expand all Collapse all v0 v0.2.0 Feb 24, 2019 Changes in this version + type Item struct + Key string + Val interface{} + type Options struct + BatchSize int + Rate time.Duration + type Queue struct + func New(logger *zap.SugaredLogger, flushFunc func([]*Item) error, ...) *Queue + func (q *Queue) Close() + func (q *Queue) IsStopped() bool + func (q *Queue) Queue(item *Item) error + func (q *Queue) Run()
Go to main page