[internal] Add sds-common-scheduler-extender v2

.gitignore

@@ -48,3 +48,7 @@ images/agent/dev
 images/agent/Makefile
 local_build.sh
 /base_images.yml
+
+images/sds-common-scheduler-extender/REVIEW.md
+
+# trigger for build

api/v1alpha1/const.go

@@ -43,4 +43,22 @@ const (
 	BlockDeviceRotaLabelKey               = blockDeviceLabelPrefix + "/rota"
 	BlockDeviceHotPlugLabelKey            = blockDeviceLabelPrefix + "/hotplug"
 	BlockDeviceMachineIDLabelKey          = blockDeviceLabelPrefix + "/machineid"
+
+	// ReplicatedStorageClass VolumeAccess modes
+	VolumeAccessLocal           = "Local"
+	VolumeAccessEventuallyLocal = "EventuallyLocal"
+	VolumeAccessPreferablyLocal = "PreferablyLocal"
+	VolumeAccessAny             = "Any"
+
+	// ReplicatedStorageClass Topology modes
+	TopologyTransZonal = "TransZonal"
+	TopologyZonal      = "Zonal"
+	TopologyIgnored    = "Ignored"
+
+	// ReplicatedStoragePool Types
+	RSPTypeLVM     = "LVM"     // Thick volumes
+	RSPTypeLVMThin = "LVMThin" // Thin volumes
+
+	// Labels for replicated volumes
+	LabelReplicatedNode = "storage.deckhouse.io/sds-replicated-volume-node"
 )

api/v1alpha1/register.go

@@ -52,6 +52,10 @@ var knownTypes = []runtime.Object{
 	&LVMVolumeGroupSetList{},
 	&LVMLogicalVolumeSnapshot{},
 	&LVMLogicalVolumeSnapshotList{},
+	&ReplicatedStorageClass{},
+	&ReplicatedStorageClassList{},
+	&ReplicatedStoragePool{},
+	&ReplicatedStoragePoolList{},
 }
 
 // Adds the list of known types to Scheme.

api/v1alpha1/replicated_storage_class.go

@@ -0,0 +1,158 @@
+/*
+Copyright 2025 Flant JSC
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+)
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+type ReplicatedStorageClassList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+
+	Items []ReplicatedStorageClass `json:"items"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+type ReplicatedStorageClass struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec   ReplicatedStorageClassSpec   `json:"spec"`
+	Status ReplicatedStorageClassStatus `json:"status,omitempty"`
+}
+
+// +k8s:deepcopy-gen=true
+type ReplicatedStorageClassSpec struct {
+	// StoragePool is the name of the ReplicatedStoragePool resource
+	StoragePool string `json:"storagePool"`
+	// ReclaimPolicy defines what happens to the volume when the PVC is deleted (Delete or Retain)
+	ReclaimPolicy string `json:"reclaimPolicy"`
+	// Replication mode: None, Availability, ConsistencyAndAvailability
+	Replication string `json:"replication,omitempty"`
+	// VolumeAccess mode: Local, EventuallyLocal, PreferablyLocal, Any
+	VolumeAccess string `json:"volumeAccess,omitempty"`
+	// Topology mode: TransZonal, Zonal, Ignored
+	Topology string `json:"topology"`
+	// Zones is the list of zones where volumes should be replicated
+	Zones []string `json:"zones,omitempty"`
+}
+
+// +k8s:deepcopy-gen=true
+type ReplicatedStorageClassStatus struct {
+	// Phase is the current state: Failed, Created
+	Phase string `json:"phase,omitempty"`
+	// Reason provides additional information about the current state
+	Reason string `json:"reason,omitempty"`
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStorageClass) DeepCopyInto(out *ReplicatedStorageClass) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	in.Spec.DeepCopyInto(&out.Spec)
+	out.Status = in.Status
+}
+
+// DeepCopy creates a deep copy of ReplicatedStorageClass
+func (in *ReplicatedStorageClass) DeepCopy() *ReplicatedStorageClass {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStorageClass)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject creates a deep copy as runtime.Object
+func (in *ReplicatedStorageClass) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStorageClassList) DeepCopyInto(out *ReplicatedStorageClassList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ListMeta.DeepCopyInto(&out.ListMeta)
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]ReplicatedStorageClass, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+}
+
+// DeepCopy creates a deep copy of ReplicatedStorageClassList
+func (in *ReplicatedStorageClassList) DeepCopy() *ReplicatedStorageClassList {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStorageClassList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject creates a deep copy as runtime.Object
+func (in *ReplicatedStorageClassList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStorageClassSpec) DeepCopyInto(out *ReplicatedStorageClassSpec) {
+	*out = *in
+	if in.Zones != nil {
+		in, out := &in.Zones, &out.Zones
+		*out = make([]string, len(*in))
+		copy(*out, *in)
+	}
+}
+
+// DeepCopy creates a deep copy of ReplicatedStorageClassSpec
+func (in *ReplicatedStorageClassSpec) DeepCopy() *ReplicatedStorageClassSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStorageClassSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStorageClassStatus) DeepCopyInto(out *ReplicatedStorageClassStatus) {
+	*out = *in
+}
+
+// DeepCopy creates a deep copy of ReplicatedStorageClassStatus
+func (in *ReplicatedStorageClassStatus) DeepCopy() *ReplicatedStorageClassStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStorageClassStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+

api/v1alpha1/replicated_storage_pool.go

@@ -0,0 +1,173 @@
+/*
+Copyright 2025 Flant JSC
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+)
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+type ReplicatedStoragePoolList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata"`
+
+	Items []ReplicatedStoragePool `json:"items"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+type ReplicatedStoragePool struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec   ReplicatedStoragePoolSpec   `json:"spec"`
+	Status ReplicatedStoragePoolStatus `json:"status,omitempty"`
+}
+
+// +k8s:deepcopy-gen=true
+type ReplicatedStoragePoolSpec struct {
+	// Type defines the volumes type: LVM (for Thick) or LVMThin (for Thin)
+	Type string `json:"type"`
+	// LvmVolumeGroups is the list of LVMVolumeGroup resources used for storage
+	LvmVolumeGroups []ReplicatedStoragePoolLVG `json:"lvmVolumeGroups"`
+}
+
+// +k8s:deepcopy-gen=true
+type ReplicatedStoragePoolLVG struct {
+	// Name is the LVMVolumeGroup resource name
+	Name string `json:"name"`
+	// ThinPoolName is the thin pool name (required for LVMThin type)
+	ThinPoolName string `json:"thinPoolName,omitempty"`
+}
+
+// +k8s:deepcopy-gen=true
+type ReplicatedStoragePoolStatus struct {
+	// Phase is the current state: Updating, Failed, Completed
+	Phase string `json:"phase,omitempty"`
+	// Reason provides additional information about the current state
+	Reason string `json:"reason,omitempty"`
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStoragePool) DeepCopyInto(out *ReplicatedStoragePool) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
+	in.Spec.DeepCopyInto(&out.Spec)
+	out.Status = in.Status
+}
+
+// DeepCopy creates a deep copy of ReplicatedStoragePool
+func (in *ReplicatedStoragePool) DeepCopy() *ReplicatedStoragePool {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStoragePool)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject creates a deep copy as runtime.Object
+func (in *ReplicatedStoragePool) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStoragePoolList) DeepCopyInto(out *ReplicatedStoragePoolList) {
+	*out = *in
+	out.TypeMeta = in.TypeMeta
+	in.ListMeta.DeepCopyInto(&out.ListMeta)
+	if in.Items != nil {
+		in, out := &in.Items, &out.Items
+		*out = make([]ReplicatedStoragePool, len(*in))
+		for i := range *in {
+			(*in)[i].DeepCopyInto(&(*out)[i])
+		}
+	}
+}
+
+// DeepCopy creates a deep copy of ReplicatedStoragePoolList
+func (in *ReplicatedStoragePoolList) DeepCopy() *ReplicatedStoragePoolList {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStoragePoolList)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyObject creates a deep copy as runtime.Object
+func (in *ReplicatedStoragePoolList) DeepCopyObject() runtime.Object {
+	if c := in.DeepCopy(); c != nil {
+		return c
+	}
+	return nil
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStoragePoolSpec) DeepCopyInto(out *ReplicatedStoragePoolSpec) {
+	*out = *in
+	if in.LvmVolumeGroups != nil {
+		in, out := &in.LvmVolumeGroups, &out.LvmVolumeGroups
+		*out = make([]ReplicatedStoragePoolLVG, len(*in))
+		copy(*out, *in)
+	}
+}
+
+// DeepCopy creates a deep copy of ReplicatedStoragePoolSpec
+func (in *ReplicatedStoragePoolSpec) DeepCopy() *ReplicatedStoragePoolSpec {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStoragePoolSpec)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStoragePoolLVG) DeepCopyInto(out *ReplicatedStoragePoolLVG) {
+	*out = *in
+}
+
+// DeepCopy creates a deep copy of ReplicatedStoragePoolLVG
+func (in *ReplicatedStoragePoolLVG) DeepCopy() *ReplicatedStoragePoolLVG {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStoragePoolLVG)
+	in.DeepCopyInto(out)
+	return out
+}
+
+// DeepCopyInto copies the receiver into out
+func (in *ReplicatedStoragePoolStatus) DeepCopyInto(out *ReplicatedStoragePoolStatus) {
+	*out = *in
+}
+
+// DeepCopy creates a deep copy of ReplicatedStoragePoolStatus
+func (in *ReplicatedStoragePoolStatus) DeepCopy() *ReplicatedStoragePoolStatus {
+	if in == nil {
+		return nil
+	}
+	out := new(ReplicatedStoragePoolStatus)
+	in.DeepCopyInto(out)
+	return out
+}
+

crds/lvmlogicalvolume.yaml

@@ -61,7 +61,7 @@ spec:
                     - rule: self == oldSelf
                       message: Value is immutable.
                   minLength: 1
-                  pattern: '^[a-z0-9]([a-z0-9-.]{0,251}[a-z0-9])?$'
+                  pattern: '^[a-z0-9]([a-z0-9-._]{0,251}[a-z0-9])?$'
                 type:
                   type: string
                   description: |

docs/README.md

@@ -30,4 +30,4 @@ The `sds-node-configurator` module manages block devices and LVM on Kubernetes c
 - [Custom Resources](./cr.html): Module CRD reference.
 - [Configuration](./configuration.html): Module parameter configuration.
 - [Configuration scenarios](./layouts.html): Typical disk subsystem configuration scenarios for various storage configurations.
-- [FAQ](./faq.html): Frequently asked questions and answers.
+- [FAQ](./faq.html): Frequently asked questions and answers.