Versions in this module Expand all Collapse all v1 v1.0.0 Mar 18, 2020 Changes in this version + type ExecutionOrder int + const OrderByKey + const OrderPreserved + const OrderRandom + func (eo ExecutionOrder) String() string + type Pool struct + func NewPool(id string, tb *topology.TopologyBuilder, metricsReporter metrics.Reporter, ...) *Pool + func (p *Pool) Run(ctx context.Context, key, val []byte, doneClb func()) + func (p *Pool) Stop() + type PoolConfig struct + NumOfWorkers int + Order ExecutionOrder + WorkerBufferSize int
Go to main page