gobatch

Mar 18, 2022

Changes in this version

type Batcher

+ Logger *zap.Logger

+ type Logger interface

+ Debug func(msg string, keyAndValue ...interface{})

+ Error func(err error, msg string, keysAndValues ...interface{})

+ Info func(msg string, keysAndValues ...interface{})

+ type LoggerImpl struct

+ func (l *LoggerImpl) Debug(msg string, keyAndValue ...interface{})

Apr 2, 2021

Changes in this version

+ type Batcher struct

+ BatchSize uint

+ Job Job

+ MaxRetry uint

+ MaxWait time.Duration

+ func NewBatcher(job Job) *Batcher

+ func (b *Batcher) Start(ctx context.Context) (chan interface{}, error)

+ type Job func(ctx context.Context, queue []interface{}) error