concurrency

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

type ConcurrencyStats struct {
	// ActiveWorkers is the number of active workers
	ActiveWorkers int32
	// PendingTasks is the number of pending tasks
	PendingTasks int32
	// CompletedTasks is the number of completed tasks
	CompletedTasks int64
	// FailedTasks is the number of failed tasks
	FailedTasks int64
	// TotalTasks is the total number of tasks
	TotalTasks int64
	// AverageTaskDuration is the average task duration
	AverageTaskDuration time.Duration
	// MaxTaskDuration is the maximum task duration
	MaxTaskDuration time.Duration
	// MinTaskDuration is the minimum task duration
	MinTaskDuration time.Duration
	// TotalTaskDuration is the total task duration
	TotalTaskDuration time.Duration
	// QueuedTasks is the number of queued tasks
	QueuedTasks int32
	// WorkerScalingEvents is the number of worker scaling events
	WorkerScalingEvents int64
	// LastScaleUpTime is the time of the last scale up
	LastScaleUpTime time.Time
	// LastScaleDownTime is the time of the last scale down
	LastScaleDownTime time.Time
}

type ManagerConfig struct {
	// MaxWorkers is the maximum number of workers
	MaxWorkers int
	// MinWorkers is the minimum number of workers
	MinWorkers int
	// InitialWorkers is the initial number of workers
	InitialWorkers int
	// QueueSize is the size of the task queue
	QueueSize int
	// WorkerIdleTimeout is the timeout for idle workers
	WorkerIdleTimeout time.Duration
	// TaskTimeout is the timeout for tasks
	TaskTimeout time.Duration
	// EnableAutoScaling enables automatic worker scaling
	EnableAutoScaling bool
	// ScaleUpThreshold is the threshold for scaling up workers
	ScaleUpThreshold float64
	// ScaleDownThreshold is the threshold for scaling down workers
	ScaleDownThreshold float64
	// ScaleCheckInterval is the interval for checking if workers need to be scaled
	ScaleCheckInterval time.Duration
	// ScaleUpStep is the number of workers to add when scaling up
	ScaleUpStep int
	// ScaleDownStep is the number of workers to remove when scaling down
	ScaleDownStep int
}

type Task interface {
	// Execute executes the task
	Execute(ctx context.Context) error
	// ID returns the task ID
	ID() string
	// Priority returns the task priority
	Priority() int
}