Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + func New(conf Config, mgr bundle.NewManagement) (processor.Pipeline, error) + type Config struct + Processors []processor.Config + Threads int + func NewConfig() Config + type Pool struct + func NewPool(threads int, log log.Modular, msgProcessors ...processor.V1) (*Pool, error) + func (p *Pool) Consume(msgs <-chan message.Transaction) error + func (p *Pool) TransactionChan() <-chan message.Transaction + func (p *Pool) TriggerCloseNow() + func (p *Pool) WaitForClose(ctx context.Context) error + type Processor struct + func NewProcessor(msgProcessors ...processor.V1) *Processor + func (p *Processor) Consume(msgs <-chan message.Transaction) error + func (p *Processor) TransactionChan() <-chan message.Transaction + func (p *Processor) TriggerCloseNow() + func (p *Processor) WaitForClose(ctx context.Context) error
Go to main page