worker_pool

Documentation

Index

• type ExecutionOrder
  • func (eo ExecutionOrder) String() string
• type Pool
  • 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

Types

type ExecutionOrder

type ExecutionOrder int

const (
	OrderRandom ExecutionOrder = iota
	OrderByKey
	OrderPreserved
)

func (ExecutionOrder) String

func (eo ExecutionOrder) String() string

type Pool

type Pool struct {
	// contains filtered or unexported fields
}

func NewPool

func NewPool(id string, tb *topology.TopologyBuilder, metricsReporter metrics.Reporter, logger log.Logger, config *PoolConfig) *Pool

func (*Pool) Run

func (p *Pool) Run(ctx context.Context, key, val []byte, doneClb func())

func (*Pool) Stop

func (p *Pool) Stop()

type PoolConfig

type PoolConfig struct {
	NumOfWorkers     int
	WorkerBufferSize int
	Order            ExecutionOrder
}