workerpool

type Config struct {
	// Size is the number of workers in the pool
	Size int
	// QueueSize is the task queue buffer size (0 = unbuffered)
	QueueSize int
	// IdleTimeout is the duration after which idle workers are reduced
	IdleTimeout time.Duration
	// EnableDynamicScaling allows the pool to scale up/down based on load
	EnableDynamicScaling bool
	// MinWorkers is the minimum number of workers when dynamic scaling is enabled
	MinWorkers int
	// MaxWorkers is the maximum number of workers when dynamic scaling is enabled
	MaxWorkers int
}

type MapPool[K comparable, V any] struct {
	// contains filtered or unexported fields
}

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

type Result struct {
	Value interface{}
	Error error
}

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

type RowPoolStats struct {
	Allocations int64
	Reuses      int64
	Returns     int64
	ReuseRate   float64
}

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

type ScanFunc func(ctx context.Context, task ScanTask) (ScanResult, error)

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

type ScanResult struct {
	TaskID int
	Items  []interface{}
	Error  error
}

type ScanTask struct {
	ID         int
	StartIndex int
	EndIndex   int
	Data       interface{}
}

type SlicePool[T any] struct {
	// contains filtered or unexported fields
}

type Stats struct {
	Workers       int
	TasksExecuted int64
	TasksFailed   int64
	QueueSize     int
	MaxQueueSize  int
	IsRunning     bool
	IsClosed      bool
}

type Task func(ctx context.Context) error

type TaskFunc func(ctx context.Context) (interface{}, error)

type ValuePool[T any] struct {
	// contains filtered or unexported fields
}