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
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

workerpool

package

Go to main page

Versions in this module

v1

v1.1.0

Feb 11, 2026

Changes in this version

+ func TimeoutErrorKey() string

type DAGResult

+ func (r DAGResult) Blockers(dag DAG, job string) []string

+ func (r DAGResult) BoundarySubtrees(dag DAG) []string

+ func (r DAGResult) Frontiers(dag DAG) Frontiers

+ func (r DAGResult) Subtree(dag DAG, root string) []string

+ type FrontierItem struct

+ BlockedBy []string

+ Job string

+ Status JobStatus

+ Subtree []string

+ func (f *FrontierItem) IsBlocked() bool

+ type Frontiers []*FrontierItem

+ func (f Frontiers) AsMap() map[string]*FrontierItem

v1.0.0

Feb 8, 2026

Changes in this version

+ type DAG map[string][]string

+ type DAGResult map[string]*JobResult

+ func (r DAGResult) FirstError() error

+ func (r DAGResult) FirstInProgress() *JobResult

+ func (r DAGResult) IsFailed() bool

+ func (r DAGResult) IsNotReady() bool

+ func (r DAGResult) IsNotSuccessful() bool

+ func (r DAGResult) IsReady() bool

+ func (r DAGResult) IsSuccessful() bool

+ func (r DAGResult) IsTimeouted() bool

+ func (r DAGResult) TimeoutError(deadline time.Duration)

+ type Job interface

+ Do func(ctx context.Context) (bool, error)

+ type JobResult struct

+ Error error

+ Name string

+ Status JobStatus

+ func (j *JobResult) Fail(err error)

+ func (j *JobResult) IsFailed() bool

+ func (j *JobResult) IsInProgress() bool

+ func (j *JobResult) IsNotSkipped() bool

+ func (j *JobResult) IsSkipped() bool

+ func (j *JobResult) IsSuccessfull() bool

+ func (j *JobResult) NotReady()

+ func (j *JobResult) Skip()

+ func (j *JobResult) Success()

+ type JobStatus int

+ const JobStatusFailed

+ const JobStatusInProgress

+ const JobStatusSkipped

+ const JobStatusSuccess

+ const JobStatusUnknown

+ type MockJob struct

+ func NewMockJob(ctrl *gomock.Controller) *MockJob

+ func (m *MockJob) Do(ctx context.Context) (bool, error)

+ func (m *MockJob) EXPECT() *MockJobMockRecorder

+ func (m *MockJob) String() string

+ type MockJobMockRecorder struct

+ func (mr *MockJobMockRecorder) Do(ctx any) *gomock.Call

+ func (mr *MockJobMockRecorder) String() *gomock.Call

+ type Result struct

+ Err error

+ IsReady bool

+ JobName string

+ type WorkerPool interface

+ Start func() DAGResult

+ func NewWorkerPool(maxConcurrentJobs int, jobs []Job, dag DAG, logger *zerolog.Logger, ...) (WorkerPool, error)

+ type WorkerPoolImpl struct

+ func (w *WorkerPoolImpl) Start() DAGResult