workerpool

package

v1.3.8 Latest Latest Go to latest Published: Feb 19, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var ErrAlreadyRunning = errors.New("worker pool is already running")

This section is empty.

type Executor interface {
	Execute(ctx context.Context) error
}

type Option func(*WorkerPool)

func WithExecutionTimeout(timeout time.Duration) Option

func WithName(name string) Option

func WithTickInterval(duration time.Duration) Option

func WithWorkerCount(count int) Option

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

func New(executor Executor, opts ...Option) *WorkerPool

func (pool *WorkerPool) Name() string

func (pool *WorkerPool) Start(ctx context.Context) error

func (pool *WorkerPool) Stop() error