gobatch

type Batcher struct {
	BatchSize uint
	MaxWait   time.Duration
	Job       Job
	MaxRetry  uint

	Logger *zap.Logger
	// contains filtered or unexported fields
}

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

type Logger interface {
	Debug(msg string, keyAndValue ...interface{})
	// Info logs routine messages about cron's operation.
	Info(msg string, keysAndValues ...interface{})
	// Error logs an error condition.
	Error(err error, msg string, keysAndValues ...interface{})
}

type LoggerImpl struct {
}