feat: node storage lvm, lvmthin, nfs

Author: awlsring

docs/data-sources/lvm_storage_classes.md

@@ -40,6 +40,6 @@ Read-Only:
 - `content_types` (List of String) The content types that can be stored on this storage class.
 - `id` (String) The identifier of the storage class.
 - `nodes` (List of String) Nodes that implement this storage class.
-- `volume_group` (String) The NFS server used in the storage class.
+- `volume_group` (String) The volume group used by the thinpool.
 
 

docs/data-sources/lvm_thinpool_storage_classes.md

@@ -40,7 +40,7 @@ Read-Only:
 - `content_types` (List of String) The content types that can be stored on this storage class.
 - `id` (String) The identifier of the storage class.
 - `nodes` (List of String) Nodes that implement this storage class.
-- `thinpool` (String) The local mount of the NFS share that should be implemented by each node.
-- `volume_group` (String) The NFS server used in the storage class.
+- `thinpool` (String) The thinpools name.
+- `volume_group` (String) The path the volume group used by the thinpool.
 
 

docs/data-sources/node_storage_lvm_thinpools.md

@@ -0,0 +1,48 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "proxmox_node_storage_lvm_thinpools Data Source - terraform-provider-proxmox"
+subcategory: ""
+description: |-
+  
+---
+
+# proxmox_node_storage_lvm_thinpools (Data Source)
+
+
+
+
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Optional
+
+- `filters` (Attributes List) (see [below for nested schema](#nestedatt--filters))
+
+### Read-Only
+
+- `node_storage_lvm_thinpools` (Attributes List) (see [below for nested schema](#nestedatt--node_storage_lvm_thinpools))
+
+<a id="nestedatt--filters"></a>
+### Nested Schema for `filters`
+
+Required:
+
+- `name` (String) The name of the attribute to filter on.
+- `values` (List of String) The value(s) to be used in the filter.
+
+
+<a id="nestedatt--node_storage_lvm_thinpools"></a>
+### Nested Schema for `node_storage_lvm_thinpools`
+
+Read-Only:
+
+- `content_types` (List of String) The content types that can be stored on this storage class.
+- `id` (String) The identifier of the node storage. Formatted as `{node}/{storage}`
+- `node` (String) The node which the class implementation is on.
+- `size` (Number) The size of the storage in bytes.
+- `storage` (String) The name of the storage class this implements.
+- `thinpool` (String) The thinpools name.
+- `volume_group` (String) The associated volume group.
+
+

docs/data-sources/node_storage_lvms.md

@@ -0,0 +1,47 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "proxmox_node_storage_lvms Data Source - terraform-provider-proxmox"
+subcategory: ""
+description: |-
+  
+---
+
+# proxmox_node_storage_lvms (Data Source)
+
+
+
+
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Optional
+
+- `filters` (Attributes List) (see [below for nested schema](#nestedatt--filters))
+
+### Read-Only
+
+- `node_storage_lvms` (Attributes List) (see [below for nested schema](#nestedatt--node_storage_lvms))
+
+<a id="nestedatt--filters"></a>
+### Nested Schema for `filters`
+
+Required:
+
+- `name` (String) The name of the attribute to filter on.
+- `values` (List of String) The value(s) to be used in the filter.
+
+
+<a id="nestedatt--node_storage_lvms"></a>
+### Nested Schema for `node_storage_lvms`
+
+Read-Only:
+
+- `content_types` (List of String) The content types that can be stored on this storage class.
+- `id` (String) The identifier of the node storage. Formatted as `{node}/{storage}`
+- `node` (String) The node which the class implementation is on.
+- `size` (Number) The size of the storage in bytes.
+- `storage` (String) The name of the storage class this implements.
+- `volume_group` (String) The associated volume group.
+
+

docs/data-sources/node_storage_nfs.md

@@ -0,0 +1,49 @@
+---
+# generated by https://github.com/hashicorp/terraform-plugin-docs
+page_title: "proxmox_node_storage_nfs Data Source - terraform-provider-proxmox"
+subcategory: ""
+description: |-
+  
+---
+
+# proxmox_node_storage_nfs (Data Source)
+
+
+
+
+
+<!-- schema generated by tfplugindocs -->
+## Schema
+
+### Optional
+
+- `filters` (Attributes List) (see [below for nested schema](#nestedatt--filters))
+
+### Read-Only
+
+- `node_storage_nfs` (Attributes List) (see [below for nested schema](#nestedatt--node_storage_nfs))
+
+<a id="nestedatt--filters"></a>
+### Nested Schema for `filters`
+
+Required:
+
+- `name` (String) The name of the attribute to filter on.
+- `values` (List of String) The value(s) to be used in the filter.
+
+
+<a id="nestedatt--node_storage_nfs"></a>
+### Nested Schema for `node_storage_nfs`
+
+Read-Only:
+
+- `content_types` (List of String) The content types that can be stored on this storage class.
+- `export` (String) The path the NFS has exported as the share.
+- `id` (String) The identifier of the node storage. Formatted as `{node}/{storage}`
+- `mount` (String) The path the NFS share is mounted at.
+- `node` (String) The node which the class implementation is on.
+- `server` (String) The NFS server.
+- `size` (Number) The size of the storage in bytes.
+- `storage` (String) The name of the storage class this implements.
+
+

internal/service/node_storage.go

@@ -0,0 +1,34 @@
+package service
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/awlsring/proxmox-go/proxmox"
+)
+
+func (c *Proxmox) GetNodeStorage(ctx context.Context, node string, storage string) (*proxmox.NodeStorageSummary, error) {
+	request := c.client.ListNodeStorage(ctx, node)
+	request = request.Storage(storage)
+	resp, _, err := c.client.ListNodeStorageExecute(request)
+	if err != nil {
+		return nil, err
+	}
+
+	if len(resp.Data) != 1 {
+		return nil, fmt.Errorf("expected 1 storage, got %d", len(resp.Data))
+	}
+
+	return &resp.Data[0], nil
+}
+
+func (c *Proxmox) ListNodeStorage(ctx context.Context, node string) ([]proxmox.NodeStorageSummary, error) {
+	request := c.client.ListNodeStorage(ctx, node)
+	request.Enabled(1)
+	resp, _, err := c.client.ListNodeStorageExecute(request)
+	if err != nil {
+		return nil, err
+	}
+
+	return resp.Data, nil
+}

internal/service/node_storage_lvm.go

@@ -0,0 +1,52 @@
+package service
+
+import (
+	"context"
+
+	"github.com/awlsring/proxmox-go/proxmox"
+)
+
+type LVMNodeStorage struct {
+	Id           string
+	Node         string
+	Storage      string
+	ContentTypes []string
+	Size         int64
+	VolumeGroup  string
+}
+
+func (c *Proxmox) DescribeLVMNodeStorage(ctx context.Context, node string) ([]*LVMNodeStorage, error) {
+	nodeStorage, err := c.ListNodeStorage(ctx, node)
+	if err != nil {
+		return nil, err
+	}
+
+	storageList := []*LVMNodeStorage{}
+	for _, s := range nodeStorage {
+		if s.Type != proxmox.STORAGETYPE_LVM || s.Enabled == nil {
+			continue
+		}
+		if *s.Enabled != 1 {
+			continue
+		}
+
+		s := &LVMNodeStorage{
+			Id:           s.Storage,
+			Node:         node,
+			Storage:      s.Storage,
+			Size:         PtrFloatToInt64(s.Total),
+			ContentTypes: StringCommaListToSlice(s.Content),
+		}
+		storageList = append(storageList, s)
+	}
+
+	for _, s := range storageList {
+		storage, err := c.GetLVMStorageClass(ctx, s.Storage)
+		if err != nil {
+			return nil, err
+		}
+		s.VolumeGroup = storage.VolumeGroup
+	}
+
+	return storageList, nil
+}

internal/service/node_storage_lvmthin.go

@@ -0,0 +1,54 @@
+package service
+
+import (
+	"context"
+
+	"github.com/awlsring/proxmox-go/proxmox"
+)
+
+type LVMThinNodeStorage struct {
+	Id           string
+	Node         string
+	Storage      string
+	ContentTypes []string
+	Size         int64
+	VolumeGroup  string
+	Thinpool     string
+}
+
+func (c *Proxmox) DescribeLVMThinNodeStorage(ctx context.Context, node string) ([]*LVMThinNodeStorage, error) {
+	nodeStorage, err := c.ListNodeStorage(ctx, node)
+	if err != nil {
+		return nil, err
+	}
+
+	storageList := []*LVMThinNodeStorage{}
+	for _, s := range nodeStorage {
+		if s.Type != proxmox.STORAGETYPE_LVMTHIN || s.Enabled == nil {
+			continue
+		}
+		if *s.Enabled != 1 {
+			continue
+		}
+
+		s := &LVMThinNodeStorage{
+			Id:           s.Storage,
+			Node:         node,
+			Storage:      s.Storage,
+			Size:         PtrFloatToInt64(s.Total),
+			ContentTypes: StringCommaListToSlice(s.Content),
+		}
+		storageList = append(storageList, s)
+	}
+
+	for _, s := range storageList {
+		storage, err := c.GetLVMThinStorageClass(ctx, s.Storage)
+		if err != nil {
+			return nil, err
+		}
+		s.VolumeGroup = storage.VolumeGroup
+		s.Thinpool = storage.Thinpool
+	}
+
+	return storageList, nil
+}

internal/service/node_storage_nfs.go

@@ -0,0 +1,56 @@
+package service
+
+import (
+	"context"
+
+	"github.com/awlsring/proxmox-go/proxmox"
+)
+
+type NFSNodeStorage struct {
+	Id           string
+	Node         string
+	Storage      string
+	ContentTypes []string
+	Size         int64
+	Server       string
+	Mount        string
+	Export       string
+}
+
+func (c *Proxmox) DescribeNFSNodeStorage(ctx context.Context, node string) ([]*NFSNodeStorage, error) {
+	nodeStorage, err := c.ListNodeStorage(ctx, node)
+	if err != nil {
+		return nil, err
+	}
+
+	storageList := []*NFSNodeStorage{}
+	for _, s := range nodeStorage {
+		if s.Type != proxmox.STORAGETYPE_NFS || s.Enabled == nil {
+			continue
+		}
+		if *s.Enabled != 1 {
+			continue
+		}
+
+		s := &NFSNodeStorage{
+			Id:           s.Storage,
+			Node:         node,
+			Storage:      s.Storage,
+			Size:         PtrFloatToInt64(s.Total),
+			ContentTypes: StringCommaListToSlice(s.Content),
+		}
+		storageList = append(storageList, s)
+	}
+
+	for _, s := range storageList {
+		storage, err := c.GetNFSStorageClass(ctx, s.Storage)
+		if err != nil {
+			return nil, err
+		}
+		s.Server = storage.Server
+		s.Export = storage.Export
+		s.Mount = storage.Mount
+	}
+
+	return storageList, nil
+}