package
1.44.0
Repository: https://github.com/rudderlabs/rudder-server.git
Documentation: pkg.go.dev

# Functions

New creates a new worker pool.
WithCleanupPeriod option sets the cleanup period for the worker pool.
WithIdleTimeout option sets the idle timeout for the worker pool.

# Interfaces

Worker is a worker that can be pinged for work and stopped by the worker pool when it is idle.
WorkerPool manages a pool of workers and their lifecycle.

# Type aliases

WorkerSupplier is a function able to create a new worker for the given partition.