processor

May 25, 2021

Changes in this version

type Processor

+ func (e *Processor) ProvideCloser()

May 19, 2021

Changes in this version

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

+ type BatchHandler interface

+ Batch func(ctx context.Context, data []interface{}) error

+ type HandleFunc func(ctx context.Context, msg *kafka.Message) (interface{}, error)

+ type Handler interface

+ Handle func(ctx context.Context, msg *kafka.Message) (interface{}, error)

+ Info func() *Info

+ type Info struct

+ AutoBatchInterval time.Duration

+ BatchSize int

+ BatchWorker int

+ ChanSize int

+ HandleWorker int

+ Name string

+ ReadWorker int

+ type Out struct

+ Handlers []Handler

+ func NewOut(handlers ...Handler) Out

+ type Processor struct

+ func New(i in) (*Processor, error)

+ func (e *Processor) ProvideRunGroup(group *run.Group)