@@ -32,21 +32,21 @@ In any high throughput event/stream processing, it is imperative to process them
3232type BatchProcessor [T any] func (ctx context.Context , trigger trigger, batch []T ) error
3333
3434type Config [T any] struct {
35- // ProcessingTimeout is context timeout for processing a single batch
36- ProcessingTimeout time.Duration
35+ // ProcessingTimeout is context timeout for processing a single batch
36+ ProcessingTimeout time.Duration
3737 // TickerDuration is the ticker duration, for when a non empty batch would be processed
38- TickerDuration time.Duration
39- // Size is the micro batch size
40- Size uint
38+ TickerDuration time.Duration
39+ // Size is the micro batch size
40+ Size uint
4141
4242 // Processor is the function which processes a single batch
43- Processor BatchProcessor [T]
43+ Processor BatchProcessor [T]
4444
45- // ResumeAfterErr if true will continue listening and keep processing if the processor returns
46- // an error, or if processor panics. In both cases, ProcessorErr would be executed
47- ResumeAfterErr bool
45+ // ResumeAfterErr if true will continue listening and keep processing if the processor returns
46+ // an error, or if processor panics. In both cases, ProcessorErr would be executed
47+ ResumeAfterErr bool
4848 // ProcessorErr is executed if the processor returns erorr or panics
49- ProcessorErr func (failedBatch []T , err error )
49+ ProcessorErr func (failedBatch []T , err error )
5050}
5151```
5252
0 commit comments