4.10.6

1.10.5
2026-06-15 13:23:15 +03:00 · 2026-04-23 12:29:28 +03:00
21 changed files with 899 additions and 107 deletions
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,8 +1,38 @@
-## Version 4.10.4
+## Version 4.10.6
+
+### Добавлено
+
+#### kvmvm
+| Идентификатор<br>задачи | Описание |
+| --- | --- |
+| BATF-1276 | Добавлено опциональное поле `create_blank` в resource `decort_kvmvm` в cloudapi/kvmvm и в resource `decort_cb_kvmvm` в cloudbroker/kvmvm |
+| BATF-1276 | Опциональное поле `alt_boot_id` в resource `decort_kvmvm` в cloudapi/kvmvm |
+
+### Изменено
+#### kvmvm
+| Идентификатор<br>задачи | Описание |
+| --- | --- |
+| BATF-1276 | Тип поля `disk_type` с опционального на вычисляемый в resource `decort_kvmvm` в cloudapi/kvmvm и в resource `decort_cb_kvmvm` в cloudbroker/kvmvm |

 ### Исправлено

-#### kvmvmm
+#### flipgroup
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BATF-1220 | Ошибки применения новой конфигурации после импортирования в resource `decort_kvmvm` в cloudapi/kvmvm и в `decort_cb_kvmvm` в cloudbroker/kvmvm |
+| BATF-1283 | Установка поля `desc` с платформы в ресурсе `decort_cb_flipgroup` в cloudbroker/flipgroup |
+
+#### kvmvm
+| Идентификатор<br>задачи | Описание |
+| --- | --- |
+| BATF-1276 | Ошибка при старте ВМ с указанием поля `alt_boot_id` в resource `decort_cb_kvmvm` в cloudbroker/kvmvm |
+
+#### trunk
+| Идентификатор<br>задачи | Описание |
+| --- | --- |
+| BATF-1285 | Установка полей `account_ids`, `ovs_bridge`, `native_vlan_id`, `trunk_tags` с платформы в ресурсе `decort_cb_trunk ` в cloudbroker/trunk |
+
+#### vfpool
+| Идентификатор<br>задачи | Описание |
+| --- | --- | 
+| BATF-1289 | Разрешено создавать пул виртуальных функций с блоком `config` при значении поля `enable` равным `false` в resource `decort_cb_vfpool` в cloudbroker/vfpool |
+| BATF-1289 | Разрешено обновлять поля `name`, `description`, `account_access` и `rg_access` без блока `config` в resource `decort_cb_vfpool` в cloudbroker/vfpool |
--- a/2
+++ b/2
@@ -7,7 +7,7 @@ ZIPDIR = ./zip
 BINARY=${NAME}
 WORKPATH= ./examples/terraform.d/plugins/${HOSTNAME}/${NAMESPACE}/${NAMESPACE}/${VERSION}/${OS_ARCH} 
 MAINPATH = ./cmd/decort/
-VERSION=4.10.4
+VERSION=4.10.6
 OS_ARCH=$(shell go env GOHOSTOS)_$(shell go env GOHOSTARCH)

 FILES = ${BINARY}_${VERSION}_darwin_amd64\
--- a/docs/resources/cb_kvmvm.md
+++ b/docs/resources/cb_kvmvm.md
@@ -36,6 +36,7 @@ description: |-
 - `chipset` (String) Type of the emulated system.
 - `cloud_init` (String) Optional cloud_init parameters. Applied when creating new compute instance only, ignored in all other cases.
 - `cpu_pin` (Boolean) Run VM on dedicated CPUs. To use this feature, the system must be pre-configured by allocating CPUs on the physical node.
+- `create_blank` (Boolean) If True, the compute is created via kvmx86/createBlank endpoint (without OS image). The image_id field is not required in this case.
 - `custom_fields` (String)
 - `description` (String) Optional text description of this compute instance.
 - `detach_disks` (Boolean)
@@ -188,8 +189,8 @@ Required:
 Optional:

 - `desc` (String) Optional description
- `disk_type` (String) The type of disk in terms of its role in compute: 'B=Boot, D=Data'
 - `image_id` (Number) Specify image id for create disk from template
+- `iotune` (Block List, Max: 1) (see [below for nested schema](#nestedblock--disks--iotune))
 - `node_ids` (Set of Number)
 - `permanently` (Boolean) Disk deletion status
 - `pool` (String) Pool name; by default will be chosen automatically
@@ -203,6 +204,7 @@ Read-Only:
 - `delete_time` (Number)
 - `devicename` (String)
 - `disk_id` (Number) Disk ID
+- `disk_type` (String) The type of disk in terms of its role in compute: 'B=Boot, D=Data'
 - `present_to` (Map of Number)
 - `shareable` (Boolean)
 - `size_max` (Number)
@@ -210,6 +212,26 @@ Read-Only:
 - `to_clean` (Boolean)
 - `update_time` (Number)

+<a id="nestedblock--disks--iotune"></a>
+### Nested Schema for `disks.iotune`
+
+Optional:
+
+- `read_bytes_sec` (Number)
+- `read_bytes_sec_max` (Number)
+- `read_iops_sec` (Number)
+- `read_iops_sec_max` (Number)
+- `size_iops_sec` (Number)
+- `total_bytes_sec` (Number)
+- `total_bytes_sec_max` (Number)
+- `total_iops_sec` (Number)
+- `total_iops_sec_max` (Number)
+- `write_bytes_sec` (Number)
+- `write_bytes_sec_max` (Number)
+- `write_iops_sec` (Number)
+- `write_iops_sec_max` (Number)
+
+

 <a id="nestedblock--libvirt_settings"></a>
 ### Nested Schema for `libvirt_settings`
--- a/docs/resources/kvmvm.md
+++ b/docs/resources/kvmvm.md
@@ -27,6 +27,7 @@ description: |-

 - `affinity_label` (String) Set affinity label for compute
 - `affinity_rules` (Block List) (see [below for nested schema](#nestedblock--affinity_rules))
+- `alt_boot_id` (Number) ID of CD-ROM live image to boot
 - `anti_affinity_rules` (Block List) (see [below for nested schema](#nestedblock--anti_affinity_rules))
 - `auto_start_w_node` (Boolean) Flag for start compute after node exits from MAINTENANCE state
 - `boot_disk_size` (Number) This compute instance boot disk size in GB. Make sure it is large enough to accomodate selected OS image.
@@ -35,6 +36,7 @@ description: |-
 - `chipset` (String) Type of the emulated system.
 - `cloud_init` (String) Optional cloud_init parameters. Applied when creating new compute instance only, ignored in all other cases.
 - `cpu_pin` (Boolean) Run VM on dedicated CPUs. To use this feature, the system must be pre-configured by allocating CPUs on the physical node.
+- `create_blank` (Boolean) If True, the compute is created via kvmx86/createBlank endpoint (without OS image). The image_id field is not required in this case.
 - `custom_fields` (String)
 - `description` (String) Optional text description of this compute instance.
 - `detach_disks` (Boolean)
@@ -182,8 +184,8 @@ Required:
 Optional:

 - `desc` (String) Optional description
- `disk_type` (String) The type of disk in terms of its role in compute: 'B=Boot, D=Data'
 - `image_id` (Number) Specify image id for create disk from template
+- `iotune` (Block List, Max: 1) (see [below for nested schema](#nestedblock--disks--iotune))
 - `permanently` (Boolean) Disk deletion status
 - `pool` (String) Pool name; by default will be chosen automatically
 - `sep_id` (Number) Storage endpoint provider ID; by default the same with boot disk
@@ -196,6 +198,7 @@ Read-Only:
 - `deleted_time` (Number)
 - `devicename` (String)
 - `disk_id` (Number) Disk ID
+- `disk_type` (String) The type of disk in terms of its role in compute: 'B=Boot, D=Data'
 - `present_to` (Map of Number)
 - `shareable` (Boolean)
 - `size_max` (Number)
@@ -203,6 +206,26 @@ Read-Only:
 - `to_clean` (Boolean)
 - `updated_time` (Number)

+<a id="nestedblock--disks--iotune"></a>
+### Nested Schema for `disks.iotune`
+
+Optional:
+
+- `read_bytes_sec` (Number)
+- `read_bytes_sec_max` (Number)
+- `read_iops_sec` (Number)
+- `read_iops_sec_max` (Number)
+- `size_iops_sec` (Number)
+- `total_bytes_sec` (Number)
+- `total_bytes_sec_max` (Number)
+- `total_iops_sec` (Number)
+- `total_iops_sec_max` (Number)
+- `write_bytes_sec` (Number)
+- `write_bytes_sec_max` (Number)
+- `write_iops_sec` (Number)
+- `write_iops_sec_max` (Number)
+
+

 <a id="nestedblock--network"></a>
 ### Nested Schema for `network`
@@ -311,6 +334,7 @@ Read-Only:
 - `disk_name` (String)
 - `disk_type` (String)
 - `image_id` (Number)
+- `iotune` (List of Object) (see [below for nested schema](#nestedobjatt--boot_disk--iotune))
 - `permanently` (Boolean)
 - `pool` (String)
 - `present_to` (Map of Number)
@@ -323,6 +347,26 @@ Read-Only:
 - `to_clean` (Boolean)
 - `updated_time` (Number)

+<a id="nestedobjatt--boot_disk--iotune"></a>
+### Nested Schema for `boot_disk.iotune`
+
+Read-Only:
+
+- `read_bytes_sec` (Number)
+- `read_bytes_sec_max` (Number)
+- `read_iops_sec` (Number)
+- `read_iops_sec_max` (Number)
+- `size_iops_sec` (Number)
+- `total_bytes_sec` (Number)
+- `total_bytes_sec_max` (Number)
+- `total_iops_sec` (Number)
+- `total_iops_sec_max` (Number)
+- `write_bytes_sec` (Number)
+- `write_bytes_sec_max` (Number)
+- `write_iops_sec` (Number)
+- `write_iops_sec_max` (Number)
+
+

 <a id="nestedatt--interfaces"></a>
 ### Nested Schema for `interfaces`
--- a/go.mod
+++ b/go.mod
@@ -9,7 +9,7 @@ require (
 	github.com/hashicorp/terraform-plugin-sdk/v2 v2.38.1
 	github.com/sirupsen/logrus v1.9.0
 	golang.org/x/net v0.44.0
-	repository.basistech.ru/BASIS/decort-golang-sdk v1.12.10
+	repository.basistech.ru/BASIS/decort-golang-sdk v1.12.12
 )

 require (
--- a/go.sum
+++ b/go.sum
@@ -318,5 +318,5 @@ gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-repository.basistech.ru/BASIS/decort-golang-sdk v1.12.10 h1:7RLk2Vjl6evKo4dLxlxiQCrRJSSlUwLztO3ZE/uBt+8=
-repository.basistech.ru/BASIS/decort-golang-sdk v1.12.10/go.mod h1:S/f7GxwWcE88eFpORV+I9xqEf8zDW5srQHpG2XQCLZM=
+repository.basistech.ru/BASIS/decort-golang-sdk v1.12.12 h1:dkLPikeIh9un93zDB2FMtF5E0hJnp8kEKBrC9YbSki8=
+repository.basistech.ru/BASIS/decort-golang-sdk v1.12.12/go.mod h1:S/f7GxwWcE88eFpORV+I9xqEf8zDW5srQHpG2XQCLZM=
--- a/internal/service/cloudapi/kvmvm/flattens.go
+++ b/internal/service/cloudapi/kvmvm/flattens.go
@@ -333,6 +333,7 @@ func flattenComputeDisksDemo(disksList compute.ListComputeDisks, disksBlocks, ex
 			"deleted_time":      disk.DeletedTime,
 			"updated_time":      disk.UpdatedTime,
 			"permanently":       pernamentlyValue,
+			"iotune":             flattenIotune(disk.IOTune),
 		}
 		res = append(res, temp)
 		indexDataDisks++
--- a/internal/service/cloudapi/kvmvm/resource_compute.go
+++ b/internal/service/cloudapi/kvmvm/resource_compute.go
@@ -71,13 +71,15 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 		return diag.Errorf("resourceComputeCreate: can't create Compute because rgID %d is not allowed or does not exist", d.Get("rg_id").(int))
 	}

-	hasImage, err := existImageId(ctx, d, m)
-	if err != nil {
-		return diag.FromErr(err)
-	}
+	if !d.Get("create_blank").(bool) {
+		hasImage, err := existImageId(ctx, d, m)
+		if err != nil {
+			return diag.FromErr(err)
+		}

-	if !hasImage {
-		return diag.Errorf("resourceComputeCreate: can't create Compute because imageID %d is not allowed or does not exist", d.Get("image_id").(int))
+		if !hasImage {
+			return diag.Errorf("resourceComputeCreate: can't create Compute because imageID %d is not allowed or does not exist", d.Get("image_id").(int))
+		}
 	}

 	if zoneID, ok := d.GetOk("zone_id"); ok {
@@ -288,7 +290,31 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 	}

 	log.Debugf("resourceComputeCreate: creating Compute of type KVM VM x86")
-	apiResp, err := c.CloudAPI().KVMX86().Create(ctx, createReqX86)
+	var apiResp uint64
+	if d.Get("create_blank").(bool) {
+		log.Debugf("resourceComputeCreate: using createBlank endpoint")
+		createBlankReq := kvmx86.CreateBlankRequest{
+			RGID:            createReqX86.RGID,
+			Name:            createReqX86.Name,
+			CPU:             createReqX86.CPU,
+			RAM:             createReqX86.RAM,
+			StoragePolicyID: createReqX86.StoragePolicyID,
+			WithoutBootDisk: createReqX86.WithoutBootDisk,
+			BootDisk:        createReqX86.BootDisk,
+			SEPID:           createReqX86.SepID,
+			Pool:            createReqX86.Pool,
+			DataDisks:       createReqX86.DataDisks,
+			Interfaces:      createReqX86.Interfaces,
+			Description:     createReqX86.Description,
+			Chipset:         createReqX86.Chipset,
+			PreferredCPU:    createReqX86.PreferredCPU,
+			ZoneID:          createReqX86.ZoneID,
+			OSVersion:       createReqX86.OSVersion,
+		}
+		apiResp, err = c.CloudAPI().KVMX86().CreateBlank(ctx, createBlankReq)
+	} else {
+		apiResp, err = c.CloudAPI().KVMX86().Create(ctx, createReqX86)
+	}
 	if err != nil {
 		return diag.FromErr(err)
 	}
@@ -384,6 +410,12 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 		}
 	}

+	if _, ok := d.GetOk("disks"); ok {
+		if err := utilityComputeCreateIOTune(ctx, d, m); err != nil {
+			warnings.Add(err)
+		}
+	}
+
 	if !cleanup {

 		if enabled, ok := d.GetOk("enabled"); ok {
@@ -446,6 +478,9 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 		if start, ok := d.GetOk("started"); ok {
 			if start.(bool) {
 				req := compute.StartRequest{ComputeID: computeId}
+				if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+					req.AltBootID = uint64(altBootID)
+				}
 				log.Debugf("resourceComputeCreate: starting Compute ID %d after completing its resource configuration", computeId)
 				if _, err := c.CloudAPI().Compute().Start(ctx, req); err != nil {
 					warnings.Add(err)
@@ -757,13 +792,15 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 		return diag.Errorf("resourceComputeUpdate: can't update Compute because rgID %d not allowed or does not exist", d.Get("rg_id").(int))
 	}

-	hasImage, err := existImageId(ctx, d, m)
-	if err != nil {
-		return diag.FromErr(err)
-	}
+	if !d.Get("create_blank").(bool) {
+		hasImage, err := existImageId(ctx, d, m)
+		if err != nil {
+			return diag.FromErr(err)
+		}

-	if !hasImage {
-		return diag.Errorf("resourceComputeUpdate: can't update Compute because imageID %d not allowed or does not exist", d.Get("image_id").(int))
+		if !hasImage {
+			return diag.Errorf("resourceComputeUpdate: can't update Compute because imageID %d not allowed or does not exist", d.Get("image_id").(int))
+		}
 	}

 	if d.HasChange("zone_id") {
@@ -851,6 +888,9 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 		if start, ok := d.GetOk("started"); ok {
 			if start.(bool) {
 				req := compute.StartRequest{ComputeID: computeRec.ID}
+				if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+					req.AltBootID = uint64(altBootID)
+				}

 				if _, err := c.CloudAPI().Compute().Start(ctx, req); err != nil {
 					return diag.FromErr(err)
@@ -1093,7 +1133,11 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf

 	// If used to be STARTED, we need to start it after update
 	if isStopRequired {
-		if _, err := c.CloudAPI().Compute().Start(ctx, compute.StartRequest{ComputeID: computeRec.ID}); err != nil {
+		req := compute.StartRequest{ComputeID: computeRec.ID}
+		if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+			req.AltBootID = uint64(altBootID)
+		}
+		if _, err := c.CloudAPI().Compute().Start(ctx, req); err != nil {
 			return diag.FromErr(err)
 		}
 	}
@@ -1118,6 +1162,7 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 		resizedDisks := make([]interface{}, 0)
 		renamedDisks := make([]interface{}, 0)
 		changeStoragePolicyDisks := make([]interface{}, 0)
+		iotuneUpdatedDisks := make([]interface{}, 0)

 		oldDisks, newDisks := d.GetChange("disks")
 		oldConv := oldDisks.([]interface{})
@@ -1158,6 +1203,9 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 			if isChangeStoragePolicy(oldConv, el) {
 				changeStoragePolicyDisks = append(changeStoragePolicyDisks, el)
 			}
+			if isChangeIOTuneDisk(oldConv, el) {
+				iotuneUpdatedDisks = append(iotuneUpdatedDisks, el)
+			}
 		}

 		if len(deletedDisks) > 0 {
@@ -1198,9 +1246,6 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 				if diskConv["sep_id"].(int) != 0 {
 					req.SepID = uint64(diskConv["sep_id"].(int))
 				}
-				if diskConv["disk_type"].(string) != "" {
-					req.DiskType = diskConv["disk_type"].(string)
-				}
 				if diskConv["pool"].(string) != "" {
 					req.Pool = diskConv["pool"].(string)
 				}
@@ -1210,10 +1255,33 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 				if diskConv["image_id"].(int) != 0 {
 					req.ImageID = uint64(diskConv["image_id"].(int))
 				}
-				_, err := c.CloudAPI().Compute().DiskAdd(ctx, req)
+				diskID, err := c.CloudAPI().Compute().DiskAdd(ctx, req)
 				if err != nil {
 					return diag.FromErr(err)
 				}
+				if iotuneRaw, ok := diskConv["iotune"].([]interface{}); ok && len(iotuneRaw) > 0 {
+					iotuneMap := iotuneRaw[0].(map[string]interface{})
+					limitReq := disks.LimitIORequest{
+						DiskID:           diskID,
+						ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+						ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+						ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+						ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+						SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+						TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+						TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+						TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+						TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+						WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+						WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+						WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+						WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+					}
+					_, err := c.CloudAPI().Disks().LimitIO(ctx, limitReq)
+					if err != nil {
+						return diag.FromErr(err)
+					}
+				}
 			}
 		}

@@ -1267,6 +1335,59 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 				}
 			}
 		}
+
+		if len(iotuneUpdatedDisks) > 0 {
+			computeRec, err := utilityComputeCheckPresence(ctx, d, m)
+			if err != nil {
+				return diag.FromErr(err)
+			}
+			allDisks := computeRec.Disks
+			bootDisk := findBootDisk(allDisks)
+			diskIDs := getComputeDiskIDs(d, allDisks)
+			for i, disk := range iotuneUpdatedDisks {
+				diskConv := disk.(map[string]interface{})
+				if diskConv["disk_type"].(string) == "B" {
+					continue
+				}
+				if bootDisk != nil && diskConv["disk_id"].(int) == int(bootDisk.ID) {
+					continue
+				}
+				var diskID uint64
+				if id := diskConv["disk_id"].(int); id != 0 {
+					diskID = uint64(id)
+				} else if i < len(diskIDs) {
+					diskID = diskIDs[i]
+				}
+				if diskID == 0 {
+					continue
+				}
+				iotuneRaw, ok := diskConv["iotune"].([]interface{})
+				if !ok || len(iotuneRaw) == 0 {
+					continue
+				}
+				iotuneMap := iotuneRaw[0].(map[string]interface{})
+				limitReq := disks.LimitIORequest{
+					DiskID:           diskID,
+					ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+					ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+					ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+					ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+					SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+					TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+					TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+					TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+					TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+					WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+					WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+					WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+					WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+				}
+				_, err := c.CloudAPI().Disks().LimitIO(ctx, limitReq)
+				if err != nil {
+					return diag.FromErr(err)
+				}
+			}
+		}
 	}

 	if d.HasChange("affinity_label") {
@@ -1770,6 +1891,9 @@ func resourceComputeUpdate(ctx context.Context, d *schema.ResourceData, m interf
 			req := compute.StartRequest{
 				ComputeID: computeRec.ID,
 			}
+			if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+				req.AltBootID = uint64(altBootID)
+			}
 			if !isStopRequired {
 				if _, err := c.CloudAPI().Compute().Start(ctx, req); err != nil {
 					return diag.FromErr(err)
@@ -1866,6 +1990,40 @@ func isContainsDisk(els []interface{}, el interface{}) bool {
 	return false
 }

+func isChangeIOTuneDisk(els []interface{}, el interface{}) bool {
+	for _, elOld := range els {
+		elOldConv := elOld.(map[string]interface{})
+		elConv := el.(map[string]interface{})
+		if elOldConv["disk_id"].(int) != elConv["disk_id"].(int) {
+			continue
+		}
+		oldIOTune := elOldConv["iotune"].([]interface{})
+		newIOTune := elConv["iotune"].([]interface{})
+		if len(oldIOTune) == 0 && len(newIOTune) == 0 {
+			return false
+		}
+		if len(oldIOTune) == 0 || len(newIOTune) == 0 {
+			return true
+		}
+		oldMap := oldIOTune[0].(map[string]interface{})
+		newMap := newIOTune[0].(map[string]interface{})
+		return oldMap["read_bytes_sec"].(int) != newMap["read_bytes_sec"].(int) ||
+			oldMap["read_bytes_sec_max"].(int) != newMap["read_bytes_sec_max"].(int) ||
+			oldMap["read_iops_sec"].(int) != newMap["read_iops_sec"].(int) ||
+			oldMap["read_iops_sec_max"].(int) != newMap["read_iops_sec_max"].(int) ||
+			oldMap["size_iops_sec"].(int) != newMap["size_iops_sec"].(int) ||
+			oldMap["total_bytes_sec"].(int) != newMap["total_bytes_sec"].(int) ||
+			oldMap["total_bytes_sec_max"].(int) != newMap["total_bytes_sec_max"].(int) ||
+			oldMap["total_iops_sec"].(int) != newMap["total_iops_sec"].(int) ||
+			oldMap["total_iops_sec_max"].(int) != newMap["total_iops_sec_max"].(int) ||
+			oldMap["write_bytes_sec"].(int) != newMap["write_bytes_sec"].(int) ||
+			oldMap["write_bytes_sec_max"].(int) != newMap["write_bytes_sec_max"].(int) ||
+			oldMap["write_iops_sec"].(int) != newMap["write_iops_sec"].(int) ||
+			oldMap["write_iops_sec_max"].(int) != newMap["write_iops_sec_max"].(int)
+	}
+	return false
+}
+
 func isContainsAR(els []interface{}, el interface{}) bool {
 	for _, elOld := range els {
 		elOldConv := elOld.(map[string]interface{})
@@ -1931,11 +2089,9 @@ func disksSubresourceSchemaMake() map[string]*schema.Schema {
 			Description: "Storage endpoint provider ID; by default the same with boot disk",
 		},
 		"disk_type": {
-			Type:         schema.TypeString,
-			Computed:     true,
-			Optional:     true,
-			ValidateFunc: validation.StringInSlice([]string{"B", "D"}, false),
-			Description:  "The type of disk in terms of its role in compute: 'B=Boot, D=Data'",
+			Type:        schema.TypeString,
+			Computed:    true,
+			Description: "The type of disk in terms of its role in compute: 'B=Boot, D=Data'",
 		},
 		"pool": {
 			Type:        schema.TypeString,
@@ -1960,6 +2116,81 @@ func disksSubresourceSchemaMake() map[string]*schema.Schema {
 			Optional:    true,
 			Description: "Disk deletion status",
 		},
+		"iotune": {
+			Type:     schema.TypeList,
+			Optional: true,
+			Computed: true,
+			MaxItems: 1,
+			Elem: &schema.Resource{
+				Schema: map[string]*schema.Schema{
+					"read_bytes_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"read_bytes_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"read_iops_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"read_iops_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"size_iops_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"total_bytes_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"total_bytes_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"total_iops_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"total_iops_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"write_bytes_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"write_bytes_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"write_iops_sec": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+					"write_iops_sec_max": {
+						Type:     schema.TypeInt,
+						Optional: true,
+						Computed: true,
+					},
+				},
+			},
+		},
 		"disk_id": {
 			Type:        schema.TypeInt,
 			Computed:    true,
@@ -2158,6 +2389,12 @@ func ResourceComputeSchemaMake() map[string]*schema.Schema {
 			Default:     false,
 			Description: "If True, the imageId, bootDisk, sepId, pool parameters are ignored and the compute is created without a boot disk in the stopped state.",
 		},
+		"create_blank": {
+			Type:        schema.TypeBool,
+			Optional:    true,
+			Default:     false,
+			Description: "If True, the compute is created via kvmx86/createBlank endpoint (without OS image). The image_id field is not required in this case.",
+		},
 		"boot_disk_size": {
 			Type:        schema.TypeInt,
 			Optional:    true,
@@ -2412,6 +2649,11 @@ func ResourceComputeSchemaMake() map[string]*schema.Schema {
 			Default:     false,
 			Description: "Flag for resize compute",
 		},
+		"alt_boot_id": {
+			Type:        schema.TypeInt,
+			Optional:    true,
+			Description: "ID of CD-ROM live image to boot",
+		},
 		"started": {
 			Type:        schema.TypeBool,
 			Optional:    true,
--- a/internal/service/cloudapi/kvmvm/utility_compute.go
+++ b/internal/service/cloudapi/kvmvm/utility_compute.go
@@ -43,6 +43,7 @@ import (
 	"github.com/hashicorp/go-cty/cty"
 	log "github.com/sirupsen/logrus"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/compute"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/disks"
 	"repository.basistech.ru/BASIS/terraform-provider-decort/internal/controller"

 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
@@ -292,7 +293,13 @@ func utilityComputeNetworksConfigure(ctx context.Context, d *schema.ResourceData

 	if needStart {
 		computeId, _ := strconv.ParseUint(d.Id(), 10, 64)
-		if numErr, err := utilityComputeStart(ctx, computeId, m); err != nil {
+		var altBootID uint64
+		if altBootIDRaw, ok := d.Get("alt_boot_id").(int); ok {
+			altBootID = uint64(altBootIDRaw)
+		} else {
+			altBootID = 0
+		}
+		if numErr, err := utilityComputeStart(ctx, computeId, altBootID, m); err != nil {
 			apiErrCount += numErr
 			lastSavedError = err
 		}
@@ -455,10 +462,14 @@ func utilityComputeStop(ctx context.Context, computeID uint64, m interface{}) er
 	return nil
 }

-func utilityComputeStart(ctx context.Context, computeID uint64, m interface{}) (int, error) {
+func utilityComputeStart(ctx context.Context, computeID uint64, altBootID uint64, m interface{}) (int, error) {
 	c := m.(*controller.ControllerCfg)
 	startReq := compute.StartRequest{ComputeID: computeID}

+	if altBootID > 0 {
+		startReq.AltBootID = altBootID
+	}
+
 	log.Debugf("utilityComputeNetworksConfigure: starting compute %d", computeID)
 	_, err := c.CloudAPI().Compute().Start(ctx, startReq)
 	if err != nil {
@@ -622,3 +633,94 @@ func enabledNetwork(rawNetworkConfig cty.Value, netID uint64, netType string) bo

 	return false
 }
+
+func getComputeDiskIDs(d *schema.ResourceData, disksList compute.ListComputeDisks) []uint64 {
+	diskList := d.Get("disks").([]interface{})
+	ids := make([]uint64, 0, len(diskList))
+	for _, item := range diskList {
+		diskConv := item.(map[string]interface{})
+		diskName := diskConv["disk_name"].(string)
+		for _, disk := range disksList {
+			if disk.Name == diskName {
+				ids = append(ids, disk.ID)
+				break
+			}
+		}
+	}
+	return ids
+}
+
+func utilityComputeCreateIOTune(ctx context.Context, d *schema.ResourceData, m interface{}) error {
+	diskList, ok := d.GetOk("disks")
+	if !ok {
+		return nil
+	}
+	disksSlice := diskList.([]interface{})
+
+	hasIotune := false
+	for _, item := range disksSlice {
+		diskConv := item.(map[string]interface{})
+		if iotuneRaw, ok := diskConv["iotune"].([]interface{}); ok && len(iotuneRaw) > 0 {
+			hasIotune = true
+			break
+		}
+	}
+	if !hasIotune {
+		return nil
+	}
+
+	computeRec, err := utilityComputeCheckPresence(ctx, d, m)
+	if err != nil {
+		return err
+	}
+	allDisks := computeRec.Disks
+	bootDisk := findBootDisk(allDisks)
+	diskIDs := getComputeDiskIDs(d, allDisks)
+
+	c := m.(*controller.ControllerCfg)
+
+	for i, item := range disksSlice {
+		diskConv := item.(map[string]interface{})
+		if diskConv["disk_type"].(string) == "B" {
+			continue
+		}
+		if bootDisk != nil && diskConv["disk_id"].(int) == int(bootDisk.ID) {
+			continue
+		}
+		iotuneRaw, ok := diskConv["iotune"].([]interface{})
+		if !ok || len(iotuneRaw) == 0 {
+			continue
+		}
+		var diskID uint64
+		if id := diskConv["disk_id"].(int); id != 0 {
+			diskID = uint64(id)
+		} else if i < len(diskIDs) {
+			diskID = diskIDs[i]
+		}
+		if diskID == 0 {
+			continue
+		}
+		iotuneMap := iotuneRaw[0].(map[string]interface{})
+		limitReq := disks.LimitIORequest{
+			DiskID:           diskID,
+			ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+			ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+			ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+			ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+			SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+			TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+			TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+			TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+			TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+			WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+			WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+			WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+			WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+		}
+		_, err := c.CloudAPI().Disks().LimitIO(ctx, limitReq)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
--- a/internal/service/cloudbroker/flipgroup/flattens.go
+++ b/internal/service/cloudbroker/flipgroup/flattens.go
@@ -70,6 +70,36 @@ func flattenFlipgroup(d *schema.ResourceData, flip *flipgroup.RecordFLIPGroup) {
 	d.Set("updated_time", flip.UpdatedTime)
 }

+func flattenFlipgroupResource(d *schema.ResourceData, flip *flipgroup.RecordFLIPGroup) {
+	d.Set("flipgroup_id", flip.ID)
+	d.Set("account_id", flip.AccountID)
+	d.Set("account_name", flip.AccountName)
+	d.Set("client_ids", flip.ClientIDs)
+	d.Set("client_names", flip.ClientNames)
+	d.Set("client_type", flip.ClientType)
+	d.Set("conn_id", flip.ConnID)
+	d.Set("conn_type", flip.ConnType)
+	d.Set("created_by", flip.CreatedBy)
+	d.Set("created_time", flip.CreatedTime)
+	d.Set("default_gw", flip.DefaultGW)
+	d.Set("deleted_by", flip.DeletedBy)
+	d.Set("deleted_time", flip.DeletedTime)
+	d.Set("desc", flip.Description)
+	d.Set("gid", flip.GID)
+	d.Set("guid", flip.GUID)
+	d.Set("ip", flip.IP)
+	d.Set("milestones", flip.Milestones)
+	d.Set("name", flip.Name)
+	d.Set("net_id", flip.NetID)
+	d.Set("net_type", flip.NetType)
+	d.Set("network", flip.Network)
+	d.Set("rg_id", flip.RGID)
+	d.Set("rg_name", flip.RGName)
+	d.Set("status", flip.Status)
+	d.Set("updated_by", flip.UpdatedBy)
+	d.Set("updated_time", flip.UpdatedTime)
+}
+
 func flattenFlipgroupsList(fg *flipgroup.ListFLIPGroups) []map[string]interface{} {
 	res := make([]map[string]interface{}, 0, len(fg.Data))
 	for _, flip := range fg.Data {
--- a/internal/service/cloudbroker/flipgroup/resource_flipgroup.go
+++ b/internal/service/cloudbroker/flipgroup/resource_flipgroup.go
@@ -110,7 +110,7 @@ func resourceFlipgroupRead(ctx context.Context, d *schema.ResourceData, m interf
 		return diag.Errorf("The flipgroup status is destroyed and cannot be read.")
 	}

-	flattenFlipgroup(d, fg)
+	flattenFlipgroupResource(d, fg)

 	log.Debugf("resourceFlipgroupRead: after flattenFlipgroup: flipgroup_id %s, name %s",
 		d.Id(), d.Get("name").(string))
--- a/internal/service/cloudbroker/kvmvm/flattens.go
+++ b/internal/service/cloudbroker/kvmvm/flattens.go
@@ -289,6 +289,7 @@ func flattenComputeDisks(disksList compute.ListDisks, disksBlocks, extraDisks []
 			"delete_by":         disk.DeletedBy,
 			"delete_time":       disk.DeletedTime,
 			"update_time":       disk.UpdatedTime,
+			"iotune":            flattenIOTune(disk.IOTune),
 		}
 		res = append(res, temp)
 		indexDataDisks++
--- a/internal/service/cloudbroker/kvmvm/resource_check_input_values.go
+++ b/internal/service/cloudbroker/kvmvm/resource_check_input_values.go
@@ -17,8 +17,10 @@ func checkParamsExistence(ctx context.Context, d *schema.ResourceData, c *contro
 		errs = append(errs, err)
 	}

-	if err := ic.ExistImage(ctx, uint64(d.Get("image_id").(int)), c); err != nil {
-		errs = append(errs, err)
+	if !d.Get("create_blank").(bool) {
+		if err := ic.ExistImage(ctx, uint64(d.Get("image_id").(int)), c); err != nil {
+			errs = append(errs, err)
+		}
 	}

 	if netErrs := existNetworks(ctx, d, c); errs != nil {
--- a/internal/service/cloudbroker/kvmvm/resource_compute.go
+++ b/internal/service/cloudbroker/kvmvm/resource_compute.go
@@ -231,7 +231,32 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 	}

 	log.Debugf("resourceComputeCreate: creating Compute of type KVM VM x86")
-	apiResp, err := c.CloudBroker().KVMX86().Create(ctx, createReqX86)
+	var apiResp uint64
+	var err error
+	if d.Get("create_blank").(bool) {
+		log.Debugf("resourceComputeCreate: using createBlank endpoint")
+		createBlankReq := kvmx86.CreateBlankRequest{
+			RGID:            createReqX86.RGID,
+			Name:            createReqX86.Name,
+			CPU:             createReqX86.CPU,
+			RAM:             createReqX86.RAM,
+			StoragePolicyID: createReqX86.StoragePolicyID,
+			WithoutBootDisk: createReqX86.WithoutBootDisk,
+			BootDisk:        createReqX86.BootDisk,
+			SEPID:           createReqX86.SEPID,
+			Pool:            createReqX86.Pool,
+			DataDisks:       createReqX86.DataDisks,
+			Interfaces:      createReqX86.Interfaces,
+			Description:     createReqX86.Description,
+			Chipset:         createReqX86.Chipset,
+			PreferredCPU:    createReqX86.PreferredCPU,
+			ZoneID:          createReqX86.ZoneID,
+			OSVersion:       createReqX86.OSVersion,
+		}
+		apiResp, err = c.CloudBroker().KVMX86().CreateBlank(ctx, createBlankReq)
+	} else {
+		apiResp, err = c.CloudBroker().KVMX86().Create(ctx, createReqX86)
+	}
 	if err != nil {
 		return diag.FromErr(err)
 	}
@@ -424,6 +449,9 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf

 		if start, ok := d.GetOk("started"); ok && start.(bool) {
 			req := compute.StartRequest{ComputeID: computeId}
+			if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+				req.AltBootID = uint64(altBootID)
+			}
 			log.Debugf("resourceComputeCreate: starting Compute ID %d after completing its resource configuration", computeId)
 			if _, err := c.CloudBroker().Compute().Start(ctx, req); err != nil {
 				warnings.Add(err)
@@ -656,6 +684,9 @@ func resourceComputeCreate(ctx context.Context, d *schema.ResourceData, m interf
 			if err != nil {
 				warnings.Add(err)
 			}
+			if err := utilityComputeCreateIOTune(ctx, d, m); err != nil {
+				warnings.Add(err)
+			}
 		}

 	}
--- a/internal/service/cloudbroker/kvmvm/schema.go
+++ b/internal/service/cloudbroker/kvmvm/schema.go
@@ -3406,6 +3406,12 @@ func resourceComputeSchemaMake() map[string]*schema.Schema {
 			Default:     false,
 			Description: "If True, the imageId, bootDisk, sepId, pool parameters are ignored and the compute is created without a boot disk in the stopped state.",
 		},
+		"create_blank": {
+			Type:        schema.TypeBool,
+			Optional:    true,
+			Default:     false,
+			Description: "If True, the compute is created via kvmx86/createBlank endpoint (without OS image). The image_id field is not required in this case.",
+		},
 		"boot_disk_size": {
 			Type:        schema.TypeInt,
 			Optional:    true,
@@ -3728,11 +3734,9 @@ func resourceComputeSchemaMake() map[string]*schema.Schema {
 						Description: "Storage endpoint provider ID; by default the same with boot disk",
 					},
 					"disk_type": {
-						Type:         schema.TypeString,
-						Computed:     true,
-						Optional:     true,
-						ValidateFunc: validation.StringInSlice([]string{"B", "D"}, false),
-						Description:  "The type of disk in terms of its role in compute: 'B=Boot, D=Data'",
+						Type:        schema.TypeString,
+						Computed:    true,
+						Description: "The type of disk in terms of its role in compute: 'B=Boot, D=Data'",
 					},
 					"pool": {
 						Type:        schema.TypeString,
@@ -3764,6 +3768,81 @@ func resourceComputeSchemaMake() map[string]*schema.Schema {
 						Optional:    true,
 						Description: "Disk deletion status",
 					},
+					"iotune": {
+						Type:     schema.TypeList,
+						Optional: true,
+						Computed: true,
+						MaxItems: 1,
+						Elem: &schema.Resource{
+							Schema: map[string]*schema.Schema{
+								"read_bytes_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"read_bytes_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"read_iops_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"read_iops_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"size_iops_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"total_bytes_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"total_bytes_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"total_iops_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"total_iops_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"write_bytes_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"write_bytes_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"write_iops_sec": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+								"write_iops_sec_max": {
+									Type:     schema.TypeInt,
+									Optional: true,
+									Computed: true,
+								},
+							},
+						},
+					},
 					"disk_id": {
 						Type:        schema.TypeInt,
 						Computed:    true,
--- a/internal/service/cloudbroker/kvmvm/utility_compute.go
+++ b/internal/service/cloudbroker/kvmvm/utility_compute.go
@@ -184,7 +184,11 @@ func utilityComputeResize(ctx context.Context, d *schema.ResourceData, m interfa
 	}

 	if isStopRequired {
-		if _, err := c.CloudBroker().Compute().Start(ctx, compute.StartRequest{ComputeID: computeId}); err != nil {
+		req := compute.StartRequest{ComputeID: computeId}
+		if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+			req.AltBootID = uint64(altBootID)
+		}
+		if _, err := c.CloudBroker().Compute().Start(ctx, req); err != nil {
 			return err
 		}
 	}
@@ -235,6 +239,7 @@ func utilityComputeUpdateDisks(ctx context.Context, d *schema.ResourceData, m in
 	resizedDisks := make([]interface{}, 0)
 	renamedDisks := make([]interface{}, 0)
 	changeStoragePolicyDisks := make([]interface{}, 0)
+	iotuneUpdatedDisks := make([]interface{}, 0)
 	presentNewDisks := make([]interface{}, 0)
 	presentOldDisks := make([]interface{}, 0)

@@ -283,6 +288,9 @@ func utilityComputeUpdateDisks(ctx context.Context, d *schema.ResourceData, m in
 		if isChangeStoragePolicy(oldConv, el) {
 			changeStoragePolicyDisks = append(changeStoragePolicyDisks, el)
 		}
+		if isChangeIOTuneDisk(oldConv, el) {
+			iotuneUpdatedDisks = append(iotuneUpdatedDisks, el)
+		}
 	}

 	if len(deletedDisks) > 0 {
@@ -320,9 +328,6 @@ func utilityComputeUpdateDisks(ctx context.Context, d *schema.ResourceData, m in
 			if diskConv["sep_id"].(int) != 0 {
 				req.SepID = uint64(diskConv["sep_id"].(int))
 			}
-			if diskConv["disk_type"].(string) != "" {
-				req.DiskType = diskConv["disk_type"].(string)
-			}
 			if diskConv["pool"].(string) != "" {
 				req.Pool = diskConv["pool"].(string)
 			}
@@ -353,9 +358,33 @@ func utilityComputeUpdateDisks(ctx context.Context, d *schema.ResourceData, m in
 					}
 				}
 			}
-			if err != nil {
-				return err
+			if iotuneRaw, ok := diskConv["iotune"].([]interface{}); ok && len(iotuneRaw) > 0 {
+				if diskConv["disk_type"].(string) == "B" {
+					continue
+				}
+				iotuneMap := iotuneRaw[0].(map[string]interface{})
+				limitReq := disks.LimitIORequest{
+					DiskID:           diskID,
+					ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+					ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+					ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+					ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+					SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+					TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+					TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+					TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+					TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+					WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+					WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+					WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+					WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+				}
+				_, err := c.CloudBroker().Disks().LimitIO(ctx, limitReq)
+				if err != nil {
+					return err
+				}
 			}
+
 		}
 	}

@@ -409,6 +438,44 @@ func utilityComputeUpdateDisks(ctx context.Context, d *schema.ResourceData, m in
 		}
 	}

+	if len(iotuneUpdatedDisks) > 0 {
+		for _, disk := range iotuneUpdatedDisks {
+			diskConv := disk.(map[string]interface{})
+			if diskConv["disk_type"].(string) == "B" {
+				continue
+			}
+			diskID := uint64(diskConv["disk_id"].(int))
+			if diskID == 0 {
+				continue
+			}
+			iotuneRaw, ok := diskConv["iotune"].([]interface{})
+			if !ok || len(iotuneRaw) == 0 {
+				continue
+			}
+			iotuneMap := iotuneRaw[0].(map[string]interface{})
+			req := disks.LimitIORequest{
+				DiskID:           diskID,
+				ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+				ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+				ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+				ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+				SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+				TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+				TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+				TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+				TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+				WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+				WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+				WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+				WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+			}
+			_, err := c.CloudBroker().Disks().LimitIO(ctx, req)
+			if err != nil {
+				return err
+			}
+		}
+	}
+
 	for i := range presentNewDisks {
 		newDisk := presentNewDisks[i].(map[string]interface{})
 		oldDisk := presentOldDisks[i].(map[string]interface{})
@@ -769,7 +836,13 @@ func utilityComputeNetworksConfigure(ctx context.Context, d *schema.ResourceData

 	if needStart {
 		computeId, _ := strconv.ParseUint(d.Id(), 10, 64)
-		if numErr, err := utilityComputeStart(ctx, computeId, m); err != nil {
+		var altBootID uint64
+		if altBootIDRaw, ok := d.Get("alt_boot_id").(int); ok {
+			altBootID = uint64(altBootIDRaw)
+		} else {
+			altBootID = 0
+		}
+		if numErr, err := utilityComputeStart(ctx, computeId, altBootID, m); err != nil {
 			apiErrCount += numErr
 			lastSavedError = err
 		}
@@ -1096,7 +1169,11 @@ func utilityComputeUpdate(ctx context.Context, d *schema.ResourceData, m interfa

 	// If used to be STARTED, we need to start it after update
 	if isStopRequired {
-		if _, err := c.CloudBroker().Compute().Start(ctx, compute.StartRequest{ComputeID: computeId}); err != nil {
+		req := compute.StartRequest{ComputeID: computeId}
+		if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+			req.AltBootID = uint64(altBootID)
+		}
+		if _, err := c.CloudBroker().Compute().Start(ctx, req); err != nil {
 			return err
 		}
 	}
@@ -1567,6 +1644,9 @@ func utilityComputeRollback(ctx context.Context, d *schema.ResourceData, m inter
 		}

 		startReq := compute.StartRequest{ComputeID: computeId}
+		if altBootID, ok := d.Get("alt_boot_id").(int); ok {
+			startReq.AltBootID = uint64(altBootID)
+		}

 		log.Debugf("utilityComputeRollback: starting compute %d", computeId)

@@ -1824,10 +1904,14 @@ func utilityComputeStop(ctx context.Context, d *schema.ResourceData, m interface
 	return nil
 }

-func utilityComputeStart(ctx context.Context, computeID uint64, m interface{}) (int, error) {
+func utilityComputeStart(ctx context.Context, computeID uint64, altBootID uint64, m interface{}) (int, error) {
 	c := m.(*controller.ControllerCfg)
 	startReq := compute.StartRequest{ComputeID: computeID}

+	if altBootID > 0 {
+		startReq.AltBootID = altBootID
+	}
+
 	log.Debugf("utilityComputeStart: starting compute %d", computeID)
 	_, err := c.CloudBroker().Compute().Start(ctx, startReq)
 	if err != nil {
@@ -1928,6 +2012,100 @@ func isContainsDisk(els []interface{}, el interface{}) bool {
 	return false
 }

+func isChangeIOTuneDisk(els []interface{}, el interface{}) bool {
+	for _, elOld := range els {
+		elOldConv := elOld.(map[string]interface{})
+		elConv := el.(map[string]interface{})
+		if elOldConv["disk_id"].(int) != elConv["disk_id"].(int) {
+			continue
+		}
+		oldIOTune := elOldConv["iotune"].([]interface{})
+		newIOTune := elConv["iotune"].([]interface{})
+		if len(oldIOTune) == 0 && len(newIOTune) == 0 {
+			return false
+		}
+		if len(oldIOTune) == 0 || len(newIOTune) == 0 {
+			return true
+		}
+		oldMap := oldIOTune[0].(map[string]interface{})
+		newMap := newIOTune[0].(map[string]interface{})
+		return oldMap["read_bytes_sec"].(int) != newMap["read_bytes_sec"].(int) ||
+			oldMap["read_bytes_sec_max"].(int) != newMap["read_bytes_sec_max"].(int) ||
+			oldMap["read_iops_sec"].(int) != newMap["read_iops_sec"].(int) ||
+			oldMap["read_iops_sec_max"].(int) != newMap["read_iops_sec_max"].(int) ||
+			oldMap["size_iops_sec"].(int) != newMap["size_iops_sec"].(int) ||
+			oldMap["total_bytes_sec"].(int) != newMap["total_bytes_sec"].(int) ||
+			oldMap["total_bytes_sec_max"].(int) != newMap["total_bytes_sec_max"].(int) ||
+			oldMap["total_iops_sec"].(int) != newMap["total_iops_sec"].(int) ||
+			oldMap["total_iops_sec_max"].(int) != newMap["total_iops_sec_max"].(int) ||
+			oldMap["write_bytes_sec"].(int) != newMap["write_bytes_sec"].(int) ||
+			oldMap["write_bytes_sec_max"].(int) != newMap["write_bytes_sec_max"].(int) ||
+			oldMap["write_iops_sec"].(int) != newMap["write_iops_sec"].(int) ||
+			oldMap["write_iops_sec_max"].(int) != newMap["write_iops_sec_max"].(int)
+	}
+	return false
+}
+
+func utilityComputeCreateIOTune(ctx context.Context, d *schema.ResourceData, m interface{}) error {
+	c := m.(*controller.ControllerCfg)
+	diskList := d.Get("disks").([]interface{})
+
+	iotuneArr := make([]interface{}, 0, len(diskList))
+	hasAny := false
+	for _, elem := range diskList {
+		diskVal := elem.(map[string]interface{})
+		iotune := diskVal["iotune"].([]interface{})
+		iotuneArr = append(iotuneArr, iotune)
+		if len(iotune) > 0 {
+			hasAny = true
+		}
+	}
+
+	if !hasAny {
+		return nil
+	}
+
+	computeRec, err := utilityComputeCheckPresence(ctx, d, m)
+	if err != nil {
+		return err
+	}
+	bootDisk := findBootDisk(computeRec.Disks)
+	computeDisksIDs := getComputeDiskIDs(computeRec.Disks, diskList, d.Get("extra_disks").(*schema.Set).List(), bootDisk.ID)
+
+	for i, diskID := range computeDisksIDs {
+		if i >= len(iotuneArr) {
+			continue
+		}
+		iotune, ok := iotuneArr[i].([]interface{})
+		if !ok || len(iotune) == 0 {
+			continue
+		}
+		iotuneMap := iotune[0].(map[string]interface{})
+		req := disks.LimitIORequest{
+			DiskID:           diskID.(uint64),
+			ReadBytesSec:     uint64(iotuneMap["read_bytes_sec"].(int)),
+			ReadBytesSecMax:  uint64(iotuneMap["read_bytes_sec_max"].(int)),
+			ReadIOPSSec:      uint64(iotuneMap["read_iops_sec"].(int)),
+			ReadIOPSSecMax:   uint64(iotuneMap["read_iops_sec_max"].(int)),
+			SizeIOPSSec:      uint64(iotuneMap["size_iops_sec"].(int)),
+			TotalBytesSec:    uint64(iotuneMap["total_bytes_sec"].(int)),
+			TotalBytesSecMax: uint64(iotuneMap["total_bytes_sec_max"].(int)),
+			TotalIOPSSec:     uint64(iotuneMap["total_iops_sec"].(int)),
+			TotalIOPSSecMax:  uint64(iotuneMap["total_iops_sec_max"].(int)),
+			WriteBytesSec:    uint64(iotuneMap["write_bytes_sec"].(int)),
+			WriteBytesSecMax: uint64(iotuneMap["write_bytes_sec_max"].(int)),
+			WriteIOPSSec:     uint64(iotuneMap["write_iops_sec"].(int)),
+			WriteIOPSSecMax:  uint64(iotuneMap["write_iops_sec_max"].(int)),
+		}
+		_, err := c.CloudBroker().Disks().LimitIO(ctx, req)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
 // isChangeNodesDisk get slice of new disks values and current value disk,
 // if need change nodes on disk returns true and new disk value, else return false and nil
 func isChangeNodesDisk(els []interface{}, elOld interface{}) (bool, interface{}) {
--- a/internal/service/cloudbroker/trunk/flattens.go
+++ b/internal/service/cloudbroker/trunk/flattens.go
@@ -15,11 +15,11 @@ func flattenTrunkResource(d *schema.ResourceData, details *trunk.ItemTrunk) {
 	d.Set("name", details.Name)
 	d.Set("mac", details.MAC)
 	d.Set("description", details.Description)
-	d.Set("accountIds", details.AccountIDs)
-	d.Set("ovsBridge", details.OVSBridge)
-	d.Set("nativeVlanId", details.NativeVLANID)
+	d.Set("account_ids", details.AccountIDs)
+	d.Set("ovs_bridge", details.OVSBridge)
+	d.Set("native_vlan_id", details.NativeVLANID)
 	d.Set("status", details.Status)
-	d.Set("trunkTags", details.TrunkTags)
+	d.Set("trunk_tags", details.TrunkTags)
 	d.Set("created_at", details.CreatedAt)
 	d.Set("created_by", details.CreatedBy)
 	d.Set("updated_at", details.UpdatedAt)
--- a/internal/service/cloudbroker/vfpool/resource_vfpool.go
+++ b/internal/service/cloudbroker/vfpool/resource_vfpool.go
@@ -33,6 +33,7 @@ package vfpool

 import (
 	"context"
+	"fmt"
 	"strconv"

 	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
@@ -85,6 +86,12 @@ func resourceVFPoolCreate(ctx context.Context, d *schema.ResourceData, m interfa
 	}

 	config, configOk := d.GetOk("config")
+
+	enableVal := d.Get("enable").(bool)
+	if enableVal && !configOk {
+		return diag.FromErr(fmt.Errorf("enable requires config to be set"))
+	}
+
 	if configOk {
 		configArray := config.(*schema.Set).List()
 		req.Config = make([]vfpool.Config, 0, len(configArray))
@@ -117,10 +124,8 @@ func resourceVFPoolCreate(ctx context.Context, d *schema.ResourceData, m interfa

 	warnings := dc.Warnings{}

-	if enable, ok := d.GetOk("enable"); ok {
-		if err := utilityVFPoolEnabled(ctx, m, enable.(bool), vfPoolID, configOk); err != nil {
-			warnings.Add(err)
-		}
+	if err := utilityVFPoolEnabled(ctx, m, enableVal, vfPoolID); err != nil {
+		warnings.Add(err)
 	}

 	log.Debugf("resourceVFPoolCreate: create VFPool with ID: %d, complete", vfPoolID)
@@ -147,20 +152,12 @@ func resourceVFPoolUpdate(ctx context.Context, d *schema.ResourceData, m interfa

 	log.Debugf("resourceVFPoolUpdate: called VFPool with id %d", vfPoolID)

-	_, ok := d.GetOk("config")
-
-	if d.HasChanges("name,", "description", "account_access", "rg_access,", "config") {
+	if d.HasChanges("name", "description", "account_access", "rg_access", "config", "enable") {
 		if err := utilityVFPoolUpdate(ctx, d, m, vfPoolID); err != nil {
 			return diag.FromErr(err)
 		}
 	}

-	if d.HasChange("enable") {
-		if err := utilityVFPoolEnabled(ctx, m, d.Get("enable").(bool), vfPoolID, ok); err != nil {
-			return diag.FromErr(err)
-		}
-	}
-
 	log.Debugf("resourceVFPoolUpdate: update VFPool with id %d, complete", vfPoolID)

 	return resourceVFPoolRead(ctx, d, m)
--- a/internal/service/cloudbroker/vfpool/utility_vfpool.go
+++ b/internal/service/cloudbroker/vfpool/utility_vfpool.go
@@ -64,37 +64,26 @@ func utilityVFpoolCheckPresence(ctx context.Context, d *schema.ResourceData, m i
 	return vfpoolData, nil
 }

-func utilityVFPoolEnabled(ctx context.Context, m interface{}, enable bool, vfPoolID uint64, configOk bool) error {
+func utilityVFPoolEnabled(ctx context.Context, m interface{}, enable bool, vfPoolID uint64) error {
 	c := m.(*controller.ControllerCfg)

-	if enable && configOk {
-		req := vfpool.EnableRequest{
-			VFPoolID: vfPoolID,
-		}
-		_, err := c.CloudBroker().VFPool().Enable(ctx, req)
-		if err != nil {
-			return err
-		}
-	}
-	if enable && !configOk {
-		return fmt.Errorf("you must provide configuration for this resource, after enabling it")
-	}
-	if !enable {
-		req := vfpool.DisableRequest{
-			VFPoolID: vfPoolID,
-		}
-		_, err := c.CloudBroker().VFPool().Disable(ctx, req)
-		if err != nil {
-			return err
-		}
+	var err error
+
+	if enable {
+		_, err = c.CloudBroker().VFPool().Enable(ctx, vfpool.EnableRequest{VFPoolID: vfPoolID})
+	} else {
+		_, err = c.CloudBroker().VFPool().Disable(ctx, vfpool.DisableRequest{VFPoolID: vfPoolID})
 	}

-	log.Debugf("utilityVFPoolEnabled: enable=%v vfPool ID %d after completing its resource configuration", enable, vfPoolID)
-
-	return nil
+	return err
 }

 func utilityVFPoolUpdate(ctx context.Context, d *schema.ResourceData, m interface{}, vfPoolID uint64) error {
+	hasConfig := len(d.Get("config").(*schema.Set).List()) > 0
+	if d.Get("enable").(bool) && !hasConfig {
+		return fmt.Errorf("enable requires config to be set")
+	}
+
 	c := m.(*controller.ControllerCfg)

 	vfPool, err := utilityVFpoolCheckPresence(ctx, d, m)
@@ -190,7 +179,7 @@ func utilityVFPoolUpdate(ctx context.Context, d *schema.ResourceData, m interfac
 	}
 	log.Debugf("utilityVFPoolUpdate: update vfPool with ID: %d, complete with params=%v", vfPoolID, req)

-	if len(d.Get("config").(*schema.Set).List()) > 0 && d.Get("enable").(bool) {
+	if hasConfig && d.Get("enable").(bool) {
 		reqEnable := vfpool.EnableRequest{
 			VFPoolID: vfPoolID,
 		}
@@ -201,8 +190,6 @@ func utilityVFPoolUpdate(ctx context.Context, d *schema.ResourceData, m interfac
 			return err
 		}
 		log.Debugf("utilityVFPoolUpdate: enable vfPool with ID: %d, complete", vfPoolID)
-	} else {
-		return (fmt.Errorf("the vfPool is not enabled after update, you must provide configuration for this resource, after enabling it"))
 	}

 	return nil
--- a/samples/cloudapi/kvmvm/resource_kvmvm/main.tf
+++ b/samples/cloudapi/kvmvm/resource_kvmvm/main.tf
@@ -112,6 +112,18 @@ resource "decort_kvmvm" "comp" {
  #используется при создании
  #without_boot_disk = true

+  #создание без образа ОС
+  #опциональный параметр
+  #тип - булев
+  #используется при создании
+  #create_blank = false
+
+  #id образа CD-ROM для загрузки
+  #опциональный параметр
+  #тип - целое число
+  #используется при создании и обновлении
+  #alt_boot_id = 1
+
  #необходимость выравнивать ВМ по NUMA
  #опциональный параметр
  #возможные значения - "none, "strict", "loose"
@@ -160,11 +172,6 @@ resource "decort_kvmvm" "comp" {
    #тип - целое число
    #size = 5

-    #тип диска
-    #опциональный параметр
-    #тип - строка
-    #disk_type = "D"
-
    #id сепа
    #опциональный параметр
    #тип - целое число
@@ -189,6 +196,25 @@ resource "decort_kvmvm" "comp" {
    #опциональный параметр
    #тип - булев
    #permanently = false
+
+    #ограничения ввода-вывода для диска
+    #опциональный параметр
+    #тип - блок
+    #iotune {
+      #read_bytes_sec      = 0
+      #read_bytes_sec_max  = 0
+      #read_iops_sec       = 0
+      #read_iops_sec_max   = 0
+      #size_iops_sec       = 0
+      #total_bytes_sec     = 0
+      #total_bytes_sec_max = 0
+      #total_iops_sec      = 0
+      #total_iops_sec_max  = 0
+      #write_bytes_sec     = 0
+      #write_bytes_sec_max = 0
+      #write_iops_sec      = 0
+      #write_iops_sec_max  = 0
+    #}
  #}

  #правила affinity
--- a/samples/cloudbroker/kvmvm/resource_kvmvm/main.tf
+++ b/samples/cloudbroker/kvmvm/resource_kvmvm/main.tf
@@ -82,6 +82,12 @@ resource "decort_cb_kvmvm" "comp" {
  #используется при создании
  #without_boot_disk = true

+  #создание без образа ОС
+  #опциональный параметр
+  #тип - булев
+  #используется при создании
+  #create_blank = false
+
  #размер загрузочного диска
  #опциональный параметр
  #тип - целое число
@@ -121,7 +127,7 @@ resource "decort_cb_kvmvm" "comp" {
  #id образа CD-ROM для загрузки
  #опциональный параметр
  #тип - целое число
-  #используется при обновлении, при повторном старте вм
+  #используется при создании и обновлении
  #alt_boot_id = 1

  #необходимость выравнивать ВМ по NUMA
@@ -166,11 +172,6 @@ resource "decort_cb_kvmvm" "comp" {
    #тип - целое число
    #storage_policy_id = 1

-    #тип диска
-    #опциональный параметр
-    #тип - строка
-    #disk_type = "D"
-
    #опциональный параметр
    #тип - целое число
    #sep_id = 1
@@ -198,6 +199,25 @@ resource "decort_cb_kvmvm" "comp" {
    #опциональный параметр
    #тип - булев
    #permanently = false
+
+    #ограничения ввода-вывода для диска
+    #опциональный параметр
+    #тип - блок
+    #iotune {
+      #read_bytes_sec      = 0
+      #read_bytes_sec_max  = 0
+      #read_iops_sec       = 0
+      #read_iops_sec_max   = 0
+      #size_iops_sec       = 0
+      #total_bytes_sec     = 0
+      #total_bytes_sec_max = 0
+      #total_iops_sec      = 0
+      #total_iops_sec_max  = 0
+      #write_bytes_sec     = 0
+      #write_bytes_sec_max = 0
+      #write_iops_sec      = 0
+      #write_iops_sec_max  = 0
+    #}
  #}

  #правила affinity
Author	SHA1	Message	Date
Alexey Fetisov	e459fcb4c4	4.10.6	2026-06-15 13:23:15 +03:00
Alexey Fetisov	6b82f23445	1.10.5	2026-04-23 12:29:28 +03:00