processor

Nov 25, 2021

Changes in this version

+ func IsFatalErr(err error) bool

+ func NewFatalErr(err error) error

+ type FatalErr interface

+ Fatal func() bool

Sep 10, 2021

retracted

Changes in this version

+ func Provides(hs ...Handler) di.Deps

Jul 21, 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) ProvideCloser()

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