Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions sunbeam-python/sunbeam/storage/backends/linstor/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""LINSTOR backend for Sunbeam storage."""
109 changes: 109 additions & 0 deletions sunbeam-python/sunbeam/storage/backends/linstor/backend.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,109 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""LINSTOR iSCSI backend implementation using base step classes."""

Comment thread
ahmad-can marked this conversation as resolved.
from typing import Annotated, Literal

from pydantic import Field

from sunbeam.core.manifest import StorageBackendConfig
from sunbeam.storage.base import StorageBackendBase


class LinstorConfig(StorageBackendConfig):
"""Configuration model for LINSTOR iSCSI 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="Storage array management IP address or hostname.")
]

# Optional backend configuration
protocol: Annotated[
Literal["iscsi"] | None,
Field(description="Protocol selector: iscsi."),
] = None
linstor_default_volume_group_name: Annotated[
str | None,
Field(
description=("Default volume group name for LINSTOR (not Cinder volume).")
),
] = None
linstor_default_uri: Annotated[
str | None,
Field(description="Default storage URI for LINSTOR."),
] = None
linstor_default_storage_pool_name: Annotated[
str | None,
Field(description="Default Storage Pool name for LINSTOR."),
] = None
linstor_volume_downsize_factor: Annotated[
str | None,
Field(description="Default volume downscale size in KiB = 4 MiB."),
] = None
linstor_default_blocksize: Annotated[
int | None,
Field(
description=(
"Default block size for image restoration. "
"When using iSCSI transport, this option specifies "
"the block size."
)
),
] = None
linstor_autoplace_count: Annotated[
int | None,
Field(
description=(
"Autoplace replication count on volume deployment: "
"0=full cluster without autoplace, 1=single-node "
"without replication, >=2=replicated with autoplace."
)
),
] = None
linstor_controller_diskless: Annotated[
bool | None,
Field(description="True means Cinder node is a diskless LINSTOR node."),
] = None


class LinstorBackend(StorageBackendBase):
"""LINSTOR iSCSI backend implementation."""

backend_type = "linstor"
display_name = "LINSTOR iSCSI"
generally_available = True
Comment thread
ahmad-can marked this conversation as resolved.

@property
def charm_name(self) -> str:
"""Return the charm application name."""
return "cinder-volume-linstor"

@property
def charm_channel(self) -> str:
"""Return the default charm channel."""
return "latest/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 LinstorConfig
12 changes: 11 additions & 1 deletion sunbeam-python/tests/unit/sunbeam/storage/backends/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
from sunbeam.storage.backends.dellpowerstore.backend import DellPowerstoreBackend
from sunbeam.storage.backends.dellsc.backend import DellSCBackend
from sunbeam.storage.backends.hitachi.backend import HitachiBackend
from sunbeam.storage.backends.linstor.backend import LinstorBackend
from sunbeam.storage.backends.purestorage.backend import PureStorageBackend


Expand All @@ -29,19 +30,28 @@ def dellsc_backend():
return DellSCBackend()


@pytest.fixture
def linstor_backend():
"""Provide a LINSTOR backend instance."""
return LinstorBackend()


@pytest.fixture
def dellpowerstore_backend():
"""Provide a Dell PowerStore backend instance."""
return DellPowerstoreBackend()


@pytest.fixture(params=["hitachi", "purestorage", "dellsc", "dellpowerstore"])
@pytest.fixture(
params=["hitachi", "purestorage", "dellsc", "linstor", "dellpowerstore"]
)
def any_backend(request):
"""Parametrized fixture that provides each backend type."""
backends = {
"hitachi": HitachiBackend(),
"purestorage": PureStorageBackend(),
"dellsc": DellSCBackend(),
"linstor": LinstorBackend(),
"dellpowerstore": DellPowerstoreBackend(),
}
return backends[request.param]
16 changes: 14 additions & 2 deletions sunbeam-python/tests/unit/sunbeam/storage/backends/test_common.py
Original file line number Diff line number Diff line change
Expand Up @@ -157,13 +157,18 @@ def backend(self, any_backend):


def test_all_backends_have_unique_types(
hitachi_backend, purestorage_backend, dellsc_backend, dellpowerstore_backend
hitachi_backend,
purestorage_backend,
dellsc_backend,
linstor_backend,
dellpowerstore_backend,
):
"""Test that all backends have unique type identifiers."""
backends = [
hitachi_backend,
purestorage_backend,
dellsc_backend,
linstor_backend,
dellpowerstore_backend,
]
types = [b.backend_type for b in backends]
Expand All @@ -173,13 +178,18 @@ def test_all_backends_have_unique_types(


def test_all_backends_have_unique_charm_names(
hitachi_backend, purestorage_backend, dellsc_backend, dellpowerstore_backend
hitachi_backend,
purestorage_backend,
dellsc_backend,
linstor_backend,
dellpowerstore_backend,
):
"""Test that all backends have unique charm names."""
backends = [
hitachi_backend,
purestorage_backend,
dellsc_backend,
linstor_backend,
dellpowerstore_backend,
]
charm_names = [b.charm_name for b in backends]
Expand All @@ -196,6 +206,7 @@ def test_all_backends_have_unique_charm_names(
("hitachi", "hitachi"),
("purestorage", "purestorage"),
("dellsc", "dellsc"),
("linstor", "linstor"),
("dellpowerstore", "dellpowerstore"),
],
)
Expand All @@ -211,6 +222,7 @@ def test_backend_types_match_expected(any_backend, backend_type, expected_type):
("hitachi", "cinder-volume-hitachi"),
("purestorage", "cinder-volume-purestorage"),
("dellsc", "cinder-volume-dellsc"),
("linstor", "cinder-volume-linstor"),
("dellpowerstore", "cinder-volume-dellpowerstore"),
],
)
Expand Down
57 changes: 57 additions & 0 deletions sunbeam-python/tests/unit/sunbeam/storage/backends/test_linstor.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,57 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""Tests for LINSTOR backend."""

import pytest
from pydantic import ValidationError

from tests.unit.sunbeam.storage.backends.test_common import BaseBackendTests


class TestLinstorBackend(BaseBackendTests):
"""Tests for LINSTOR backend."""

@pytest.fixture
def backend(self, linstor_backend):
"""Provide LINSTOR backend instance."""
return linstor_backend

def test_backend_type_is_linstor(self, backend):
"""Test that backend type is 'linstor'."""
assert backend.backend_type == "linstor"

def test_charm_name_is_linstor_charm(self, backend):
"""Test that charm name is cinder-volume-linstor."""
assert backend.charm_name == "cinder-volume-linstor"

def test_config_has_required_field(self, backend):
"""Test that LINSTOR config exposes its required field."""
fields = backend.config_type().model_fields
assert "san_ip" in fields, "Required field san_ip not found in config"


class TestLinstorConfigValidation:
"""Test LINSTOR config validation behavior."""

def test_protocol_rejects_invalid_value(self, linstor_backend):
"""Test that protocol rejects values other than iscsi."""
config_class = linstor_backend.config_type()
with pytest.raises(ValidationError):
config_class.model_validate(
{
"san-ip": "192.168.1.1",
"protocol": "fc",
}
)

def test_protocol_accepts_iscsi(self, linstor_backend):
"""Test that protocol accepts iscsi."""
config_class = linstor_backend.config_type()
config = config_class.model_validate(
{
"san-ip": "192.168.1.1",
"protocol": "iscsi",
}
)
assert config.protocol == "iscsi"
Loading