Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

go-adaptive-pool

module

Go to main page

Versions in this module

v0

v0.2.0

Oct 23, 2026

Changes in this version

type Config

+ func SuggestConfig(workloadType WorkloadType) *Config

+ func (c *Config) MaxWorkers() int

+ func (c *Config) MinWorkers() int

+ func (c *Config) QueueSize() int

+ func (c *Config) ScaleCooldown() time.Duration

+ func (c *Config) ScaleDownIdleDuration() time.Duration

+ func (c *Config) ScaleUpThreshold() float64

type Option

+ func WithAutoConfig(profile WorkloadProfile) Option

+ func WithSystemAwareConfig(sysConfig SystemAwareConfig) Option

+ type SystemAwareConfig struct

+ AvgJobMemoryBytes int64

+ MemoryLimitPercent float64

+ TargetLatencyMs int

+ WorkloadType WorkloadType

+ type WorkloadProfile int

+ const ProfileAPIServer

+ const ProfileBatchProcessor

+ const ProfileCPUIntensive

+ type WorkloadType int

+ const CPUBound

+ const IOBound

+ const Mixed

v0.1.0

Oct 22, 2026

Changes in this version

+ var ErrNilJob = errors.New("job is nil")

+ var ErrPermanentFailure = errors.New("permanent failure")

+ var ErrRetriesExhausted = errors.New("retries exhausted")

+ var ErrRetryBudgetExceeded = errors.New("retry time budget exceeded")

+ func Permanent(err error) error

+ func RetryAfter(err error, d time.Duration) error

+ type Attacher interface

+ Attach func(info PoolInfo, stats Metrics) error

+ Detach func()

+ type Backoff interface

+ Next func(retry int) time.Duration

+ type Clock interface

+ After func(d time.Duration) <-chan time.Time

+ Now func() time.Time

+ type ConstantBackoff struct

+ Delay time.Duration

+ func (b ConstantBackoff) Next(int) time.Duration

+ type ErrorLimit struct

+ Err error

+ MaxAttempts int

+ type ExponentialBackoff struct

+ Base time.Duration

+ Multiplier float64

+ func (b ExponentialBackoff) Next(retry int) time.Duration

+ type LinearBackoff struct

+ Base time.Duration

+ func (b LinearBackoff) Next(retry int) time.Duration

type Metrics

+ AvgQueueWait func() time.Duration

+ BusyWorkers func() int

+ JobsDropped func() int64

+ JobsFailed func() int64

+ JobsRetried func() int64

+ RetryAttempts func() int64

type Option

+ func WithLogger(l *slog.Logger) Option

+ func WithName(name string) Option

+ func WithOnTaskDone(fn func(TaskResult)) Option

+ func WithRecorder(r Recorder) Option

+ func WithRetry(policy RetryPolicy) Option

+ type PanicError struct

+ Stack []byte

+ Value any

+ func (e *PanicError) Error() string

type Pool

+ SubmitTask func(ctx context.Context, task Task) error

+ TrySubmit func(ctx context.Context, task Task) error

+ type PoolInfo struct

+ MaxWorkers int

+ MinWorkers int

+ Name string

+ QueueSize int

+ type Recorder interface

+ JobCompleted func(kind string, status Status, attempts int, queueWait, duration time.Duration)

+ JobDropped func(kind string)

+ JobRejected func(kind string, reason RejectReason)

+ JobSubmitted func(kind string)

+ ScaledUp func(added int)

+ type RejectReason string

+ const RejectCanceled

+ const RejectQueueFull

+ const RejectShutdown

+ const RejectTimeout

+ type RetryError struct

+ Attempts int

+ Err error

+ Reason error

+ func (e *RetryError) Error() string

+ func (e *RetryError) Unwrap() []error

+ type RetryPolicy struct

+ Backoff Backoff

+ Clock Clock

+ ErrorLimits []ErrorLimit

+ Jitter bool

+ MaxAttempts int

+ MaxDelay time.Duration

+ MaxElapsedTime time.Duration

+ type ShutdownError struct

+ Dropped int

+ Err error

+ func (e *ShutdownError) Error() string

+ func (e *ShutdownError) Unwrap() error

+ type Status string

+ const StatusBudgetExceeded

+ const StatusCanceled

+ const StatusError

+ const StatusPanic

+ const StatusPermanent

+ const StatusRetriesExhausted

+ const StatusShutdown

+ const StatusSuccess

+ type Task struct

+ Context context.Context

+ ID string

+ Kind string

+ Run Job

+ type TaskResult struct

+ Attempts int

+ Duration time.Duration

+ Err error

+ ID string

+ Kind string

+ QueueWait time.Duration

+ Status Status

v0.0.2

Jan 1, 2026

Changes in this version

+ var ErrInvalidConfig = errors.New("invalid pool configuration")

+ var ErrPoolShutdown = errors.New("pool is shutdown")

+ var ErrQueueFull = errors.New("queue is full")

+ var ErrTimeout = errors.New("submission timeout")

+ type Config struct

+ type Job func(ctx context.Context) error

+ type Metrics interface

+ ActiveWorkers func() int

+ AvgJobLatency func() time.Duration

+ JobsProcessed func() int64

+ JobsRejected func() int64

+ QueueDepth func() int

+ type Option func(*Config)

+ func WithMaxWorkers(n int) Option

+ func WithMetricsEnabled(enabled bool) Option

+ func WithMinWorkers(n int) Option

+ func WithQueueSize(n int) Option

+ func WithScaleCooldown(d time.Duration) Option

+ func WithScaleDownIdleDuration(d time.Duration) Option

+ func WithScaleUpThreshold(pct float64) Option

+ type Pool interface

+ Metrics func() Metrics

+ Shutdown func(ctx context.Context) error

+ Submit func(ctx context.Context, job Job) error

+ func New(options ...Option) (Pool, error)

v0.0.1

Dec 30, 2025