forked from gnuoy/snap-openstack
-
Notifications
You must be signed in to change notification settings - Fork 35
feat: genearte stx charm #770
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Open
ahmad-can
wants to merge
3
commits into
canonical:main
Choose a base branch
from
ahmad-can:feature/generate-stx-charm
base: main
Could not load branches
Branch not found: {{ refName }}
Loading
Could not load tags
Nothing to show
Loading
Are you sure you want to change the base?
Some commits from the old base branch may be removed from the timeline,
and old review comments may become outdated.
Open
Changes from all commits
Commits
File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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 | ||
|
|
||
| """Stx backend for Sunbeam storage.""" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| # SPDX-FileCopyrightText: 2026 - Canonical Ltd | ||
| # SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| """Stx backend implementation using base step classes.""" | ||
|
|
||
| import logging | ||
| from enum import StrEnum | ||
| from typing import Annotated | ||
|
|
||
| from pydantic import Field | ||
| from rich.console import Console | ||
|
|
||
| from sunbeam.core.manifest import StorageBackendConfig | ||
| from sunbeam.storage.base import StorageBackendBase | ||
|
|
||
| LOG = logging.getLogger(__name__) | ||
| console = Console() | ||
|
|
||
|
|
||
| class PoolType(StrEnum): | ||
| """Enumeration of valid pool types.""" | ||
|
|
||
| LINEAR = "linear" | ||
| VIRTUAL = "virtual" | ||
|
|
||
|
|
||
| class Protocol(StrEnum): | ||
| """Enumeration of valid protocol types.""" | ||
|
|
||
| ISCSI = "iscsi" | ||
|
|
||
|
|
||
| class StxConfig(StorageBackendConfig): | ||
| """Configuration model for Stx 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 connection configuration | ||
| protocol: Annotated[ | ||
| Protocol | None, | ||
| Field(description="Protocol selector: iscsi."), | ||
| ] = None | ||
|
|
||
| # Optional backend configuration | ||
| seagate_pool_name: Annotated[ | ||
| str | None, | ||
| Field(description="Pool or vdisk name to use for volume creation"), | ||
| ] = "A" | ||
| seagate_pool_type: Annotated[ | ||
| PoolType | None, | ||
| Field(description="linear (for vdisk) or virtual (for virtual pool)"), | ||
| ] = None | ||
| seagate_iscsi_ips: Annotated[ | ||
| str | None, | ||
| Field(description="List of comma-separated target iSCSI IP addresses"), | ||
| ] = None | ||
|
ahmad-can marked this conversation as resolved.
|
||
|
|
||
|
|
||
| class StxBackend(StorageBackendBase): | ||
| """Stx backend implementation.""" | ||
|
|
||
| backend_type = "stx" | ||
| display_name = "Stx" | ||
| generally_available = True | ||
|
|
||
| @property | ||
| def charm_name(self) -> str: | ||
| """Return the charm application name.""" | ||
| return "cinder-volume-stx" | ||
|
|
||
| @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 StxConfig | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
84 changes: 84 additions & 0 deletions
84
sunbeam-python/tests/unit/sunbeam/storage/backends/test_stx.py
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,84 @@ | ||
| # SPDX-FileCopyrightText: 2026 - Canonical Ltd | ||
| # SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| """Tests for Stx backend.""" | ||
|
|
||
| import pytest | ||
| from pydantic import ValidationError | ||
|
|
||
| from tests.unit.sunbeam.storage.backends.test_common import BaseBackendTests | ||
|
|
||
|
|
||
| class TestStxBackend(BaseBackendTests): | ||
| """Tests for Stx backend.""" | ||
|
|
||
| @pytest.fixture | ||
| def backend(self, stx_backend): | ||
| """Provide Stx backend instance.""" | ||
| return stx_backend | ||
|
|
||
| def test_config_has_stx_specific_fields(self, backend): | ||
| """Test that Stx config exposes Stx-specific fields.""" | ||
| fields = backend.config_type().model_fields | ||
| for field in ("seagate_pool_name", "seagate_pool_type", "seagate_iscsi_ips"): | ||
| assert field in fields, f"Stx-specific field {field} not found in config" | ||
|
|
||
| def test_seagate_pool_name_has_expected_default(self, backend): | ||
| """Test that seagate_pool_name default is set.""" | ||
| field = backend.config_type().model_fields["seagate_pool_name"] | ||
| assert field.default == "A" | ||
|
|
||
|
|
||
| class TestStxConfigValidation: | ||
| """Test Stx config validation behavior.""" | ||
|
|
||
| def test_protocol_rejects_invalid_value(self, stx_backend): | ||
| """Test that protocol rejects values other than iscsi.""" | ||
| config_class = stx_backend.config_type() | ||
| with pytest.raises(ValidationError) as exc_info: | ||
| config_class.model_validate( | ||
| { | ||
| "san-ip": "192.168.1.1", | ||
| "protocol": "fc", | ||
| } | ||
| ) | ||
| assert any( | ||
| error.get("loc") == ("protocol",) for error in exc_info.value.errors() | ||
| ) | ||
|
|
||
| def test_protocol_accepts_iscsi(self, stx_backend): | ||
| """Test that protocol accepts iscsi.""" | ||
| config_class = stx_backend.config_type() | ||
| config = config_class.model_validate( | ||
| { | ||
| "san-ip": "192.168.1.1", | ||
| "protocol": "iscsi", | ||
| } | ||
| ) | ||
| assert config.protocol == "iscsi" | ||
|
|
||
| def test_pool_type_accepts_valid_value(self, stx_backend): | ||
| """Test that seagate_pool_type accepts valid enum values.""" | ||
| config_class = stx_backend.config_type() | ||
| config = config_class.model_validate( | ||
| { | ||
| "san-ip": "192.168.1.1", | ||
| "seagate-pool-type": "linear", | ||
| } | ||
| ) | ||
| assert str(config.seagate_pool_type) == "linear" | ||
|
|
||
| def test_pool_type_rejects_invalid_value(self, stx_backend): | ||
| """Test that seagate_pool_type rejects invalid values.""" | ||
| config_class = stx_backend.config_type() | ||
| with pytest.raises(ValidationError) as exc_info: | ||
| config_class.model_validate( | ||
| { | ||
| "san-ip": "192.168.1.1", | ||
| "seagate-pool-type": "raid", | ||
| } | ||
| ) | ||
| assert any( | ||
| error.get("loc") == ("seagate-pool-type",) | ||
| for error in exc_info.value.errors() | ||
| ) |
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.