Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, t *node.TopologyBuilder, metricsReporter metrics.Reporter, config *PoolConfig) *Pool
type PoolConfig ¶
type PoolConfig struct { NumOfWorkers int WorkerBufferSize int Logger log.Logger Order ExecutionOrder }
Click to show internal directories.
Click to hide internal directories.