workerpool

type Component interface {
	StartTask(*component.TaskConfig)
	FromRequestContext(context.Context) context.Context
}

type Config struct {
	Component
	context.Context                  // The base context of the pool.
	Name              string         // The name of the pool.
	CreateHandler     HandlerFactory // The function that creates handlers.
	MinWorkers        int            // The minimum number of workers in the pool.
	MaxWorkers        int            // The maximum number of workers in the pool.
	QueueSize         int            // The size of the work queue.
	WorkerIdleTimeout time.Duration  // The maximum amount of time a worker will stay idle before closing.
}

type Handler func(ctx context.Context, item interface{})

type HandlerFactory func() (Handler, error)

type WorkerPool interface {
	// Publish publishes an item to the worker pool to be processed.
	// Publish may spawn a worker in order to fullfil the work load.
	// Publish does not block.
	Publish(ctx context.Context, item interface{}) error
}