pool

type BatchQueueOptions struct {
	Capacity  int
	BatchSize int
}

type DelayedQueueOptions struct {
	Capacity int
}

type PriorityQueueOptions struct {
	Capacity int
}

type QueueOptions struct {
	Capacity int
}

type RateLimitQueueOptions struct {
	Capacity      int
	RatePerSecond float64
}

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

type WorkerPoolConfig struct {
	// Name of the worker pool
	Name string

	// Number of workers in the pool
	NumWorkers int

	// Queue configuration
	QueueType      queue.QueueType
	QueueCapacity  int
	QueueRateLimit time.Duration
	QueueBatchSize int

	// Dead letter queue configuration
	DeadLetterQueueCapacity int

	// Default timeout for task execution
	DefaultTimeout time.Duration

	// Default retry policy
	DefaultRetryPolicy worker.RetryPolicy

	// Error handler for task execution errors
	ErrorHandler func(error)

	// Metrics configuration
	EnableMetrics bool
	Metrics       *metrics.Metrics

	// Task store for persistence (now includes execution results)
	TaskStore store.TaskStore

	// Enable task persistence
	EnablePersistence bool
}