worker

package

v1.0.0 Latest Latest Go to latest Published: Jun 12, 2026 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func CalculateRetryDelay(attempt int, maxRetries int) time.Duration

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

func NewClaimer(store storage.Storage, workerID string, batchSize int) *Claimer

func (c *Claimer) Start()

func (c *Claimer) Stop()

func (c *Claimer) Tasks() <-chan *task.Task

type ExponentialBackoff struct {
	BaseDelay  time.Duration
	MaxDelay   time.Duration
	Multiplier float64
}

func NewExponentialBackoff(base, max time.Duration) *ExponentialBackoff

func (e *ExponentialBackoff) NextDelay(attempt int) time.Duration

type FixedBackoff struct {
	Delay time.Duration
}

func NewFixedBackoff(delay time.Duration) *FixedBackoff

func (f *FixedBackoff) NextDelay(attempt int) time.Duration

type LinearBackoff struct {
	BaseDelay time.Duration
	MaxDelay  time.Duration
}

func NewLinearBackoff(base, max time.Duration) *LinearBackoff

func (l *LinearBackoff) NextDelay(attempt int) time.Duration

type NoBackoff struct{}

func (n *NoBackoff) NextDelay(attempt int) time.Duration

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

func NewPool(store storage.Storage, registry *registry.Registry, count int) *Pool

func (p *Pool) Start()

func (p *Pool) Stop()

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

func NewProcessor(store storage.Storage, registry *registry.Registry,
	workerID string, taskChan <-chan *task.Task, concurrency int) *Processor

func (p *Processor) Start()

func (p *Processor) Stop()

type RetryStrategy interface {
	NextDelay(attempt int) time.Duration
}

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