refactor(compute): move libvirt VM pool driver into gcl_sdk

The libvirt-based machine pool driver and its universal-agent bridge
(compute/agents/universal/drivers/pool.py) now live natively in gcl_sdk
as a MetaCoordinatorAgentDriver (gcl_sdk.agents.universal.drivers.pool /
.libvirt), so remove the exordos_core-side copies:

- exordos_core/compute/pool/drivers/{base,exceptions,libvirt}.py
- exordos_core/compute/agents/universal/drivers/pool.py (and the now-empty
  compute/agents/ tree)
- the gcn_machine_pool_driver entry points and the PoolAgentDriver/
  LocalPoolAgentDriver entries under gcl_sdk_universal_agent
- the libvirt-python dependency (now pulled in transitively via the
  gcl_sdk[libvirt] extra)

compute/dm/models.py and compute/constants.py now re-export the moved
spec/storage-pool models and status enums from gcl_sdk instead of
defining them locally, so existing call sites (models.LibvirtPoolDriverSpec,
nc.MachineStatus, etc.) keep working unchanged. Also drop the dead
MachinePool.load_driver() method, which had no remaining callers.

compute/pool/dm/models.py (the control-plane Pool/Machine/MachineVolume
ORM models used by the scheduler/builder) is untouched.

Requires a gcl_sdk release containing gcl_sdk.agents.universal.drivers.pool/
.libvirt before `uv lock` can be re-run here; the gcl_sdk[libvirt] dependency
bump in pyproject.toml is in place but uv.lock is left as-is until then.

Author: VasilyStepanov

exordos_core/compute/agents/__init__.py

@@ -15,21 +15,24 @@
 #    under the License.
 
 import enum
-import typing as tp
 import uuid as sys_uuid
 
+from gcl_sdk.agents.universal.drivers.pool import BootAlternative  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import BootType  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import MachinePoolStatus  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import MachineStatus  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import NodeType  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import PortStatus  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import VolumeStatus  # noqa: F401
+
 DEF_SQL_LIMIT = 300
-EP_MACHINE_POOL_DRIVERS = "gcn_machine_pool_driver"
 EP_NETWORK_DRIVERS = "gcn_network_driver"
 DEF_ROOT_DISK_SIZE = 10
 POLICY_SERVICE_NAME = "compute"
 
 NODE_SET_PROJECT = sys_uuid.UUID("11111113-bc70-4760-9fbf-9fcfe40da329")
 
 
-BootType = tp.Literal["hd", "network", "cdrom"]
-
-
 class NodeStatus(str, enum.Enum):
     NEW = "NEW"
     SCHEDULED = "SCHEDULED"
@@ -39,30 +42,6 @@ class NodeStatus(str, enum.Enum):
     ERROR = "ERROR"
 
 
-class MachineStatus(str, enum.Enum):
-    NEW = "NEW"
-    SCHEDULED = "SCHEDULED"
-    IN_PROGRESS = "IN_PROGRESS"
-    STARTED = "STARTED"
-    ACTIVE = "ACTIVE"
-    IDLE = "IDLE"
-    ERROR = "ERROR"
-    FLASHED = "FLASHED"
-    NEED_RESCHEDULE = "NEED_RESCHEDULE"
-
-
-class VolumeStatus(str, enum.Enum):
-    NEW = "NEW"
-    IN_PROGRESS = "IN_PROGRESS"
-    ACTIVE = "ACTIVE"
-    ERROR = "ERROR"
-
-
-class NodeType(str, enum.Enum):
-    VM = "VM"
-    HW = "HW"
-
-
 class VolumeType(str, enum.Enum):
     QCOW2 = "QCOW2"
 
@@ -77,51 +56,5 @@ class MachineBuildStatus(str, enum.Enum):
     READY = "READY"
 
 
-class MachinePoolStatus(str, enum.Enum):
-    ACTIVE = "ACTIVE"
-    DISABLED = "DISABLED"
-    MAINTENANCE = "MAINTENANCE"
-    IN_PROGRESS = "IN_PROGRESS"
-
-
-class BootAlternative(str, enum.Enum):
-    hd0 = "hd0"
-    hd1 = "hd1"
-    hd2 = "hd2"
-    hd3 = "hd3"
-    hd4 = "hd4"
-    hd5 = "hd5"
-    hd6 = "hd6"
-    hd7 = "hd7"
-    cdrom = "cdrom"
-    network = "network"
-
-    @property
-    def hd_prefix(self) -> str:
-        return "hd"
-
-    @property
-    def boot_from_hd(self) -> bool:
-        return self.value.startswith(self.hd_prefix)
-
-    @property
-    def boot_type(self) -> BootType:
-        if self.boot_from_hd:
-            return self.hd_prefix
-        elif self.value == "cdrom":
-            return "cdrom"
-        elif self.value == "network":
-            return "network"
-
-        raise ValueError(f"Invalid boot alternative: {self.value}")
-
-
-class PortStatus(str, enum.Enum):
-    NEW = "NEW"
-    IN_PROGRESS = "IN_PROGRESS"
-    ACTIVE = "ACTIVE"
-    ERROR = "ERROR"
-
-
 class PlacementPolicyKind(str, enum.Enum):
     SOFT_ANTI_AFFINITY = "soft-anti-affinity"

exordos_core/compute/agents/universal/__init__.py

@@ -20,6 +20,12 @@
 
 from gcl_sdk.agents.universal.api import crypto as ua_crypto
 from gcl_sdk.agents.universal.dm import models as ua_models
+from gcl_sdk.agents.universal.drivers.pool import AbstractPoolDriverSpec  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import AbstractStoragePool  # noqa: F401
+from gcl_sdk.agents.universal.drivers.pool import DummyPoolDriverSpec
+from gcl_sdk.agents.universal.drivers.pool import ExordosLocalHyperDriverSpec
+from gcl_sdk.agents.universal.drivers.pool import LibvirtPoolDriverSpec
+from gcl_sdk.agents.universal.drivers.pool import ThinStoragePool
 from gcl_sdk.infra.dm import models as infra_models
 import netaddr
 from restalchemy.dm import filters as dm_filters
@@ -38,7 +44,6 @@
 from exordos_core.compute import constants as nc
 
 if tp.TYPE_CHECKING:
-    from exordos_core.compute.pool.drivers.base import AbstractPoolDriver
     from exordos_core.network.driver.base import AbstractNetworkDriver
 
 
@@ -61,135 +66,6 @@ def from_unicode(self, value):
         return self.from_simple_type(value)
 
 
-class AbstractStoragePool(
-    models.SimpleViewMixin,
-    types_dynamic.AbstractKindModel,
-):
-    """The abstract model for storage pool.
-
-    This model is used to represent the storage pool and determine
-    the its interfaces.
-    """
-
-    uuid = properties.property(
-        types.UUID(),
-        read_only=True,
-        id_property=True,
-        default=lambda: sys_uuid.uuid4(),
-    )
-    pool_type = properties.property(types.String(), required=True)
-
-    @property
-    def capacity(self) -> int:
-        """Storage pool capacity."""
-        return 0
-
-    @property
-    def available(self) -> int:
-        """Storage pool available space."""
-        return 0
-
-    def allocate_capacity(self, size: int) -> None:
-        """Allocate capacity."""
-        raise NotImplementedError()
-
-    def free_capacity(self, size: int) -> None:
-        """Free capacity."""
-        raise NotImplementedError()
-
-    def has_capacity(self, size: int) -> bool:
-        """Check if the storage pool has enough capacity."""
-        return self.available >= size
-
-
-class AbstractPoolDriverSpec(
-    types_dynamic.AbstractKindModel,
-    models.SimpleViewMixin,
-):
-    """Base class for all pool driver specs."""
-
-
-class LibvirtPoolDriverSpec(AbstractPoolDriverSpec):
-    KIND = "libvirt"
-
-    connection_uri = properties.property(
-        types.String(max_length=2048),
-        required=True,
-    )
-    network = properties.property(
-        types.AllowNone(types.String(max_length=255)),
-        default=None,
-    )
-    storage_pool = properties.property(
-        types.AllowNone(types.String(max_length=255)),
-        default=None,
-    )
-    machine_prefix = properties.property(
-        types.AllowNone(types.String(max_length=255)),
-        default=None,
-    )
-    network_type = properties.property(
-        types.Enum(["network", "bridge"]),
-        default="network",
-    )
-    iface_rom_file = properties.property(
-        types.AllowNone(types.String(max_length=255)),
-        default=None,
-    )
-    iface_mtu = properties.property(
-        types.Integer(min_value=0, max_value=65536),
-        default=1500,
-    )
-    iface_source = properties.property(
-        types.AllowNone(types.String(max_length=255)),
-        default=None,
-    )
-
-
-class ExordosLocalHyperDriverSpec(LibvirtPoolDriverSpec):
-    KIND = "exordos_local_hyper"
-
-    node = properties.property(types.UUID(), required=True)
-
-
-class DummyPoolDriverSpec(AbstractPoolDriverSpec):
-    KIND = "dummy"
-
-
-class ThinStoragePool(
-    AbstractStoragePool,
-    models.ModelWithNameDesc,
-):
-    """The model represents thin provisioned storage pool."""
-
-    KIND = "thin_storage_pool"
-
-    capacity_usable = properties.property(types.Integer(min_value=0), default=0)
-    capacity_provisioned = properties.property(types.Integer(min_value=0), default=0)
-    oversubscription_ratio = properties.property(
-        types.Float(min_value=0.0), default=1.0
-    )
-    available_actual = properties.property(types.Integer(min_value=0), default=0)
-
-    @property
-    def capacity(self) -> int:
-        """Storage pool capacity."""
-        return int(self.capacity_usable * self.oversubscription_ratio)
-
-    @property
-    def available(self) -> int:
-        """Storage pool available space."""
-        return self.capacity - self.capacity_provisioned
-
-    def allocate_capacity(self, size: int) -> None:
-        """Allocate capacity."""
-        self.capacity_provisioned += size
-
-    def free_capacity(self, size: int) -> None:
-        """Free capacity."""
-        self.capacity_provisioned -= size
-
-
 class MachinePool(
     models.ModelWithUUID,
     models.ModelWithNameDesc,
@@ -198,7 +74,6 @@ class MachinePool(
     models.SimpleViewMixin,
 ):
     __tablename__ = "machine_pools"
-    __driver_map__ = {}
 
     driver_spec = properties.property(
         types_dynamic.KindModelSelectorType(
@@ -235,38 +110,6 @@ class MachinePool(
         default=list,
     )
 
-    def load_driver(self) -> tp.Type["AbstractPoolDriver"]:
-        """
-        Load the driver for the machine pool.
-
-        This method will try to load all drivers from the
-        ``exordos_core.machine_pool_drivers`` entry point group and try to
-        instantiate them with the current machine pool. If a driver is
-        successfully loaded, it is stored in a cache for faster access.
-
-        If no driver is found, a ValueError is raised.
-
-        :return: The loaded driver class
-        :raises ValueError: If no driver is found
-        """
-        driver_key = str(self.driver_spec)
-
-        if driver_key in self.__driver_map__:
-            return self.__driver_map__[driver_key]
-
-        ep_group = utils.load_group_from_entry_point(nc.EP_MACHINE_POOL_DRIVERS)
-        for e in ep_group:
-            try:
-                class_ = e.load()
-                driver = class_(self)
-                self.__driver_map__[driver_key] = driver
-                return driver
-            except Exception:
-                # Just try another driver
-                pass
-
-        raise ValueError(f"Driver for spec '{self.driver_spec}' not found")
-
 
 class Volume(
     infra_models.Volume,