workerpool

type Context struct {
	context.Context
	// contains filtered or unexported fields
}

type None struct{}

type Option[T TaskMayPanic, R any] interface {
	Apply(pool *WorkerPool[T, R])
}

type TaskMayPanic interface {
	// RecoverArgs returns the argument for pkg/util.Recover function of this task.
	// The error returned is which will be passed to upper level, if not provided,
	// we will use the default error.
	RecoverArgs() (metricsLabel string, funcInfo string, err error)
}

type Tuner interface {
	Tune(numWorkers int32, wait bool)
}

type Worker[T TaskMayPanic, R any] interface {
	// HandleTask consumes a task(T), either produces a result(R) or return an error.
	// The result is sent to the result channel by calling `send` function, and the
	// error returned will be catched, log, and broadcasted it to other operators
	// by worker pool.
	// TODO(joechenrh): we can pass the context to HandleTask, so we don't need to
	// store the context in each worker implementation.
	HandleTask(task T, send func(R)) error
	Close() error
}

type WorkerPool[T TaskMayPanic, R any] struct {
	// contains filtered or unexported fields
}