pool

type Config struct {
	// Instance name
	Name string `koanf:"-"`

	// Pools defines the named pools this module manages. Prefer snake_case
	// pool names; hyphens cannot be overridden via environment variables.
	Pools map[string]PoolConfig `koanf:"pools"`

	// CodePools holds pools registered via WithPool (code-only). A config
	// entry with the same name replaces it wholesale.
	CodePools map[string]PoolConfig `code_only:"WithPool" koanf:"-"`
}

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

type Module struct {
	lakta.NamedBase
	// contains filtered or unexported fields
}

type Option func(m *Config)

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

type PoolConfig struct {
	// Workers is the number of concurrent workers. Zero or less uses NumCPU.
	Workers int `koanf:"workers"`

	// QueueSize is the pending-task queue capacity. Nil uses the default
	// (1024); zero means direct handoff to an idle worker.
	QueueSize *int `koanf:"queue_size"`
}

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