worker

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

type ParallelizationStrategy string

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

type PoolConfig struct {
	// Basic pool sizing
	WorkerCount int
	QueueSize   int

	// Timeouts
	TaskTimeout time.Duration

	// Rate limiting
	RateLimit rate.Limit

	// Retry behaviour
	RetryPolicy *RetryPolicy

	// Progress & observability
	ProgressTracking bool
	DetailedLogging  bool

	// Parallelisation hint (may influence task schedulers)
	Strategy ParallelizationStrategy
}

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

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

type Result interface{}

type RetryPolicy struct {
	MaxAttempts       int
	InitialBackoff    time.Duration
	MaxBackoff        time.Duration
	BackoffMultiplier float64
	JitterFraction    float64
}

type Task interface {
	Execute(ctx context.Context) (Result, error)
	ID() string
	Priority() int
	Dependencies() []string
	Status() TaskStatus
	SetStatus(TaskStatus)
}

type TaskError struct {
	Task Task
	Err  error
}

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

type TaskResult struct {
	Task  Task
	Value Result
}

type TaskRunSummary struct {
	Results []TaskResult
	Errors  []TaskError
}

type TaskStatus int