worker

Documentation

Index

• type Config
  • func DefaultConfig() Config
• type Job
• type Pool
  • func NewPool(config Config) *Pool
  • func (p *Pool) Start()
  • func (p *Pool) Stop()
  • func (p *Pool) Submit(job Job) error

Types

type Config

type Config struct {
	Workers    int
	QueueSize  int
	MaxRetries int
	RetryDelay time.Duration
}

Config represents worker pool configuration

func DefaultConfig

func DefaultConfig() Config

DefaultConfig returns default configuration

type Job

type Job struct {
	ID       string
	Task     func() error
	Response chan error
}

Job represents a task to be processed

type Pool

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

Pool represents a worker pool

func NewPool

func NewPool(config Config) *Pool

NewPool creates a new worker pool

func (*Pool) Start

func (p *Pool) Start()

Start initializes and starts the worker pool

func (*Pool) Stop

func (p *Pool) Stop()

Stop gracefully shuts down the worker pool

func (*Pool) Submit

func (p *Pool) Submit(job Job) error

Submit adds a new job to the pool