feat: add Cinder volume storage backends and tests

sunbeam-python/sunbeam/storage/backends/datacore/__init__.py

@@ -0,0 +1,4 @@
+# SPDX-FileCopyrightText: 2026 - Canonical Ltd
+# SPDX-License-Identifier: Apache-2.0
+
+"""DataCore storage backend for Sunbeam."""

sunbeam-python/sunbeam/storage/backends/datacore/backend.py

@@ -0,0 +1,126 @@
+# SPDX-FileCopyrightText: 2026 - Canonical Ltd
+# SPDX-License-Identifier: Apache-2.0
+
+"""DataCore backend implementation using base step classes."""
+
+import logging
+from typing import Annotated, Literal
+
+from pydantic import Field
+from rich.console import Console
+
+from sunbeam.core.manifest import StorageBackendConfig
+from sunbeam.storage.base import StorageBackendBase
+from sunbeam.storage.models import SecretDictField
+
+LOG = logging.getLogger(__name__)
+console = Console()
+
+
+class DatacoreConfig(StorageBackendConfig):
+    """Configuration model for DataCore SANsymphony backend.
+
+    This model includes ALL configuration options for the backend.
+    Additional configuration can be managed dynamically through the charm.
+    """
+
+    # Mandatory connection parameters
+    san_ip: Annotated[
+        str,
+        Field(description="IP address or hostname of the DataCore management endpoint"),
+    ]
+    san_login: Annotated[
+        str,
+        Field(description="Username for DataCore management authentication"),
+        SecretDictField(field="san-login"),
+    ]
+    san_password: Annotated[
+        str,
+        Field(description="Password for DataCore management authentication"),
+        SecretDictField(field="san-password"),
+    ]
+
+    # Protocol selection
+    protocol: Annotated[
+        Literal["iscsi", "fc"] | None,
+        Field(description="Front-end protocol used by DataCore (iscsi or fc)"),
+    ] = None
+
+    # DataCore-specific options
+    datacore_disk_pools: Annotated[
+        str | None,
+        Field(
+            description="Comma-separated list of DataCore disk pools to use for virtual disk creation"  # noqa: E501
+        ),
+    ] = None
+    datacore_disk_type: Annotated[
+        Literal["single", "mirrored"] | None,
+        Field(
+            description="Virtual disk type: single or mirrored (mirrored requires two DataCore servers)"  # noqa: E501
+        ),
+    ] = None
+    datacore_storage_profile: Annotated[
+        str | None,
+        Field(
+            description="Storage profile for virtual disk (Critical, High, Normal, Low, Archive)"  # noqa: E501
+        ),
+    ] = None
+    datacore_api_timeout: Annotated[
+        int | None,
+        Field(description="Timeout in seconds for DataCore API calls"),
+    ] = None
+    datacore_disk_failed_delay: Annotated[
+        int | None,
+        Field(
+            description="Timeout in seconds to wait for a virtual disk to leave Failed state"  # noqa: E501
+        ),
+    ] = None
+
+    # iSCSI-specific options
+    datacore_iscsi_unallowed_targets: Annotated[
+        str | None,
+        Field(
+            description="Comma-separated list of iSCSI targets that cannot be used for volume attachment"  # noqa: E501
+        ),
+    ] = None
+    use_chap_auth: Annotated[
+        bool | None,
+        Field(description="Enable CHAP authentication for iSCSI targets"),
+    ] = None
+
+
+class DatacoreBackend(StorageBackendBase):
+    """DataCore backend implementation."""
+
+    backend_type = "datacore"
+    display_name = "DataCore"
+    generally_available = True
+
+    @property
+    def charm_name(self) -> str:
+        """Return the charm application name."""
+        return "cinder-volume-datacore"
+
+    @property
+    def charm_channel(self) -> str:
+        """Return the default charm channel."""
+        return "2024.1/edge"
+
+    @property
+    def charm_revision(self) -> str | None:
+        """Return a pinned charm revision, if any."""
+        return None
+
+    @property
+    def charm_base(self) -> str:
+        """Return the target base for this charm."""
+        return "ubuntu@24.04"
+
+    @property
+    def supports_ha(self) -> bool:
+        """Whether this backend supports HA deployments."""
+        return False
+
+    def config_type(self) -> type[StorageBackendConfig]:
+        """Return the configuration model type for this backend."""
+        return DatacoreConfig

sunbeam-python/sunbeam/storage/backends/datera/__init__.py

@@ -0,0 +1,4 @@
+# SPDX-FileCopyrightText: 2026 - Canonical Ltd
+# SPDX-License-Identifier: Apache-2.0
+
+"""Datera backend for Sunbeam storage."""

sunbeam-python/sunbeam/storage/backends/datera/backend.py

@@ -0,0 +1,141 @@
+# SPDX-FileCopyrightText: 2026 - Canonical Ltd
+# SPDX-License-Identifier: Apache-2.0
+
+"""Datera backend implementation using base step classes."""
+
+import logging
+from typing import Annotated, Literal
+
+from pydantic import Field
+from rich.console import Console
+
+from sunbeam.core.manifest import StorageBackendConfig
+from sunbeam.storage.base import StorageBackendBase
+from sunbeam.storage.models import SecretDictField
+
+LOG = logging.getLogger(__name__)
+console = Console()
+
+
+class DateraConfig(StorageBackendConfig):
+    """Configuration model for Datera backend.
+
+    This model includes ALL configuration options for the backend.
+    Additional configuration can be managed dynamically through the charm.
+    """
+
+    # Mandatory connection parameters
+    san_ip: Annotated[str, Field(description="IP address of SAN controller")]
+    san_login: Annotated[
+        str,
+        Field(description="Username for SAN controller"),
+        SecretDictField(field="san-login"),
+    ]
+    san_password: Annotated[
+        str,
+        Field(description="Password for SAN controller"),
+        SecretDictField(field="san-password"),
+    ]
+
+    # Optional backend configuration
+    protocol: Annotated[
+        Literal["iscsi"],
+        Field(description="Protocol selector: iscsi."),
+    ] = "iscsi"
+    datera_ldap_server: Annotated[
+        str | None, Field(description="LDAP authentication server")
+    ] = None
+    datera_503_timeout: Annotated[
+        int | None, Field(description="Timeout for HTTP 503 retry messages")
+    ] = None
+    datera_503_interval: Annotated[
+        int | None, Field(description="Interval between 503 retries")
+    ] = None
+    datera_debug: Annotated[
+        bool | None, Field(description="True to set function arg and return logging")
+    ] = None
+    datera_debug_replica_count_override: Annotated[
+        bool | None,
+        Field(
+            description="ONLY FOR DEBUG/TESTING PURPOSES True to set replica_count to 1"
+        ),
+    ] = None
+    datera_tenant_id: Annotated[
+        str | None,
+        Field(
+            description="If set to 'Map' --> OpenStack project ID will be mapped implicitly to Datera tenant ID"  # noqa: E501
+        ),
+    ] = None
+    datera_enable_image_cache: Annotated[
+        bool | None,
+        Field(description="Set to True to enable Datera backend image caching"),
+    ] = None
+    datera_image_cache_volume_type_id: Annotated[
+        str | None, Field(description="Cinder volume type id to use for cached volumes")
+    ] = None
+    datera_disable_profiler: Annotated[
+        bool | None,
+        Field(description="Set to True to disable profiling in the Datera driver"),
+    ] = None
+    datera_disable_extended_metadata: Annotated[
+        bool | None,
+        Field(
+            description="Set to True to disable sending additional metadata to the Datera backend"  # noqa: E501
+        ),
+    ] = None
+    datera_disable_template_override: Annotated[
+        bool | None,
+        Field(
+            description="Set to True to disable automatic template override of the size attribute when creating from a template"  # noqa: E501
+        ),
+    ] = None
+    datera_volume_type_defaults: Annotated[
+        str | None,
+        Field(
+            description="Settings here will be used as volume-type defaults if the volume-type setting is not provided."  # noqa: E501
+        ),
+    ] = None
+    san_thin_provision: Annotated[
+        bool | None, Field(description="Use thin provisioning for SAN volumes?")
+    ] = None
+    use_multipath_for_image_xfer: Annotated[
+        bool | None,
+        Field(description="Enable multipathing for image transfer operations."),
+    ] = None
+
+
+class DateraBackend(StorageBackendBase):
+    """Datera backend implementation."""
+
+    backend_type = "datera"
+    display_name = "Datera"
+    generally_available = True
+
+    @property
+    def charm_name(self) -> str:
+        """Return the charm application name."""
+        return "cinder-volume-datera"
+
+    @property
+    def charm_channel(self) -> str:
+        """Return the default charm channel."""
+        return "2024.1/edge"
+
+    @property
+    def charm_revision(self) -> str | None:
+        """Return a pinned charm revision, if any."""
+        return None
+
+    @property
+    def charm_base(self) -> str:
+        """Return the target base for this charm."""
+        return "ubuntu@24.04"
+
+    @property
+    def supports_ha(self) -> bool:
+        """Whether this backend supports HA deployments."""
+        return False
+
+    def config_type(self) -> type[StorageBackendConfig]:
+        """Return the configuration model type for this backend."""
+        return DateraConfig

sunbeam-python/sunbeam/storage/backends/dellpowermax/__init__.py

@@ -0,0 +1,4 @@
+# SPDX-FileCopyrightText: 2026 - Canonical Ltd
+# SPDX-License-Identifier: Apache-2.0
+
+"""Dell PowerMax backend for Sunbeam storage."""