feat: Resource CRD + /v1/view/resources

Phase 2 fourth slice. linstor-csi calls GetResourceView in its volume
reconciliation loop — without it volume operations stall.

- pkg/api/v1/resource.go: Resource, ResourceWithVolumes, Volume, state types.
- api/v1alpha1/resource_types.go: CRD with composite (rd, node) key encoded
  as metadata.name = '<rd>.<node>'; status carries inUse and per-volume
  runtime state.
- pkg/store: ResourceStore interface; InMemory + k8s impls (k8s indexed by
  blockstor.io/resource-definition + blockstor.io/node-name labels for
  ListByDefinition); 5-case shared suite green on both.
- pkg/rest/resources.go: /v1/view/resources handler.
- 3 contract tests (empty, multi-node, no-store→503).

CSI MVP api-surface.md: /v1/view/resources ✅.

Co-Authored-By: Claude <noreply@anthropic.com>
Signed-off-by: Andrei Kvapil <kvapss@gmail.com>

Author: kvaps

.golangci.yml

@@ -125,10 +125,15 @@ linters:
       - linters:
           - dupl
         path: pkg/store/k8s/
-      # Same applies to the in-memory store implementations.
+      # Same applies to the in-memory store implementations and the
+      # interface definitions in pkg/store/store.go (per-resource Store
+      # interfaces share the same shape on purpose).
       - linters:
           - dupl
         path: pkg/store/inmemory_
+      - linters:
+          - dupl
+        path: pkg/store/store\.go
       # REST handlers follow the same Get/Create/Update/Delete shape per
       # resource for the same reason.
       - linters:

PROJECT

@@ -41,4 +41,12 @@ resources:
   kind: ResourceDefinition
   path: github.com/cozystack/blockstor/api/v1alpha1
   version: v1alpha1
+- api:
+    crdVersion: v1
+  controller: true
+  domain: blockstor.io
+  group: blockstor.io
+  kind: Resource
+  path: github.com/cozystack/blockstor/api/v1alpha1
+  version: v1alpha1
 version: "3"

api/v1alpha1/resource_types.go

@@ -0,0 +1,108 @@
+/*
+Copyright 2026 Cozystack contributors.
+
+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"
+)
+
+// ResourceSpec is the desired state of one replica of a ResourceDefinition
+// placed on a node. The composite key is (resourceDefinitionName, nodeName);
+// metadata.name encodes that as `<rd>.<node>`.
+type ResourceSpec struct {
+	// resourceDefinitionName is the parent ResourceDefinition.
+	// +required
+	ResourceDefinitionName string `json:"resourceDefinitionName"`
+
+	// nodeName is the satellite hosting this replica.
+	// +required
+	NodeName string `json:"nodeName"`
+
+	// props is the LINSTOR per-resource property map.
+	// +optional
+	Props map[string]string `json:"props,omitempty"`
+
+	// flags carries the user-controlled placement flags.
+	// +optional
+	Flags []string `json:"flags,omitempty"`
+}
+
+// ResourceStatus is the observed state of a placed resource.
+type ResourceStatus struct {
+	// inUse is whether DRBD reports the resource as primary anywhere.
+	// +optional
+	InUse bool `json:"inUse,omitempty"`
+
+	// volumes is the per-volume runtime state reported by the satellite.
+	// +optional
+	Volumes []ResourceVolumeStatus `json:"volumes,omitempty"`
+
+	// conditions represent the current state of the Resource.
+	// +listType=map
+	// +listMapKey=type
+	// +optional
+	Conditions []metav1.Condition `json:"conditions,omitempty"`
+}
+
+// ResourceVolumeStatus is the runtime state of one volume of a Resource.
+type ResourceVolumeStatus struct {
+	VolumeNumber int32 `json:"volumeNumber"`
+	// +optional
+	StoragePool string `json:"storagePool,omitempty"`
+	// +optional
+	DevicePath string `json:"devicePath,omitempty"`
+	// +optional
+	AllocatedKib int64 `json:"allocatedKib,omitempty"`
+	// +optional
+	UsableKib int64 `json:"usableKib,omitempty"`
+	// +optional
+	DiskState string `json:"diskState,omitempty"`
+}
+
+// +kubebuilder:object:root=true
+// +kubebuilder:subresource:status
+// +kubebuilder:resource:scope=Cluster
+
+// Resource is the Schema for the resources API
+type Resource struct {
+	metav1.TypeMeta `json:",inline"`
+
+	// metadata is a standard object metadata
+	// +optional
+	metav1.ObjectMeta `json:"metadata,omitzero"`
+
+	// spec defines the desired state of Resource
+	// +required
+	Spec ResourceSpec `json:"spec"`
+
+	// status defines the observed state of Resource
+	// +optional
+	Status ResourceStatus `json:"status,omitzero"`
+}
+
+// +kubebuilder:object:root=true
+
+// ResourceList contains a list of Resource
+type ResourceList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitzero"`
+	Items           []Resource `json:"items"`
+}
+
+func init() {
+	SchemeBuilder.Register(&Resource{}, &ResourceList{})
+}

api/v1alpha1/zz_generated.deepcopy.go

@@ -214,6 +214,13 @@ func main() {
 		setupLog.Error(err, "Failed to create controller", "controller", "resourcedefinition")
 		os.Exit(1)
 	}
+	if err := (&controller.ResourceReconciler{
+		Client: mgr.GetClient(),
+		Scheme: mgr.GetScheme(),
+	}).SetupWithManager(mgr); err != nil {
+		setupLog.Error(err, "Failed to create controller", "controller", "resource")
+		os.Exit(1)
+	}
 	// +kubebuilder:scaffold:builder
 
 	if err := mgr.AddHealthzCheck("healthz", healthz.Ping); err != nil {