v1.14.5

v1.14.4

CHANGELOG.md

@@ -1,57 +1,49 @@
-## Version 1.13.2
+## Version 1.14.5
 
 Методы `Audits` в cloudapi/compute, cloudbroker/compute, cloudapi/account, cloudbroker/account, cloudapi/vins, cloudbroker/vins, cloudapi/rg и cloudbroker/rg  стали deprecated и в следующих версиях будут удалены, вместо них необходимо использовать метод `List` в cloudapi/audit и cloudbroker/audit с соответствующими фильтрами  
-Метод `ListNodes` в cloudbroker/image стал deprecated и в следующих версиях будет удалён  
 Методы `AccessGrant`, `AccessGrantToPool`, `AccessRevoke`, `AccessRevokeToPool` в cloudbroker/sep стали deprecated и в следующих версиях будут удалены  
-Методы `ComputeCISet`, `ComputeCIUnset`, `GetAudits` в cloudbroker/computeGetAudits и `GetAudits` в cloudbroker/compute стали deprecated и будут удалены в следующих версиях
+Методы `ComputeCISet`, `ComputeCIUnset`, `GetAudits` в cloudbroker/compute и `GetAudits` в cloudapi/compute стали deprecated и будут удалены в следующих версиях  
+Методы `ComputeCISet`, `ComputeCIUnset` в cloudbroker/image стали deprecated и будут удалены в следующих версиях 
 
 Все методы группы `.SDN()` находятся в альфа-версии.
 
 ### Добавлено
 
-#### audit
-| Идентификатор<br>задачи | Описание |
-| --- | ---|
-| BGOS-706 | Поля `ResgroupID`, `AccountID`, `ComputeID` в структуру ответа `RecordAudit` в cloudbroker/audit |
-
 #### compute
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-703 | Опциональное поле `NetMask` в структуру запроса `NetAttachRequest` в cloudbroker/compute |
-| BGOS-704 | Поле `SepID` в структуру ответа `InfoDisk` в cloudapi/compute и cloudbroker/compute |
+| BGOS-360 | Валидация поля `Label` в структуре запроса `SnapshotCreateRequest` в cloudapi/compute и cloudbroker/compute | 
 
-#### kvmx86
+#### image
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-703 | Опциональное поле `NetMask` в структуры запросов `Interface` в cloudapi/kvmx86 и cloudbroker/kvmx86 |
+| BGOS-820 | Обязательное поле `SEPID` в структуру запроса `MultiImageExportRequest` в cloudbroker/image |
 
-#### sep
+#### locations
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-704 | Опциональное поле `SepIDs` в структуре запроса `ListRequest` в cloudbroker/sep |
+| BGOS-823 | Вычисляемое поле `ZeroAccessEnabled` в структуру ответа `ItemLocation` в cloudapi/locations |
 
-#### storage policy
+#### resource_optimizer
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-708 | Поле `SepTechStatus` в структуру запроса `ListRequest` в cloudapi/stpolicy и в cloudbroker/stpolicy |
-| BGOS-710 | Обязательное поле `AccessSEPsPool` в структуру запроса `UpdateRequest` в cloudbroker/stpolicy |
+| BGOS-818 | Группа методов `cloudbroker/resource_optimizer` для управления инструментом оптимизации ресурсов (DRS) |
 
-#### trunk
+### zone
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-705 | Поле `MTU` в структуру ответа `ItemTrunk` в cloudapi/trunk и в cloudbroker/trunk |
-| BGOS-705 | Опциональное поле `MTU` в структуры запроса`CreateRequest` и `UpdateRequest` в cloudbroker/trunk |
+| BGOS-819 | Вычисляемые поля `DRS`, `DRSUID`, `AppID`, `DecortURL`, `DRSName` и `SSOURL` в структуру ответа `RecordZone` в cloudapi/zone и в cloudbroker/zone |
+| BGOS-819 | Структура ответа `ItemZone` в cloudapi/zone и в cloudbroker/zone |
+| BGOS-819 | Опциональное поле `DRS` в структуру запроса `CreateRequest` в cloudbroker/zone |
 
 ### Изменено
 
-#### compute
+#### image
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-707 | Поле `Value` стало обязательным в структурах запроса `AntiAffinityRuleAddRequest`, `AntiAffinityRuleRemoveRequest`, `AffinityRuleAddRequest` и `AffinityRuleRemoveRequest` в cloudapi/compute и в cloudbroker/compute |
-| BGOS-707 | Тип поля `StoragePolicyID` изменен с обязательного на опциональный в структуре запроса`CloneRequest` в cloudbroker/compute |
-| BGOS-707 | Тип поля `ComputeID` с `uint64` на `string` в структуре запроса `GetCloneStatusRequest` в cloudbroker/compute |
+| BGOS-822 | Тип полей `HotResize` и `Bootable` в структуре запроса `EditRequest` с bool на interface в cloudbroker/image |
 
 #### node
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-709 | Поле `VFNum` заменено на поле `FNID` в структуре `VFParam` в структуре запроса `SetVFsParamsRequest` в cloudbroker/node |
+| BGOS-821 | Тип вычисляемого поля `VCPU` с `uint64` на `float64` в структуре ответа `FreeResourcesInfo` в cloudbroker/node |

README.md

@@ -18,6 +18,7 @@ Decort SDK - это библиотека, написанная на языке G
     - Версия 1.11.х Decort-SDK соответствует 4.3.0 версии платформы
     - Версия 1.12.х Decort-SDK соответствует 4.4.0 версии платформы
     - Версия 1.13.х Decort-SDK соответствует 4.5.0 версии платформы
+    - Версия 1.14.х Decort-SDK соответствует 4.6.0 версии платформы
 
 ## Оглавление
 
@@ -159,6 +160,7 @@ go get -u repository.basistech.ru/BASIS/decort-golang-sdk
 - `PCIDevice` - управление устройствами;
 - `Prometheus` - получение статистики prometheus;
 - `Resmon` - получение статистики resource monitoring;
+- `ResourceOptimizer` - управление инструментом оптимизации ресурсов (DRS);
 - `RG` - управление ресурсными группами аккаунта;
 - `Security group` – управление группами безопасности;
 - `SEP` - управление storage endpoint (sep);
@@ -364,6 +366,7 @@ func main() {
     - `pkg/cloudbroker/pcidevice` - для `PCIDevice`
     - `pkg/cloudbroker/prometheus` - для `Prometheus`
     - `pkg/cloudbroker/resmon` - для `Resmon`
+    - `pkg/cloudbroker/resource_optimizer` - для `ResourceOptimizer`
     - `pkg/cloudbroker/rg` - для `RG`
     - `pkg/cloudbroker/secgroup` - для `Security group`
     - `pkg/cloudbroker/sep` - для `SEP`
@@ -466,16 +469,6 @@ type CreateRequest struct {
 	// Node ID
 	// Required: false
 	NodeID uint64 `url:"nodeId,omitempty" json:"nodeId,omitempty"`
-
-	// System name
-	// Required: false
-	IS string `url:"IS,omitempty" json:"IS,omitempty"`
-
-	// Compute purpose
-	// Required: false
-	IPAType string `url:"ipaType,omitempty" json:"ipaType,omitempty"`
-
-	
 }
 ```
 
@@ -572,6 +565,7 @@ func main() {
     - `.PCIDevice()` - для работы с `PCIDevice`
     - `.Prometheus()` - для работы с `Prometheus`
     - `.Resmon()` - для работы с `Resmon`
+    - `.ResourceOptimizer()` - для работы с `ResourceOptimizer`
     - `.RG()` - для работы с `RG`
     - `.SecurityGroup()` - для работы с `Security Group`
     - `.SEP()` - для работы с `SEP`

internal/constants/constants.go

@@ -28,6 +28,7 @@ var FileName = map[string]string{
 var K8sValues = []string{"labels", "taints", "annotations, additionalSANs"}
 
 var VersionMap = map[string]string{
+	"4.6.0": "-",
 	"4.5.0": "-",
 	"4.4.0": "-",
 	"4.3.0": "-",

internal/validators/custom.go

@@ -86,13 +86,6 @@ func computeModeValidator(fe validator.FieldLevel) bool {
 	return IsInSlice(fieldValue, computeModeValues)
 }
 
-// computeDiskTypeValidator is used to validate DiskType field.
-func computeDiskTypeValidator(fe validator.FieldLevel) bool {
-	fieldValue := fe.Field().String()
-
-	return IsInSlice(fieldValue, computeDiskTypeValues)
-}
-
 // computeNetTypeValidator is used to validate NetType field.
 func computeNetTypeValidator(fe validator.FieldLevel) bool {
 	fieldValue := fe.Field().String()
@@ -151,13 +144,6 @@ func computeDataDisksValidator(fe validator.FieldLevel) bool {
 	return IsInSlice(fieldValue, computeDataDisksValues)
 }
 
-// diskTypeValidator is used to validate Type field.
-func diskTypeValidator(fe validator.FieldLevel) bool {
-	fieldValue := fe.Field().String()
-
-	return IsInSlice(fieldValue, diskTypeValues)
-}
-
 // flipgroupClientTypeValidator is used to validate ClientType field.
 func flipgroupClientTypeValidator(fe validator.FieldLevel) bool {
 	fieldValue := fe.Field().String()

internal/validators/messages.go

@@ -86,12 +86,6 @@ func errorMessage(fe validator.FieldError) string {
 			fe.Field(),
 			joinValues(computeModeValues))
 
-	case "computeDiskType":
-		return fmt.Sprintf("%s %s must be one of the following: %s",
-			prefix,
-			fe.Field(),
-			joinValues(computeDiskTypeValues))
-
 	case "mtu":
 		return fmt.Sprint(prefix, fe.Field(), "must be ", mtuMin, "-", mtuMax)
 
@@ -122,13 +116,6 @@ func errorMessage(fe validator.FieldError) string {
 			fe.Field(),
 			joinValues(computeDataDisksValues))
 
-	// Disk Validators
-	case "diskType":
-		return fmt.Sprintf("%s %s must be one of the following: %s",
-			prefix,
-			fe.Field(),
-			joinValues(diskTypeValues))
-
 	// Flipgroup Validators
 	case "flipgroupClientType":
 		return fmt.Sprintf("%s %s must be one of the following: %s",

internal/validators/validator.go

@@ -86,11 +86,6 @@ func registerAllValidators(validate *validator.Validate) error {
 		return err
 	}
 
-	err = validate.RegisterValidation("computeDiskType", computeDiskTypeValidator)
-	if err != nil {
-		return err
-	}
-
 	err = validate.RegisterValidation("computeNetType", computeNetTypeValidator)
 	if err != nil {
 		return err
@@ -111,11 +106,6 @@ func registerAllValidators(validate *validator.Validate) error {
 		return err
 	}
 
-	err = validate.RegisterValidation("diskType", diskTypeValidator)
-	if err != nil {
-		return err
-	}
-
 	err = validate.RegisterValidation("flipgroupClientType", flipgroupClientTypeValidator)
 	if err != nil {
 		return err

internal/validators/values.go

@@ -14,14 +14,11 @@ var (
 	computeTopologyValues   = []string{"compute", "node"}
 	computePolicyValues     = []string{"RECOMMENDED", "REQUIRED"}
 	computeModeValues       = []string{"EQ", "EN", "ANY"}
-	computeDiskTypeValues   = []string{"D", "B"}
 	computeNetTypeValues    = []string{"EXTNET", "VINS"}
 	computex86NetTypeValues = []string{"EXTNET", "VINS", "VFNIC", "DPDK", "SDN", "EMPTY", "TRUNK"}
 	computeOrderValues      = []string{"cdrom", "network", "hd"}
 	computeDataDisksValues  = []string{"KEEP", "DETACH", "DESTROY"}
 
-	diskTypeValues = []string{"B", "T", "D"}
-
 	flipgroupClientTypeValues = []string{"compute", "vins"}
 
 	massCreateNetTypeValues = []string{"EXTNET", "VINS", "TRUNK"}
@@ -66,7 +63,7 @@ var (
 
 	loaderTypeValues = []string{"linux", "windows", "unknown"}
 
-	sepTypeValues = []string{"hitachi", "dorado", "tatlin", "shared", "local", "des"}
+	sepTypeValues = []string{"hitachi", "dorado", "tatlin", "shared", "local", "des", "ustor"}
 
 	languageValues = []string{"ru", "en"}
 
@@ -86,7 +83,7 @@ var (
 )
 
 const (
-	mtuMin = 1
+	mtuMin = 1500
 	mtuMax = 9216
 
 	trunkTagsMin = 1

pkg/cloudapi/account/models.go

@@ -95,6 +95,9 @@ type ItemAccount struct {
 	// Deleted time
 	DeletedTime uint64 `json:"deletedTime"`
 
+	// Deleted by
+	DeletedBy string `json:"deletedBy"`
+
 	// Description
 	Description string `json:"desc"`
 
@@ -107,6 +110,9 @@ type ItemAccount struct {
 	// Status
 	Status string `json:"status"`
 
+	// Updated by
+	UpdatedBy string `json:"updatedBy"`
+
 	// Updated time
 	UpdatedTime uint64 `json:"updatedTime"`
 
@@ -299,6 +305,9 @@ type RecordAccount struct {
 	// UniqPools
 	UniqPools []interface{} `json:"uniqPools"`
 
+	// Updated By
+	UpdatedBy string `json:"updatedBy"`
+
 	// Updated time
 	UpdatedTime uint64 `json:"updatedTime"`
 

pkg/cloudapi/bservice/group_add.go

@@ -38,10 +38,6 @@ type GroupAddRequest struct {
 	// Required: true
 	ImageID uint64 `url:"imageId" json:"imageId" validate:"required"`
 
-	// Compute driver like a KVM_X86, etc.
-	// Required: true
-	Driver string `url:"driver" json:"driver" validate:"required"`
-
 	// Storage endpoint provider ID
 	// Required: false
 	SEPID uint64 `url:"sepId,omitempty" json:"sepId,omitempty"`

pkg/cloudapi/bservice/group_resize.go

@@ -25,15 +25,15 @@ type GroupResizeRequest struct {
 	// Chipset for new computes, either i440fx or Q35 (i440fx by default)
 	// Available values : i440fx, Q35
 	// Default value : Q35
-	// Required: true
-	Chipset string `url:"chipset" json:"chipset" validate:"required,chipset"`
+	// Required: false
+	Chipset string `url:"chipset,omitempty" json:"chipset,omitempty" validate:"omitempty,chipset"`
 
 	// Either delta or absolute value of computes
 	// Should be one of:
 	//	- ABSOLUTE
 	//	- RELATIVE
-	// Required: true
-	Mode string `url:"mode" json:"mode" validate:"bserviceMode"`
+	// Required: false
+	Mode string `url:"mode,omitempty" json:"mode,omitempty" validate:"omitempty,bserviceMode"`
 }
 
 // GroupResize resize the group by changing the number of computes

pkg/cloudapi/compute/abort_shared_snapshot_merge.go

@@ -3,7 +3,6 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
@@ -20,23 +19,18 @@ type AbortSharedSnapshotMergeRequest struct {
 }
 
 // AbortSharedSnapshotMerge shared snapshots merge abort
-func (c Compute) AbortSharedSnapshotMerge(ctx context.Context, req AbortSharedSnapshotMergeRequest) (bool, error) {
+func (c Compute) AbortSharedSnapshotMerge(ctx context.Context, req AbortSharedSnapshotMergeRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudapi/compute/abort_shared_snapshot_merge"
 
 	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
-		return false, err
+		return "", err
 	}
 
-	result, err := strconv.ParseBool(string(res))
-	if err != nil {
-		return false, err
-	}
-
-	return result, nil
+	return string(res), nil
 }

pkg/cloudapi/compute/clone_abort.go

@@ -2,8 +2,8 @@ package compute
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
-	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
@@ -17,22 +17,24 @@ type CloneAbortRequest struct {
 }
 
 // CloneAbort aborts a compute clone
-func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) (bool, error) {
+func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) (ListCloneAbort, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudapi/compute/clone_abort"
 
 	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
 	if err != nil {
-		return false, err
+		return nil, err
 	}
 
-	result, err := strconv.ParseBool(string(res))
+	var result ListCloneAbort
+
+	err = json.Unmarshal(res, &result)
 	if err != nil {
-		return false, err
+		return nil, err
 	}
 
 	return result, nil

pkg/cloudapi/compute/disk_add.go

@@ -26,13 +26,6 @@ type DiskAddRequest struct {
 	// Required: true
 	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
 
-	// Type of the disk
-	// Should be one of:
-	//	- D
-	//	- B
-	// Required: false
-	DiskType string `url:"diskType,omitempty" json:"diskType,omitempty" validate:"omitempty,computeDiskType"`
-
 	// Storage endpoint provider ID
 	// By default the same with boot disk
 	// Required: false

pkg/cloudapi/compute/disk_attach.go

@@ -18,10 +18,6 @@ type DiskAttachRequest struct {
 	// Required: true
 	DiskID uint64 `url:"diskId" json:"diskId" validate:"required"`
 
-	// Type of the disk B;D
-	// Required: false
-	DiskType string `url:"diskType,omitempty" json:"diskType,omitempty" validate:"omitempty,computeDiskType"`
-
 	// Desired PCI slot (hex string, e.g. "0x1A")
 	// Required: false
 	PCISlot string `url:"pci_slot,omitempty" json:"pci_slot,omitempty"`

pkg/cloudapi/compute/models.go

@@ -545,6 +545,9 @@ type RecordCompute struct {
 	// VNC password
 	VNCPassword string `json:"vncPasswd"`
 
+	// Weight
+	Weight uint64 `json:"weight"`
+
 	// Zone ID
 	// Required: false
 	ZoneID uint64 `json:"zoneId"`
@@ -789,12 +792,21 @@ type ItemComputeDisk struct {
 	// Account ID
 	AccountID uint64 `json:"accountId"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block Size
+	BlockSize string `json:"block_size"`
+
 	// Boot partition
 	BootPartition uint64 `json:"bootPartition"`
 
 	// Bus number
 	BusNumber uint64 `json:"bus_number"`
 
+	// Chache
+	Cache string `json:"cache"`
+
 	// Created by
 	CreatedBy string `json:"createdBy"`
 
@@ -831,6 +843,9 @@ type ItemComputeDisk struct {
 	// Image ID
 	ImageID uint64 `json:"imageId"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// List image IDs
 	Images []uint64 `json:"images"`
 
@@ -867,6 +882,9 @@ type ItemComputeDisk struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge time
 	PurgeTime uint64 `json:"purgeTime"`
 
@@ -1226,6 +1244,9 @@ type ItemCompute struct {
 	// VINS connected
 	VINSConnected uint64 `json:"vinsConnected"`
 
+	// Weight
+	Weight uint64 `json:"weight"`
+
 	// Zone ID
 	ZoneID uint64 `json:"zoneId"`
 }
@@ -1367,6 +1388,21 @@ type RecordCloneStatus struct {
 	Status CloneStatus `json:"status"`
 }
 
+// Information about aborted clone disk
+type RecordCloneAbort struct {
+	// Disk ID
+	DiskID uint64 `json:"disk_id"`
+
+	// Aborted
+	Aborted bool `json:"aborted"`
+
+	// Blockcopy abort job ID
+	BlockcopyAbortJobID string `json:"blockcopy_abort_job_id"`
+}
+
+// List of aborted clone disks
+type ListCloneAbort []RecordCloneAbort
+
 type CloneStatus struct {
 	// Type
 	Type int `json:"type"`

pkg/cloudapi/compute/net_attach.go

@@ -20,7 +20,7 @@ type NetAttachRequest struct {
 	// 'VFNIC' for connect to vfpool
 	// 'DPDK' for connect to DPDK
 	// `EMPTY` for connect empty network
-	// `SDT` for connect to SDN
+	// `SDN` for connect to SDN
 	// `TRUNK` for connect to TRUNK
 	// Required: true
 	NetType string `url:"netType" json:"netType" validate:"computex86NetType"`
@@ -39,12 +39,32 @@ type NetAttachRequest struct {
 	// Required: false
 	MACAddr string `url:"mac_addr,omitempty" json:"mac_addr,omitempty"`
 
-	// Used only for EXTNET and DPDK
-	// For DPDK must be 1-9216
-	// For EXTNET must be 1500-9216
+	// Used for EXTNET, TRUNK and DPDK
+	// Must be 1500-9216
 	// Required: false
 	MTU uint64 `url:"mtu,omitempty" json:"mtu,omitempty" validate:"omitempty,mtu"`
 
+	// Net mask
+	// Used only to DPDK or VFNIC net type
+	// Required: false
+	NetMask uint64 `url:"netMask,omitempty" json:"netMask,omitempty"`
+
+	// SDN Segment ID
+	// Required: false
+	SDNSegmentID string `url:"sdn_segment_id,omitempty" json:"sdn_segment_id,omitempty"`
+
+	// SDN Object Group ID
+	// Required: false
+	SDNObjectGroupID string `url:"sdn_object_group_id,omitempty" json:"sdn_object_group_id,omitempty"`
+
+	// SDN Logical Port Display Name
+	// Required: false
+	SDNLogicalPortDisplayName string `url:"sdn_logical_port_display_name,omitempty" json:"sdn_logical_port_display_name,omitempty"`
+
+	// SDN Logical Port Description
+	// Required: false
+	SDNLogicalPortDescription string `url:"sdn_logical_port_description,omitempty" json:"sdn_logical_port_description,omitempty"`
+
 	// Unique identifier of logical port on SDN side
 	// Required: false
 	SDNInterfaceID string `url:"sdn_interface_id,omitempty" json:"sdn_interface_id,omitempty" validate:"omitempty"`

pkg/cloudapi/compute/snapshot_create.go

@@ -16,8 +16,10 @@ type SnapshotCreateRequest struct {
 
 	// Text label for snapshot.
 	// Must be unique among this compute snapshots
+	// Allowed characters: a-z, 0-9, spaces, punctuation except '<' and '>'
+	// Maximum length: 36 characters
 	// Required: true
-	Label string `url:"label" json:"label" validate:"required"`
+	Label string `url:"label" json:"label" validate:"required,max=36,excludesall=<>"`
 }
 
 // SnapshotCreate create compute snapshot

pkg/cloudapi/disks/filter_test.go

@@ -48,7 +48,6 @@ var disks = ListDisks{
 			Snapshots:  []ItemSnapshot{},
 			Status:     "ASSIGNED",
 			TechStatus: techStatusAllocated,
-			Type:       "B",
 			VMID:       48500,
 		},
 		{
@@ -92,7 +91,6 @@ var disks = ListDisks{
 			Snapshots:  []ItemSnapshot{},
 			Status:     "ASSIGNED",
 			TechStatus: techStatusAllocated,
-			Type:       "B",
 			VMID:       48502,
 		},
 	},
@@ -224,7 +222,6 @@ var searchDisks = ListSearchDisks{
 		Snapshots:  []ItemSnapshot{},
 		Status:     "ASSIGNED",
 		TechStatus: techStatusAllocated,
-		Type:       "B",
 		VMID:       48500,
 	},
 	ItemDisk{
@@ -268,7 +265,6 @@ var searchDisks = ListSearchDisks{
 		Snapshots:  []ItemSnapshot{},
 		Status:     "ASSIGNED",
 		TechStatus: techStatusAllocated,
-		Type:       "B",
 		VMID:       48502,
 	},
 }
@@ -360,7 +356,6 @@ func TestListSearchDisks_SortByCreatedTime(t *testing.T) {
 var unattachedDisks = ListDisksUnattached{
 	Data: []ItemDiskUnattached{
 		{
-			CKey: "",
 			Meta: []interface{}{
 				"cloudbroker",
 				"disk",
@@ -408,11 +403,9 @@ var unattachedDisks = ListDisksUnattached{
 			Snapshots:           nil,
 			Status:              "CREATED",
 			TechStatus:          techStatusAllocated,
-			Type:                "D",
 			VMID:                0,
 		},
 		{
-			CKey: "",
 			Meta: []interface{}{
 				"cloudbroker",
 				"disk",
@@ -463,7 +456,6 @@ var unattachedDisks = ListDisksUnattached{
 			Snapshots:           nil,
 			Status:              "CREATED",
 			TechStatus:          techStatusAllocated,
-			Type:                "B",
 			VMID:                0,
 		},
 	},

pkg/cloudapi/disks/list.go

@@ -38,10 +38,6 @@ type ListRequest struct {
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// Find by sep ID
 	// Required: false
 	SEPID uint64 `url:"sepId,omitempty" json:"sepId,omitempty"`
@@ -65,6 +61,14 @@ type ListRequest struct {
 	// Page size
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
+
+	// ID of the resource group
+	// Required: false
+	RGID uint64 `url:"rg_id,omitempty" json:"rg_id,omitempty"`
+
+	// ID of the compute
+	// Required: false
+	ComputeID uint64 `url:"compute_id,omitempty" json:"compute_id,omitempty"`
 }
 
 // List gets list of the created disks belonging to an account as a ListDisks struct

pkg/cloudapi/disks/list_deleted.go

@@ -34,10 +34,6 @@ type ListDeletedRequest struct {
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// Sort by one of supported fields, format +|-(field)
 	// Required: false
 	SortBy string `url:"sortBy,omitempty" json:"sortBy,omitempty" validate:"omitempty,sortBy"`

pkg/cloudapi/disks/list_types.go

@@ -1,52 +0,0 @@
-package disks
-
-import (
-	"context"
-	"encoding/json"
-	"net/http"
-
-	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
-)
-
-// ListTypesRequest struct to get list types of disks
-type ListTypesRequest struct {
-	// Show detailed disk types by seps
-	// Required: true
-	Detailed bool `url:"detailed" json:"detailed"`
-
-	// Sort by one of supported fields, format +|-(field)
-	// Required: false
-	SortBy string `url:"sortBy,omitempty" json:"sortBy,omitempty" validate:"omitempty,sortBy"`
-
-	// Page number
-	// Required: false
-	Page uint64 `url:"page,omitempty" json:"page,omitempty"`
-
-	// Page size
-	// Required: false
-	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
-}
-
-// ListTypes gets list defined disk types
-func (d Disks) ListTypes(ctx context.Context, req ListTypesRequest) (*ListTypes, error) {
-
-	if err := validators.ValidateRequest(req); err != nil {
-		return nil, validators.ValidationErrors(validators.GetErrors(err))
-	}
-
-	url := "/cloudapi/disks/listTypes"
-
-	res, err := d.client.DecortApiCall(ctx, http.MethodPost, url, req)
-	if err != nil {
-		return nil, err
-	}
-
-	list := ListTypes{}
-
-	err = json.Unmarshal(res, &list)
-	if err != nil {
-		return nil, err
-	}
-
-	return &list, nil
-}

pkg/cloudapi/disks/list_unattached.go

@@ -26,10 +26,6 @@ type ListUnattachedRequest struct {
 	// Required: false
 	Status string `url:"status,omitempty" json:"status,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// ID of the account
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`

pkg/cloudapi/disks/models.go

@@ -11,6 +11,12 @@ type ItemDisk struct {
 	// Account name
 	AccountName string `json:"accountName"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block size of disk
+	BlockSize string `json:"block_size"`
+
 	// Computes
 	Computes map[string]string `json:"computes"`
 
@@ -44,6 +50,9 @@ type ItemDisk struct {
 	// Image ID
 	ImageID uint64 `json:"imageId"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// List of image IDs
 	Images []uint64 `json:"images"`
 
@@ -80,6 +89,9 @@ type ItemDisk struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge time
 	PurgeTime uint64 `json:"purgeTime"`
 
@@ -128,9 +140,6 @@ type ItemDisk struct {
 	// Need to clean before destroy
 	ToClean bool `json:"to_clean"`
 
-	// Type
-	Type string `json:"type"`
-
 	// Virtual machine ID
 	VMID uint64 `json:"vmid"`
 
@@ -139,12 +148,12 @@ type ItemDisk struct {
 
 	// Updated by
 	UpdatedBy string `json:"updatedBy"`
+
+	// Cache mode of disk
+	Cache string `json:"cache"`
 }
 
 type ItemDiskUnattached struct {
-	// CKey
-	CKey string `json:"_ckey"`
-
 	// Meta
 	Meta []interface{} `json:"_meta"`
 
@@ -157,9 +166,18 @@ type ItemDiskUnattached struct {
 	// Access Control List
 	ACL map[string]interface{} `json:"acl"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block size of disk
+	BlockSize string `json:"block_size"`
+
 	// Boot Partition
 	BootPartition uint64 `json:"bootPartition"`
 
+	// Cache
+	Cache string `json:"cache"`
+
 	// Created time
 	CreatedTime uint64 `json:"createdTime"`
 
@@ -226,6 +244,9 @@ type ItemDiskUnattached struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge attempts
 	PurgeAttempts uint64 `json:"purgeAttempts"`
 
@@ -268,8 +289,11 @@ type ItemDiskUnattached struct {
 	// Tech status
 	TechStatus string `json:"techStatus"`
 
-	// Type
-	Type string `json:"type"`
+	// Need to clean before destroy
+	ToClean bool `json:"to_clean"`
+
+	// ID of the Storage Policy
+	StoragePolicyID uint64 `json:"storage_policy_id"`
 
 	// Virtual machine ID
 	VMID uint64 `json:"vmid"`
@@ -375,6 +399,12 @@ type RecordDisk struct {
 	// Account name
 	AccountName string `json:"accountName"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block size of disk
+	BlockSize string `json:"block_size"`
+
 	// Computes
 	Computes map[string]string `json:"computes"`
 
@@ -408,6 +438,9 @@ type RecordDisk struct {
 	// Image ID
 	ImageID uint64 `json:"imageId"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// List of image IDs
 	Images []uint64 `json:"images"`
 
@@ -444,6 +477,9 @@ type RecordDisk struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge time
 	PurgeTime uint64 `json:"purgeTime"`
 
@@ -492,9 +528,6 @@ type RecordDisk struct {
 	// Need to clean before destroy
 	ToClean bool `json:"to_clean"`
 
-	// Type
-	Type string `json:"type"`
-
 	// Virtual machine ID
 	VMID uint64 `json:"vmid"`
 
@@ -503,6 +536,9 @@ type RecordDisk struct {
 
 	// Updated by
 	UpdatedBy string `json:"updatedBy"`
+
+	// Cache mode of disk
+	Cache string `json:"cache"`
 }
 
 type ItemReplication struct {
@@ -524,11 +560,3 @@ type ItemReplication struct {
 	// VolumeID
 	VolumeID string `json:"volumeId"`
 }
-
-type ListTypes struct {
-	// Data
-	Data []interface{} `json:"data"`
-
-	// Entry count
-	EntryCount uint64 `json:"entryCount"`
-}

pkg/cloudapi/flipgroup/list.go

@@ -34,10 +34,6 @@ type ListRequest struct {
 	// Required: false
 	AccountId uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Find by resource group ID
-	// Required: false
-	RGID uint64 `url:"rgId,omitempty" json:"rgId,omitempty"`
-
 	// Find by id
 	// Required: false
 	ByID uint64 `url:"by_id,omitempty" json:"by_id,omitempty"`

pkg/cloudapi/flipgroup/models.go

@@ -85,12 +85,6 @@ type RecordFLIPGroup struct {
 	// Network
 	Network string `json:"network"`
 
-	// Resource group ID
-	RGID uint64 `json:"rgId"`
-
-	// Resource group name
-	RGName string `json:"rgName"`
-
 	// Status
 	Status string `json:"status"`
 

pkg/cloudapi/image/models.go

@@ -92,9 +92,6 @@ type RecordImage struct {
 	// UNCPathj
 	UNCPath string `json:"UNCPath"`
 
-	// CKey
-	CKey string `json:"_ckey"`
-
 	// Account ID
 	AccountID uint64 `json:"accountId"`
 
@@ -143,12 +140,18 @@ type RecordImage struct {
 	// ID
 	ID uint64 `json:"id"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// Last modified
 	LastModified uint64 `json:"lastModified"`
 
 	// Link to
 	LinkTo uint64 `json:"linkTo"`
 
+	// Links to
+	LinksTo []uint64 `json:"linksTo"`
+
 	// Milestones
 	Milestones uint64 `json:"milestones"`
 

pkg/cloudapi/kvmx86/create.go

@@ -30,8 +30,8 @@ type Interface struct {
 	// Required: false
 	IPAddr string `url:"ipAddr,omitempty" json:"ipAddr,omitempty"`
 
-	// Maximum transmission unit, must be 1-9216
-	// Used only to DPDK net type
+	// Used for EXTNET, TRUNK and DPDK
+	// Must be 1500-9216
 	// Required: false
 	MTU uint64 `url:"mtu,omitempty" json:"mtu,omitempty" validate:"omitempty,mtu"`
 
@@ -44,6 +44,22 @@ type Interface struct {
 	// Required: false
 	MAC string `url:"mac,omitempty" json:"mac,omitempty" validate:"omitempty"`
 
+	// SDN Segment ID
+	// Required: false
+	SDNSegmentID string `url:"sdn_segment_id,omitempty" json:"sdn_segment_id,omitempty"`
+
+	// SDN Object Group ID
+	// Required: false
+	SDNObjectGroupID string `url:"sdn_object_group_id,omitempty" json:"sdn_object_group_id,omitempty"`
+
+	// SDN Logical Port Display Name
+	// Required: false
+	SDNLogicalPortDisplayName string `url:"sdn_logical_port_display_name,omitempty" json:"sdn_logical_port_display_name,omitempty"`
+
+	// SDN Logical Port Description
+	// Required: false
+	SDNLogicalPortDescription string `url:"sdn_logical_port_description,omitempty" json:"sdn_logical_port_description,omitempty"`
+
 	// SDN interface id
 	// Required: false
 	SDNInterfaceID string `url:"sdn_interface_id,omitempty" json:"sdn_interface_id,omitempty"`
@@ -167,14 +183,6 @@ type CreateRequest struct {
 	// Required: false
 	Start bool `url:"start" json:"start"`
 
-	// System name
-	// Required: false
-	IS string `url:"IS,omitempty" json:"IS,omitempty"`
-
-	// Compute purpose
-	// Required: false
-	IPAType string `url:"ipaType,omitempty" json:"ipaType,omitempty"`
-
 	// Custom fields for compute. Must be a dict
 	// Required: false
 	CustomFields string `url:"customFields,omitempty" json:"customFields,omitempty"`

pkg/cloudapi/lb/create.go

@@ -38,8 +38,8 @@ type CreateRequest struct {
 	HighlyAvailable bool `url:"highlyAvailable,omitempty" json:"highlyAvailable,omitempty"`
 
 	// Start now Load balancer
-	// Required: true
-	Start bool `url:"start" json:"start" validate:"required"`
+	// Required: false
+	Start interface{} `url:"start,omitempty" json:"start,omitempty" validate:"omitempty,isBool"`
 
 	// Text description of this load balancer
 	// Required: false

pkg/cloudapi/locations/models.go

@@ -34,6 +34,9 @@ type ItemLocation struct {
 
 	// Support of SDN
 	SDNSupport bool `json:"sdn_support"`
+
+	// Is Zero Access enabled
+	ZeroAccessEnabled bool `json:"zeroaccess_enabled"`
 }
 
 // List of locations

pkg/cloudapi/rg/models.go

@@ -267,6 +267,9 @@ type ListResourceGroups struct {
 
 // Main information about Access Control List
 type ItemACL struct {
+	// Email
+	Email string `json:"email"`
+
 	// Explicit
 	Explicit bool `json:"explicit"`
 

pkg/cloudapi/zone/filter.go

@@ -2,7 +2,7 @@ package zone
 
 // FilterByID returns ListZones with specified ID.
 func (list ListZones) FilterByID(id uint64) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.ID == id
 	}
 
@@ -11,7 +11,7 @@ func (list ListZones) FilterByID(id uint64) ListZones {
 
 // FilterByName returns ListZones with specified Name.
 func (list ListZones) FilterByName(name string) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.Name == name
 	}
 
@@ -20,7 +20,7 @@ func (list ListZones) FilterByName(name string) ListZones {
 
 // FilterByStatus returns ListZones with specified Status.
 func (list ListZones) FilterByStatus(status string) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.Status == status
 	}
 
@@ -28,7 +28,7 @@ func (list ListZones) FilterByStatus(status string) ListZones {
 }
 
 // FilterFunc allows filtering ListZones based on a user-specified predicate.
-func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
+func (list ListZones) FilterFunc(predicate func(ItemZone) bool) ListZones {
 	var result ListZones
 
 	for _, item := range list.Data {
@@ -42,11 +42,11 @@ func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
 	return result
 }
 
-// FindOne returns first found RecordZone
+// FindOne returns first found ItemZone
 // If none was found, returns an empty struct.
-func (list ListZones) FindOne() RecordZone {
+func (list ListZones) FindOne() ItemZone {
 	if list.EntryCount == 0 {
-		return RecordZone{}
+		return ItemZone{}
 	}
 
 	return list.Data[0]

pkg/cloudapi/zone/filter_test.go

@@ -3,7 +3,7 @@ package zone
 import "testing"
 
 var zones = ListZones{
-	Data: []RecordZone{
+	Data: []ItemZone{
 
 		{
 			ID:          2,
@@ -76,7 +76,7 @@ func TestFilterByStatus(t *testing.T) {
 }
 
 func TestFilterFunc(t *testing.T) {
-	actual := zones.FilterFunc(func(ien RecordZone) bool {
+	actual := zones.FilterFunc(func(ien ItemZone) bool {
 		return ien.Deletable == true
 	})
 

pkg/cloudapi/zone/models.go

@@ -5,11 +5,14 @@ type ListZones struct {
 	EntryCount uint64 `json:"entryCount"`
 
 	// Data
-	Data []RecordZone `json:"data"`
+	Data []ItemZone `json:"data"`
 }
 
 // Detailed information about the zone record
 type RecordZone struct {
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	AutoStart bool `json:"autostart"`
+
 	// ID
 	ID uint64 `json:"id"`
 
@@ -44,7 +47,7 @@ type RecordZone struct {
 	K8SIDs []uint64 `json:"k8sIds"`
 
 	// List of associated LB IDs
-	LBIDs []uint64 `json:"lbIds"`
+	LBIDs []uint64 `json:"lbsIds"`
 
 	// Status
 	Status string `json:"status"`
@@ -60,4 +63,76 @@ type RecordZone struct {
 
 	// List of associated VINS IDs
 	VinsIDs []uint64 `json:"vinsIds"`
+
+	// DRS
+	DRS bool `json:"drs"`
+
+	// DRS UID
+	DRSUID string `json:"drs_uid"`
+
+	// App ID
+	AppID string `json:"app_id"`
+
+	// Decort URL
+	DecortURL string `json:"decort_url"`
+
+	// DRS Name
+	DRSName string `json:"drs_name"`
+
+	// SSO URL
+	SSOURL string `json:"sso_url"`
+}
+
+// A zone item from a list
+type ItemZone struct {
+	// App ID
+	AppID string `json:"app_id"`
+
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	AutoStart bool `json:"autostart"`
+
+	// Created timestamp
+	CreatedTime uint64 `json:"createdTime"`
+
+	// Decort URL
+	DecortURL string `json:"decort_url"`
+
+	// Deletable flag
+	Deletable bool `json:"deletable"`
+
+	// Description
+	Description string `json:"description"`
+
+	// DRS
+	DRS bool `json:"drs"`
+
+	// DRS Name
+	DRSName string `json:"drs_name"`
+
+	// DRS UID
+	DRSUID string `json:"drs_uid"`
+
+	// GID
+	GID uint64 `json:"gid"`
+
+	// GUID
+	GUID uint64 `json:"guid"`
+
+	// ID
+	ID uint64 `json:"id"`
+
+	// Name
+	Name string `json:"name"`
+
+	// List of associated Node IDs
+	NodeIDs []uint64 `json:"nodeIds"`
+
+	// SSO URL
+	SSOURL string `json:"sso_url"`
+
+	// Status
+	Status string `json:"status"`
+
+	// Updated timestamp
+	UpdatedTime uint64 `json:"updatedTime"`
 }

pkg/cloudbroker/account/models.go

@@ -215,6 +215,9 @@ type InfoAccount struct {
 	// UniqPools
 	UniqPools []string `json:"uniqPools"`
 
+	// Updated By
+	UpdatedBy string `json:"updatedBy"`
+
 	// UpdatedTime
 	UpdatedTime uint64 `json:"updatedTime"`
 

pkg/cloudbroker/account/update.go

@@ -64,6 +64,10 @@ type UpdateRequest struct {
 	// Default zone ID
 	// Required: false
 	DefaultZoneID uint64 `url:"defaultZoneId,omitempty" json:"defaultZoneId,omitempty"`
+
+	// CPU allocation parameter
+	// Required: false
+	CpuAllocationParameter string `url:"cpu_allocation_parameter,omitempty" json:"cpu_allocation_parameter,omitempty"`
 }
 
 // Update updates an account name and resource types and limits

pkg/cloudbroker/bservice/group_add.go

@@ -38,10 +38,6 @@ type GroupAddRequest struct {
 	// Required: true
 	ImageID uint64 `url:"imageId" json:"imageId" validate:"required"`
 
-	// Compute driver like a KVM_X86, etc.
-	// Required: true
-	Driver string `url:"driver" json:"driver" validate:"required"`
-
 	// Storage endpoint provider ID
 	// Required: false
 	SEPID uint64 `url:"sepId,omitempty" json:"sepId,omitempty"`

pkg/cloudbroker/bservice/group_resize.go

@@ -25,15 +25,15 @@ type GroupResizeRequest struct {
 	// Chipset for new computes, either i440fx or Q35 (i440fx by default)
 	// Available values : i440fx, Q35
 	// Default value : Q35
-	//Required: true
-	Chipset string `url:"chipset" json:"chipset" validate:"required,chipset"`
+	// Required: false
+	Chipset string `url:"chipset,omitempty" json:"chipset,omitempty" validate:"omitempty,chipset"`
 
 	// Either delta or absolute value of computes
 	// Should be one of:
 	//	- ABSOLUTE
 	//	- RELATIVE
-	// Required: true
-	Mode string `url:"mode" json:"mode" validate:"bserviceMode"`
+	// Required: false
+	Mode string `url:"mode,omitempty" json:"mode,omitempty" validate:"omitempty,bserviceMode"`
 }
 
 // GroupResize resize the group by changing the number of computes

pkg/cloudbroker/compute/abort_shared_snapshot_merge.go

@@ -3,7 +3,6 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
@@ -20,23 +19,18 @@ type AbortSharedSnapshotMergeRequest struct {
 }
 
 // AbortSharedSnapshotMerge shared snapshots merge abort
-func (c Compute) AbortSharedSnapshotMerge(ctx context.Context, req AbortSharedSnapshotMergeRequest) (bool, error) {
+func (c Compute) AbortSharedSnapshotMerge(ctx context.Context, req AbortSharedSnapshotMergeRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudbroker/compute/abort_shared_snapshot_merge"
 
 	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
-		return false, err
+		return "", err
 	}
 
-	result, err := strconv.ParseBool(string(res))
-	if err != nil {
-		return false, err
-	}
-
-	return result, nil
+	return string(res), nil
 }

pkg/cloudbroker/compute/check_compute_placement.go

@@ -0,0 +1,47 @@
+package compute
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// CheckComputePlacementRequest struct for check compute placement
+type CheckComputePlacementRequest struct {
+	// IDs of compute instances to check
+	// Required: true
+	ComputeIDs []uint64 `url:"compute_ids" json:"compute_ids" validate:"required"`
+
+	// Filter by CPU and RAM when checking placement
+	// Required: false
+	// Default: true
+	FilterByCPURAM interface{} `url:"filter_by_cpu_ram,omitempty" json:"filter_by_cpu_ram,omitempty" validate:"omitempty,isBool"`
+}
+
+// CheckComputePlacement checks compute placement and returns structured result
+func (c Compute) CheckComputePlacement(ctx context.Context, req CheckComputePlacementRequest) (CheckComputePlacementResult, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/compute/check_compute_placement"
+
+	if req.FilterByCPURAM == nil {
+		req.FilterByCPURAM = true
+	}
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	result := make(CheckComputePlacementResult)
+	if err := json.Unmarshal(res, &result); err != nil {
+		return nil, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/compute/clone.go

@@ -19,8 +19,8 @@ type CloneRequest struct {
 	Name string `url:"name" json:"name" validate:"required"`
 
 	// ID of the Storage Policy
-	// Required: false
-	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id"`
+	// Required: true
+	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
 
 	// Timestamp of the parent's snapshot to create clone from
 	// Required: false

pkg/cloudbroker/compute/clone_abort.go

@@ -2,8 +2,8 @@ package compute
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
-	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
@@ -17,22 +17,24 @@ type CloneAbortRequest struct {
 }
 
 // CloneAbort aborts a compute clone
-func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) (bool, error) {
+func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) ([]RecordCloneAbort, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudbroker/compute/clone_abort"
 
 	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
 	if err != nil {
-		return false, err
+		return nil, err
 	}
 
-	result, err := strconv.ParseBool(string(res))
+	result := make([]RecordCloneAbort, 0)
+
+	err = json.Unmarshal(res, &result)
 	if err != nil {
-		return false, err
+		return nil, err
 	}
 
 	return result, nil

pkg/cloudbroker/compute/disk_add.go

@@ -31,13 +31,6 @@ type DiskAddRequest struct {
 	// Required: true
 	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
 
-	// Type of the disk
-	// Should be one of:
-	//	- D
-	//	- B
-	// Required: false
-	DiskType string `url:"diskType,omitempty" json:"diskType,omitempty" validate:"omitempty,computeDiskType"`
-
 	// Pool name
 	// By default will be chosen automatically
 	// Required: false
@@ -58,6 +51,14 @@ type DiskAddRequest struct {
 	// Desired bus number (hex string, e.g. "0x03")
 	// Required: false
 	BusNumber string `url:"bus_number,omitempty" json:"bus_number,omitempty"`
+
+	// Disk cache mode
+	// Required: false
+	Cache string `url:"cache,omitempty" json:"cache,omitempty"`
+
+	// BLK Discard
+	// Required: false
+	BLKDiscard interface{} `url:"blkdiscard,omitempty" json:"blkdiscard,omitempty" validate:"omitempty,isBool"`
 }
 
 // DiskAdd creates new disk and attach to compute

pkg/cloudbroker/compute/disk_attach.go

@@ -18,10 +18,6 @@ type DiskAttachRequest struct {
 	// Required: true
 	DiskID uint64 `url:"diskId" json:"diskId" validate:"required"`
 
-	// Type of the disk B;D
-	// Required: false
-	DiskType string `url:"diskType,omitempty" json:"diskType,omitempty"`
-
 	// Desired PCI slot (hex string, e.g. "0x1A")
 	// Required: false
 	PCISlot string `url:"pci_slot,omitempty" json:"pci_slot,omitempty"`

pkg/cloudbroker/compute/models.go

@@ -391,12 +391,21 @@ type ItemDisk struct {
 	// Access Control List
 	ACL ItemACL `json:"acl"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block Size
+	BlockSize string `json:"block_size"`
+
 	// Boot partition
 	BootPartition uint64 `json:"bootPartition"`
 
 	// Bus number
 	BusNumber uint64 `json:"bus_number"`
 
+	// Chache
+	Cache string `json:"cache"`
+
 	// Created by
 	CreatedBy string `json:"createdBy"`
 
@@ -433,6 +442,9 @@ type ItemDisk struct {
 	// Image ID
 	ImageID uint64 `json:"imageId"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// List image IDs
 	Images []uint64 `json:"images"`
 
@@ -469,6 +481,9 @@ type ItemDisk struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge attempts
 	PurgeAttempts uint64 `json:"purgeAttempts"`
 
@@ -882,6 +897,9 @@ type InfoCompute struct {
 	// VINS connected
 	VINSConnected uint64 `json:"vinsConnected"`
 
+	// Weight
+	Weight uint64 `json:"weight"`
+
 	// Zone ID
 	ZoneID uint64 `json:"zoneId"`
 }
@@ -1169,6 +1187,9 @@ type RecordCompute struct {
 	// VNC password
 	VNCPassword string `json:"vncPasswd"`
 
+	// Weight
+	Weight uint64 `json:"weight"`
+
 	// Zone ID
 	ZoneID uint64 `json:"zoneId"`
 
@@ -1460,6 +1481,17 @@ type MigrateStorageItem struct {
 	TargetNodeID uint64 `json:"targetNodeId"`
 }
 
+type RecordCloneAbort struct {
+	// Disk ID
+	DiskID uint64 `json:"disk_id"`
+
+	// Aborted
+	Aborted bool `json:"aborted"`
+
+	// Blockcopy abort job ID
+	BlockcopyAbortJobID string `json:"blockcopy_abort_job_id"`
+}
+
 type RecordCloneStatus struct {
 	// Disk ID
 	DiskID int `json:"disk_id"`
@@ -1487,3 +1519,20 @@ type CloneStatus struct {
 	// Progress percent
 	ProgressPercent int `json:"progress_percent"`
 }
+
+type CheckComputePlacementError struct {
+	// Code
+	Code int64 `json:"code"`
+
+	// Message
+	Message string `json:"message"`
+}
+
+type CheckComputePlacementItem struct {
+	// Nide IDs
+	NodeIDs []uint64 `json:"node_ids"`
+	// error
+	Error CheckComputePlacementError `json:"error,omitempty"`
+}
+
+type CheckComputePlacementResult map[uint64]CheckComputePlacementItem

pkg/cloudbroker/compute/net_attach.go

@@ -20,7 +20,7 @@ type NetAttachRequest struct {
 	// 'VFNIC' for connect to vfpool
 	// 'DPDK' for connect to DPDK
 	// `EMPTY` for connect empty network
-	// `SDT` for connect to SDN
+	// `SDN` for connect to SDN
 	// `TRUNK` for connect to TRUNK
 	// Required: true
 	NetType string `url:"netType" json:"netType" validate:"computex86NetType"`
@@ -39,9 +39,8 @@ type NetAttachRequest struct {
 	// Required: false
 	MACAddr string `url:"mac_addr,omitempty" json:"mac_addr,omitempty"`
 
-	// Used only for EXTNET and DPDK
-	// For DPDK must be 1-9216
-	// For EXTNET must be 1500-9216
+	// Used for EXTNET, TRUNK and DPDK
+	// Must be 1500-9216
 	// Required: false
 	MTU uint64 `url:"mtu,omitempty" json:"mtu,omitempty" validate:"omitempty,mtu"`
 
@@ -50,6 +49,22 @@ type NetAttachRequest struct {
 	// Required: false
 	NetMask uint64 `url:"netMask,omitempty" json:"netMask,omitempty"`
 
+	// SDN Segment ID
+	// Required: false
+	SDNSegmentID string `url:"sdn_segment_id,omitempty" json:"sdn_segment_id,omitempty"`
+
+	// SDN Object Group ID
+	// Required: false
+	SDNObjectGroupID string `url:"sdn_object_group_id,omitempty" json:"sdn_object_group_id,omitempty"`
+
+	// SDN Logical Port Display Name
+	// Required: false
+	SDNLogicalPortDisplayName string `url:"sdn_logical_port_display_name,omitempty" json:"sdn_logical_port_display_name,omitempty"`
+
+	// SDN Logical Port Description
+	// Required: false
+	SDNLogicalPortDescription string `url:"sdn_logical_port_description,omitempty" json:"sdn_logical_port_description,omitempty"`
+
 	// Unique identifier of logical port on SDN side
 	// Required: false
 	SDNInterfaceID string `url:"sdn_interface_id,omitempty" json:"sdn_interface_id,omitempty" validate:"omitempty"`

pkg/cloudbroker/compute/snapshot_create.go

@@ -16,8 +16,10 @@ type SnapshotCreateRequest struct {
 
 	// Text label for snapshot.
 	// Must be unique among this compute snapshots
+	// Allowed characters: a-z, 0-9, spaces, punctuation except '<' and '>'
+	// Maximum length: 36 characters
 	// Required: true
-	Label string `url:"label" json:"label" validate:"required"`
+	Label string `url:"label" json:"label" validate:"required,max=36,excludesall=<>"`
 }
 
 // SnapshotCreate creates compute snapshot

pkg/cloudbroker/compute/start_migration_out.go

@@ -33,7 +33,11 @@ type StartMigrationOutRequest struct {
 
 	// Mapping of guest disk target names to absolute paths on the destination host.
 	// Required: false
-	Diskmap map[string]string `url:"diskmap,omitempty" json:"diskmap,omitempty"`
+	DiskMap map[string]string `url:"diskmap,omitempty" json:"diskmap,omitempty"`
+
+	// Mapping of network interfaces
+	// Required: false
+	NetMap map[string]string `url:"netmap,omitempty" json:"netmap,omitempty"`
 
 	// Mapping for CD/DVD devices or their source paths to new ISO/device paths on the destination
 	// Required: false

pkg/cloudbroker/compute/update.go

@@ -69,6 +69,10 @@ type UpdateRequest struct {
 	// The OS version that will be installed on the virtual machine
 	// Required: false
 	OSVersion string `url:"os_version,omitempty" json:"os_version,omitempty"`
+
+	// Priority weight of the compute: higher value means higher priority and later migration
+	// Required: false
+	Weight uint64 `url:"weight,omitempty" json:"weight,omitempty"`
 }
 
 // Update updates some properties of the compute

pkg/cloudbroker/disks/create.go

@@ -37,6 +37,14 @@ type CreateRequest struct {
 	// Pool name to create disk
 	// Required: false
 	Pool string `url:"pool,omitempty" json:"pool,omitempty"`
+
+	// Cache mode of disk
+	// Required: false
+	Cache string `url:"cache,omitempty" json:"cache,omitempty"`
+
+	// BLK Discard
+	// Required: false
+	BLKDiscard interface{} `url:"blkdiscard,omitempty" json:"blkdiscard,omitempty" validate:"omitempty,isBool"`
 }
 
 // Create creates a disk

pkg/cloudbroker/disks/filter_test.go

@@ -59,7 +59,6 @@ var disks = ListDisks{
 					Snapshots:           []ItemSnapshot{},
 					Status:              "ASSIGNED",
 					TechStatus:          "ALLOCATED",
-					Type:                "B",
 					VMID:                48500,
 				},
 			},
@@ -120,7 +119,6 @@ var disks = ListDisks{
 					Snapshots:           []ItemSnapshot{},
 					Status:              "ASSIGNED",
 					TechStatus:          "ALLOCATED",
-					Type:                "B",
 					VMID:                48502,
 				},
 			},

pkg/cloudbroker/disks/list.go

@@ -38,10 +38,6 @@ type ListRequest struct {
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// Find by sep ID
 	// Required: false
 	SEPID uint64 `url:"sepId,omitempty" json:"sepId,omitempty"`
@@ -65,6 +61,14 @@ type ListRequest struct {
 	// Page size
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
+
+	// ID of the resource group
+	// Required: false
+	RGID uint64 `url:"rg_id,omitempty" json:"rg_id,omitempty"`
+
+	// ID of the compute
+	// Required: false
+	ComputeID uint64 `url:"compute_id,omitempty" json:"compute_id,omitempty"`
 }
 
 // List gets list of the created disks belonging to an account as a ListDisks struct

pkg/cloudbroker/disks/list_deleted.go

@@ -34,10 +34,6 @@ type ListDeletedRequest struct {
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// Sort by one of supported fields, format +|-(field)
 	// Required: false
 	SortBy string `url:"sortBy,omitempty" json:"sortBy,omitempty" validate:"omitempty,sortBy"`

pkg/cloudbroker/disks/list_types.go

@@ -1,53 +0,0 @@
-package disks
-
-import (
-	"context"
-	"encoding/json"
-	"net/http"
-
-	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
-)
-
-// ListTypesRequest struct to get list of types of disks
-type ListTypesRequest struct {
-	// Show detailed disk types by seps
-	// Required: false
-	Detailed bool `url:"detailed" json:"detailed"`
-
-	// Sort by one of supported fields, format +|-(field)
-	// Required: false
-	SortBy string `url:"sortBy,omitempty" json:"sortBy,omitempty" validate:"omitempty,sortBy"`
-
-	// Page number
-	// Required: false
-	Page uint64 `url:"page,omitempty" json:"page,omitempty"`
-
-	// Page size
-	// Required: false
-	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
-}
-
-// ListTypes gets list of defined disk types
-func (d Disks) ListTypes(ctx context.Context, req ListTypesRequest) (*ListTypes, error) {
-
-	if err := validators.ValidateRequest(req); err != nil {
-		return nil, validators.ValidationErrors(validators.GetErrors(err))
-	}
-
-	url := "/cloudbroker/disks/listTypes"
-
-	res, err := d.client.DecortApiCall(ctx, http.MethodPost, url, req)
-	if err != nil {
-		return nil, err
-	}
-
-	list := ListTypes{}
-
-	err = json.Unmarshal(res, &list)
-	if err != nil {
-		return nil, err
-	}
-
-	return &list, nil
-
-}

pkg/cloudbroker/disks/list_unattached.go

@@ -26,10 +26,6 @@ type ListUnattachedRequest struct {
 	// Required: false
 	Status string `url:"status,omitempty" json:"status,omitempty"`
 
-	// Type of the disks
-	// Required: false
-	Type string `url:"type,omitempty" json:"type,omitempty"`
-
 	// ID of the account
 	// Required: false
 	AccountID uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`

pkg/cloudbroker/disks/models.go

@@ -53,6 +53,12 @@ type InfoDisk struct {
 	// Access Control Control
 	ACL map[string]interface{} `json:"acl"`
 
+	// BLK Discard
+	BLKDiscard bool `json:"blkdiscard"`
+
+	// Block size of disk
+	BlockSize string `json:"block_size"`
+
 	// Boot partition
 	BootPartition uint64 `json:"bootPartition"`
 
@@ -125,6 +131,9 @@ type InfoDisk struct {
 	// Present to
 	PresentTo map[string]uint64 `json:"presentTo"`
 
+	// Provision
+	Provision string `json:"provision"`
+
 	// Purge attempts
 	PurgeAttempts uint64 `json:"purgeAttempts"`
 
@@ -179,14 +188,14 @@ type InfoDisk struct {
 	// Need to clean before destroy
 	ToClean bool `json:"to_clean"`
 
-	// Type
-	Type string `json:"type"`
-
 	// Virtual machine ID
 	VMID uint64 `json:"vmid"`
 
 	// Updated by
 	UpdatedBy string `json:"updatedBy"`
+
+	// Cache mode of disk
+	Cache string `json:"cache"`
 }
 
 type ItemReplication struct {
@@ -212,6 +221,9 @@ type ItemReplication struct {
 // Detailed indormation about disk
 type RecordDisk struct {
 
+	// Block size of disk
+	BlockSize string `json:"block_size"`
+
 	//Created by
 	CreatedBy string `json:"createdBy"`
 
@@ -233,6 +245,9 @@ type RecordDisk struct {
 	// Main information about disk
 	InfoDisk
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	//Updated by
 	UpdatedBy string `json:"updatedBy"`
 
@@ -261,9 +276,6 @@ type SearchListDisks []ItemDisk
 
 // Main information about unattached disk
 type ItemUnattachedDisk struct {
-	// CKey
-	CKey string `json:"_ckey"`
-
 	// Meta
 	Meta []interface{} `json:"_meta"`
 
@@ -313,14 +325,6 @@ type ItemSnapshot struct {
 // List snapshots
 type ListSnapshots []ItemSnapshot
 
-type ListTypes struct {
-	// Data
-	Data []interface{} `json:"data"`
-
-	// Entry count
-	EntryCount uint64 `json:"entryCount"`
-}
-
 type MigrateStatus struct {
 	// Type
 	Type int `json:"type"`

pkg/cloudbroker/disks/update.go

@@ -0,0 +1,50 @@
+package disks
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// UpdateRequest struct to update disk
+type UpdateRequest struct {
+	// ID of the disk to update
+	// Required: true
+	DiskID uint64 `url:"disk_id" json:"disk_id" validate:"required"`
+
+	// Cache mode of disk
+	// Required: false
+	Cache string `url:"cache,omitempty" json:"cache,omitempty"`
+
+	// BLK Discard
+	// Required: false
+	BLKDiscard interface{} `url:"blkdiscard,omitempty" json:"blkdiscard,omitempty" validate:"omitempty,isBool"`
+
+	// Block size of disk
+	// Required: false
+	BlockSize string `url:"block_size,omitempty" json:"block_size,omitempty"`
+}
+
+// Update updates disk
+func (d Disks) Update(ctx context.Context, req UpdateRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/disks/update"
+
+	res, err := d.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/flipgroup/list.go

@@ -34,10 +34,6 @@ type ListRequest struct {
 	// Required: false
 	AccountId uint64 `url:"accountId,omitempty" json:"accountId,omitempty"`
 
-	// Find by resource group ID
-	// Required: false
-	RGID uint64 `url:"rgId,omitempty" json:"rgId,omitempty"`
-
 	// Find by id
 	// Required: false
 	ByID uint64 `url:"by_id,omitempty" json:"by_id,omitempty"`

pkg/cloudbroker/flipgroup/models.go

@@ -85,12 +85,6 @@ type RecordFLIPGroup struct {
 	// Network
 	Network string `json:"network"`
 
-	// Resource group ID
-	RGID uint64 `json:"rgId"`
-
-	// Resource group name
-	RGName string `json:"rgName"`
-
 	// Status
 	Status string `json:"status"`
 

pkg/cloudbroker/grid/purge_logs.go

@@ -15,8 +15,8 @@ type PurgeLogsRequest struct {
 	GID uint64 `url:"gid" json:"gid" validate:"required"`
 
 	// Age of the records to remove, e.g. -1h for records older than 1 hour, -1w - one week, etc
-	// Required: true
-	Age string `url:"age" json:"age" validate:"required"`
+	// Required: false
+	Age string `url:"age,omitempty" json:"age,omitempty"`
 }
 
 // PurgeLogs clear Log and ECO records that are older than the specified age.

pkg/cloudbroker/image/create_multi_image.go

@@ -0,0 +1,47 @@
+package image
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// CreateMultiImageRequest struct to create multi image
+type CreateMultiImageRequest struct {
+	// Name of the multi image
+	// Required: true
+	Name string `url:"name" json:"name" validate:"required"`
+
+	// IDs of real images
+	// Required: true
+	TargetIDs []uint64 `url:"target_ids" json:"target_ids" validate:"required"`
+
+	// Account ID
+	// Required: false
+	AccountID uint64 `url:"account_id,omitempty" json:"account_id,omitempty"`
+}
+
+// CreateMultiImage creates multi image
+func (i Image) CreateMultiImage(ctx context.Context, req CreateMultiImageRequest) (uint64, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return 0, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/image/create_multi_image"
+
+	res, err := i.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
+	if err != nil {
+		return 0, err
+	}
+
+	result, err := strconv.ParseUint(string(res), 10, 64)
+	if err != nil {
+		return 0, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/image/edit.go

@@ -39,11 +39,11 @@ type EditRequest struct {
 
 	// Does this machine supports hot resize
 	// Required: false
-	HotResize bool `url:"hotresize,omitempty" json:"hotresize,omitempty"`
+	HotResize interface{} `url:"hotresize,omitempty" json:"hotresize,omitempty" validate:"omitempty,isBool"`
 
 	// Does this image boot OS
 	// Required: false
-	Bootable bool `url:"bootable,omitempty" json:"bootable,omitempty"`
+	Bootable interface{} `url:"bootable,omitempty" json:"bootable,omitempty" validate:"omitempty,isBool"`
 }
 
 // Edit edits an existing image

pkg/cloudbroker/image/models.go

@@ -53,12 +53,18 @@ type RecordImage struct {
 	// ID
 	ID uint64 `json:"id"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// Last modified
 	LastModified uint64 `json:"lastModified"`
 
 	// Link to
 	LinkTo uint64 `json:"linkTo"`
 
+	// Links to
+	LinksTo []uint64 `json:"linksTo"`
+
 	// Milestones
 	Milestones uint64 `json:"milestones"`
 
@@ -185,12 +191,18 @@ type ItemImage struct {
 	// ID
 	ID uint64 `json:"id"`
 
+	// Independent
+	Independent bool `json:"independent"`
+
 	// Last modified
 	LastModified uint64 `json:"lastModified"`
 
 	// Link to
 	LinkTo uint64 `json:"linkTo"`
 
+	// Links to
+	LinksTo []uint64 `json:"linksTo"`
+
 	// Milestones
 	Milestones uint64 `json:"milestones"`
 

pkg/cloudbroker/image/multi_image_add_links.go

@@ -0,0 +1,43 @@
+package image
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// MultiImageAddLinksRequest struct to add links to multi image
+type MultiImageAddLinksRequest struct {
+	// ID of the multi image
+	// Required: true
+	ImageID uint64 `url:"image_id" json:"image_id" validate:"required"`
+
+	// IDs of real images
+	// Required: true
+	TargetIDs []uint64 `url:"target_ids" json:"target_ids" validate:"required"`
+}
+
+// MultiImageAddLinks adds image links to multi image
+func (i Image) MultiImageAddLinks(ctx context.Context, req MultiImageAddLinksRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/image/multi_image_add_links"
+
+	res, err := i.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/image/multi_image_del_links.go

@@ -0,0 +1,43 @@
+package image
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// MultiImageDelLinksRequest struct to delete links from multi image
+type MultiImageDelLinksRequest struct {
+	// ID of the multi image
+	// Required: true
+	ImageID uint64 `url:"image_id" json:"image_id" validate:"required"`
+
+	// IDs of real images
+	// Required: true
+	TargetIDs []uint64 `url:"target_ids" json:"target_ids" validate:"required"`
+}
+
+// MultiImageDelLinks removes image links from multi image
+func (i Image) MultiImageDelLinks(ctx context.Context, req MultiImageDelLinksRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/image/multi_image_del_links"
+
+	res, err := i.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/image/multi_image_export.go

@@ -0,0 +1,46 @@
+package image
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// MultiImageExportRequest struct to export multi image to a pool
+type MultiImageExportRequest struct {
+	// ID of the multi image
+	// Required: true
+	MultiImageID uint64 `url:"multi_image_id" json:"multi_image_id" validate:"required"`
+
+	// Name of the target pool
+	// Required: true
+	PoolName string `url:"pool_name" json:"pool_name" validate:"required"`
+
+	// Target SEP ID
+	// Required: true
+	SEPID uint64 `url:"sep_id" json:"sep_id" validate:"required"`
+}
+
+// MultiImageExport copies a physical image from multi image to the specified pool
+func (i Image) MultiImageExport(ctx context.Context, req MultiImageExportRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/image/multi_image_export"
+
+	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/kvmx86/create.go

@@ -28,8 +28,8 @@ type Interface struct {
 	// Required: false
 	IPAddr string `url:"ipAddr,omitempty" json:"ipAddr,omitempty"`
 
-	// Maximum transmission unit, must be 1-9216
-	// Used only to DPDK net type
+	// Used for EXTNET, TRUNK and DPDK
+	// Must be 1500-9216
 	// Required: false
 	MTU uint64 `url:"mtu,omitempty" json:"mtu,omitempty" validate:"omitempty,mtu"`
 
@@ -57,6 +57,22 @@ type Interface struct {
 	// Flag indicating whether this interface is enabled (only for VINS, EXTNET, DPDK, SDN, TRUNK)
 	// Required: false
 	Enabled interface{} `url:"enabled,omitempty" json:"enabled,omitempty" validate:"omitempty,isBool"`
+
+	// SDN Segment ID
+	// Required: false
+	SDNSegmentID string `url:"sdn_segment_id,omitempty" json:"sdn_segment_id,omitempty"`
+
+	// SDN Object Group ID
+	// Required: false
+	SDNObjectGroupID string `url:"sdn_object_group_id,omitempty" json:"sdn_object_group_id,omitempty"`
+
+	// SDN Logical Port Display Name
+	// Required: false
+	SDNLogicalPortDisplayName string `url:"sdn_logical_port_display_name,omitempty" json:"sdn_logical_port_display_name,omitempty"`
+
+	// SDN Logical Port Description
+	// Required: false
+	SDNLogicalPortDescription string `url:"sdn_logical_port_description,omitempty" json:"sdn_logical_port_description,omitempty"`
 }
 
 // DataDisk detailed struct for DataDisks field in CreateRequest, CreateBlankRequest and MassCreateRequest
@@ -90,6 +106,14 @@ type DataDisk struct {
 	// Specify image id for create disk from template
 	// Required: false
 	ImageID uint64 `url:"imageId,omitempty" json:"imageId,omitempty"`
+
+	// Cache mode for disk
+	// Required: false
+	Cache string `url:"cache,omitempty" json:"cache,omitempty"`
+
+	// BLK Discard
+	// Required: false
+	BLKDiscard interface{} `url:"blkdiscard,omitempty" json:"blkdiscard,omitempty" validate:"omitempty,isBool"`
 }
 
 // CreateRequest struct to create KVM x86 VM
@@ -169,14 +193,6 @@ type CreateRequest struct {
 	// Required: false
 	NodeID uint64 `url:"node_id,omitempty" json:"node_id,omitempty"`
 
-	// System name
-	// Required: false
-	IS string `url:"IS,omitempty" json:"IS,omitempty"`
-
-	// Compute purpose
-	// Required: false
-	IPAType string `url:"ipaType,omitempty" json:"ipaType,omitempty"`
-
 	// Custom fields for Compute. Must be dict
 	// Required: false
 	CustomField string `url:"customFields,omitempty" json:"customFields,omitempty"`
@@ -211,6 +227,19 @@ type CreateRequest struct {
 	// Zone ID
 	// Required: false
 	ZoneID uint64 `url:"zoneId,omitempty" json:"zoneId,omitempty"`
+
+	// Cache mode for boot disk
+	// Required: false
+	BootDiskCache string `url:"boot_disk_cache,omitempty" json:"boot_disk_cache,omitempty"`
+
+	// Boot Disk BLK Discard
+	// Required: false
+	BootDiskBLKDiscard interface{} `url:"boot_disk_blkdiscard,omitempty" json:"boot_disk_blkdiscard,omitempty" validate:"omitempty,isBool"`
+
+	// Priority weight of the VM: higher value means higher priority and later migration
+	// Required: false
+	// Default: 1
+	Weight uint64 `url:"weight,omitempty" json:"weight,omitempty"`
 }
 
 // GetRAM returns RAM field values

pkg/cloudbroker/kvmx86/create_blank.go

@@ -115,6 +115,19 @@ type CreateBlankRequest struct {
 	// The OS version that will be installed on the virtual machine
 	// Required: false
 	OSVersion string `url:"os_version,omitempty" json:"os_version,omitempty"`
+
+	// Cache mode for boot disk
+	// Required: false
+	BootDiskCache string `url:"boot_disk_cache,omitempty" json:"boot_disk_cache,omitempty"`
+
+	// Boot Disk BLK Discard
+	// Required: false
+	BootDiskBLKDiscard interface{} `url:"boot_disk_blkdiscard" json:"boot_disk_blkdiscard" validate:"omitempty,isBool"`
+
+	// Priority weight of the VM: higher value means higher priority and later migration
+	// Required: false
+	// Default: 1
+	Weight uint64 `url:"weight,omitempty" json:"weight,omitempty"`
 }
 
 // GetRAM returns RAM field values

pkg/cloudbroker/kvmx86/mass_create.go

@@ -14,17 +14,21 @@ type InterfaceMassCreate struct {
 	//	- VINS
 	//	- EXTNET
 	//  - TRUNK
+	//  - SDN
+	// For SDN, one of the fields sdn_interface_id or sdn_segment_id is specified, but not both at the same time
+	// Required: false
 	NetType string `url:"netType" json:"netType" validate:"required,massCreateNetType"`
 
 	// Network ID for connect
+	// Required: false
 	NetID uint64 `url:"netId" json:"netId" validate:"required"`
 
 	// IP address to assign to this VM when connecting to the specified network
 	// Required: false
 	IPAddr string `url:"ipAddr,omitempty" json:"ipAddr,omitempty"`
 
-	// Maximum transmission unit, must be 1-9216
-	// Used only to DPDK net type
+	// Used for EXTNET, TRUNK and DPDK
+	// Must be 1500-9216
 	// Required: false
 	MTU uint64 `url:"mtu,omitempty" json:"mtu,omitempty" validate:"omitempty,mtu"`
 
@@ -47,6 +51,22 @@ type InterfaceMassCreate struct {
 	// Flag indicating whether this interface is enabled (only for VINS, EXTNET, DPDK, SDN, TRUNK)
 	// Required: false
 	Enabled interface{} `url:"enabled,omitempty" json:"enabled,omitempty" validate:"omitempty,isBool"`
+
+	// SDN Segment ID
+	// Required: false
+	SDNSegmentID string `url:"sdn_segment_id,omitempty" json:"sdn_segment_id,omitempty"`
+
+	// SDN Object Group ID
+	// Required: false
+	SDNObjectGroupID string `url:"sdn_object_group_id,omitempty" json:"sdn_object_group_id,omitempty"`
+
+	// SDN Logical Port Display Name
+	// Required: false
+	SDNLogicalPortDisplayName string `url:"sdn_logical_port_display_name,omitempty" json:"sdn_logical_port_display_name,omitempty"`
+
+	// SDN Logical Port Description
+	// Required: false
+	SDNLogicalPortDescription string `url:"sdn_logical_port_description,omitempty" json:"sdn_logical_port_description,omitempty"`
 }
 
 // MassCreateRequest struct to mass create KVM x86
@@ -132,6 +152,19 @@ type MassCreateRequest struct {
 	// The OS version that will be installed on the virtual machine
 	// Required: false
 	OSVersion string `url:"os_version,omitempty" json:"os_version,omitempty"`
+
+	// Cache mode for boot disk
+	// Required: false
+	BootDiskCache string `url:"boot_disk_cache,omitempty" json:"boot_disk_cache,omitempty"`
+
+	// Boot Disk BLK Discard
+	// Required: false
+	BootDiskBLKDiscard interface{} `url:"boot_disk_blkdiscard" json:"boot_disk_blkdiscard" validate:"omitempty,isBool"`
+
+	// Priority weight of the VM: higher value means higher priority and later migration
+	// Required: false
+	// Default: 1
+	Weight uint64 `url:"weight,omitempty" json:"weight,omitempty"`
 }
 
 type asyncWrapperMassCreateRequest struct {

pkg/cloudbroker/lb/create.go

@@ -30,8 +30,8 @@ type CreateRequest struct {
 	VINSID uint64 `url:"vinsId" json:"vinsId"`
 
 	// Start now Load balancer
-	// Required: true
-	Start bool `url:"start" json:"start" validate:"required"`
+	// Required: false
+	Start interface{} `url:"start,omitempty" json:"start,omitempty" validate:"omitempty,isBool"`
 
 	// Custom  sysctl values for Load Balancer instance. Applied on boot
 	// Required: false

pkg/cloudbroker/node/autostart.go

@@ -0,0 +1,42 @@
+package node
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// AutoStartRequest struct to set node autostart
+type AutoStartRequest struct {
+	// Node ID
+	// Required: true
+	NodeID uint64 `url:"node_id" json:"node_id" validate:"required"`
+
+	// Auto start
+	// Required: true
+	AutoStart bool `url:"autostart" json:"autostart" validate:"required"`
+}
+
+// AutoStart sets node autostart
+func (n Node) AutoStart(ctx context.Context, req AutoStartRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/node/autostart"
+
+	res, err := n.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/node/enable.go

@@ -18,7 +18,7 @@ type EnableRequest struct {
 	Message string `url:"message,omitempty" json:"message,omitempty"`
 
 	// Do not check locks, iscsi-sessions or disk-present
-	// Default: true
+	// Default: false
 	// Required: false
 	Force interface{} `url:"force" json:"force" validate:"isBool"`
 
@@ -41,7 +41,7 @@ func (n Node) Enable(ctx context.Context, req EnableRequest) (string, error) {
 	}
 
 	if req.Force == nil {
-		req.Force = true
+		req.Force = false
 	}
 
 	reqWrapped := wrapperEnableRequest{
@@ -67,7 +67,7 @@ func (n Node) EnableAsync(ctx context.Context, req EnableRequest) (string, error
 	}
 
 	if req.Force == nil {
-		req.Force = true
+		req.Force = false
 	}
 
 	reqWrapped := wrapperEnableRequest{

pkg/cloudbroker/node/get_logical_cores_count.go

@@ -13,6 +13,10 @@ type GetLogicalCoresCountRequest struct {
 	// Node ID
 	// Required: true
 	NodeId uint64 `url:"node_id" json:"node_id" validate:"required"`
+
+	// Target
+	// Required: false
+	Target string `url:"target,omitempty" json:"target,omitempty" validate:"omitempty,oneof=core node"`
 }
 
 // GetLogicalCoresCount get logical cores count by node
@@ -24,7 +28,7 @@ func (i Node) GetLogicalCoresCount(ctx context.Context, req GetLogicalCoresCount
 
 	url := "/cloudbroker/node/get_logical_cores_count"
 
-	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := i.client.DecortApiCall(ctx, http.MethodGet, url, req)
 	if err != nil {
 		return 0, err
 	}

pkg/cloudbroker/node/list.go

@@ -49,6 +49,10 @@ type ListRequest struct {
 	// Page size
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
+
+	// Find by zone ID
+	// Required: false
+	ZoneID uint64 `url:"zone_id,omitempty" json:"zone_id,omitempty"`
 }
 
 // List gets list of all nodes as a ListNodes struct

pkg/cloudbroker/node/maintenance.go

@@ -26,6 +26,11 @@ type MaintenanceRequest struct {
 	// Reason
 	// Required: false
 	Reason string `url:"reason,omitempty" json:"reason,omitempty"`
+
+	// Allow node auto-enable
+	// Default: false
+	// Required: false
+	AutoStart bool `url:"autostart" json:"autostart"`
 }
 
 // Maintenance places node in maintenance state

pkg/cloudbroker/node/models.go

@@ -26,6 +26,9 @@ type RecordNode struct {
 	// Isolated Cpus
 	IsolatedCpus []interface{} `json:"isolatedCpus"`
 
+	// MemAllocationRatio
+	MemAllocationRatio float64 `json:"mem_allocation_ratio"`
+
 	// Name
 	Name string `json:"name"`
 
@@ -85,6 +88,12 @@ type RecordNode struct {
 
 	// CPU used by the node
 	UsableCPUs []string `json:"usable_cpus"`
+
+	// AutoStart
+	AutoStart bool `json:"autostart"`
+
+	// AutoStart Count
+	AutoStartCount uint64 `json:"autostart_count"`
 }
 
 // Resource consumption of the node
@@ -111,7 +120,7 @@ type FreeResourcesInfo struct {
 	RAM float64 `json:"RAM"`
 
 	// VCPU
-	VCPU uint64 `json:"vCPUs"`
+	VCPU float64 `json:"vCPUs"`
 }
 
 // Resources Info
@@ -146,6 +155,9 @@ type CpuInfo struct {
 	// PhysCount
 	PhysCount uint64 `json:"physCount"`
 
+	// Thread count
+	ThreadCount uint64 `json:"threadCount"`
+
 	// Flags
 	Flags []string `json:"flags"`
 
@@ -301,6 +313,12 @@ type ItemNode struct {
 
 	// CPU used by the node
 	UsableCPUs []string `json:"usable_cpus"`
+
+	// AutoStart
+	AutoStart bool `json:"autostart"`
+
+	// AutoStart Count
+	AutoStartCount uint64 `json:"autostart_count"`
 }
 
 type PackageInfo struct {

pkg/cloudbroker/resource_optimizer.go

@@ -0,0 +1,10 @@
+package cloudbroker
+
+import (
+	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/resource_optimizer"
+)
+
+// Accessing the ResourceOptimizer method group
+func (cb *CloudBroker) ResourceOptimizer() *resource_optimizer.ResourceOptimizer {
+	return resource_optimizer.New(cb.client)
+}

pkg/cloudbroker/resource_optimizer/drs_add_nodes.go

@@ -0,0 +1,42 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSAddNodesRequest struct to add nodes to DRS
+type DRSAddNodesRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+
+	// IDs of the nodes to add
+	// Required: true
+	NodeIDs []uint64 `url:"node_ids" json:"node_ids" validate:"required"`
+}
+
+// DRSAddNodes adds nodes to DRS in the specified zone
+func (ro ResourceOptimizer) DRSAddNodes(ctx context.Context, req DRSAddNodesRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_add_nodes"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_create.go

@@ -0,0 +1,58 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSCreateRequest struct to create DRS
+type DRSCreateRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+
+	// Application ID
+	// Required: true
+	AppID string `url:"app_id" json:"app_id" validate:"required"`
+
+	// Application secret
+	// Required: true
+	AppSecret string `url:"app_secret" json:"app_secret" validate:"required"`
+
+	// Decort URL
+	// Required: true
+	DecortURL string `url:"decort_url" json:"decort_url" validate:"required"`
+
+	// SSO URL
+	// Required: true
+	SSOURL string `url:"sso_url" json:"sso_url" validate:"required"`
+
+	// DRS name
+	// Required: true
+	DRSName string `url:"drs_name" json:"drs_name" validate:"required"`
+}
+
+// DRSCreate creates a new DRS in the specified zone
+func (ro ResourceOptimizer) DRSCreate(ctx context.Context, req DRSCreateRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_create"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_del_nodes.go

@@ -0,0 +1,42 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSDelNodesRequest struct to delete nodes from DRS
+type DRSDelNodesRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+
+	// IDs of the nodes to delete
+	// Required: true
+	NodeIDs []uint64 `url:"node_ids" json:"node_ids" validate:"required"`
+}
+
+// DRSDelNodes removes nodes from DRS in the specified zone
+func (ro ResourceOptimizer) DRSDelNodes(ctx context.Context, req DRSDelNodesRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_del_nodes"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_remove.go

@@ -0,0 +1,38 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSRemoveRequest struct to remove DRS
+type DRSRemoveRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+}
+
+// DRSRemove removes DRS from the specified zone
+func (ro ResourceOptimizer) DRSRemove(ctx context.Context, req DRSRemoveRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_remove"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_start.go

@@ -0,0 +1,38 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSStartRequest struct to start DRS
+type DRSStartRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+}
+
+// DRSStart starts DRS in the specified zone
+func (ro ResourceOptimizer) DRSStart(ctx context.Context, req DRSStartRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_start"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_stop.go

@@ -0,0 +1,38 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSStopRequest struct to stop DRS
+type DRSStopRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+}
+
+// DRSStop stops DRS in the specified zone
+func (ro ResourceOptimizer) DRSStop(ctx context.Context, req DRSStopRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_stop"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/drs_update.go

@@ -0,0 +1,58 @@
+package resource_optimizer
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DRSUpdateRequest struct to update DRS
+type DRSUpdateRequest struct {
+	// ID of the zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+
+	// Application ID
+	// Required: false
+	AppID string `url:"app_id,omitempty" json:"app_id,omitempty"`
+
+	// Application secret
+	// Required: false
+	AppSecret string `url:"app_secret,omitempty" json:"app_secret,omitempty"`
+
+	// Decort URL
+	// Required: false
+	DecortURL string `url:"decort_url,omitempty" json:"decort_url,omitempty"`
+
+	// SSO URL
+	// Required: false
+	SSOURL string `url:"sso_url,omitempty" json:"sso_url,omitempty"`
+
+	// DRS name
+	// Required: false
+	DRSName string `url:"drs_name,omitempty" json:"drs_name,omitempty"`
+}
+
+// DRSUpdate updates DRS configuration in the specified zone
+func (ro ResourceOptimizer) DRSUpdate(ctx context.Context, req DRSUpdateRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/resource_optimizer/drs_update"
+
+	res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/resource_optimizer/resource_optimizer.go

@@ -0,0 +1,16 @@
+// API Actor API for managing resource optimizer
+package resource_optimizer
+
+import "repository.basistech.ru/BASIS/decort-golang-sdk/interfaces"
+
+// Structure for creating request to resource_optimizer
+type ResourceOptimizer struct {
+	client interfaces.Caller
+}
+
+// Builder for resource_optimizer endpoints
+func New(client interfaces.Caller) *ResourceOptimizer {
+	return &ResourceOptimizer{
+		client: client,
+	}
+}

pkg/cloudbroker/rg/models.go

@@ -66,7 +66,7 @@ type ItemResourceConsumption struct {
 	ResourceLimits ResourceLimits `json:"resourceLimits"`
 
 	// Resource group ID
-	RGID uint64 `json:"rgid"`
+	RGID uint64 `json:"id"`
 }
 
 type ListResourceConsumption struct {
@@ -79,6 +79,9 @@ type ListResourceConsumption struct {
 
 // Access Control List
 type ACL struct {
+	// Email
+	Email string `json:"email"`
+
 	// Explicit
 	Explicit bool `json:"explicit"`
 

pkg/cloudbroker/rg/update.go

@@ -51,6 +51,10 @@ type UpdateRequest struct {
 	// Storage policies
 	// Required: false
 	StoragePolicies []StoragePolicy `url:"-" json:"storage_policies,omitempty"`
+
+	// CPU allocation parameter
+	// Required: false
+	CPUAllocationParameter string `url:"cpu_allocation_parameter,omitempty" json:"cpu_allocation_parameter,omitempty"`
 }
 
 // Update updates resource group

pkg/cloudbroker/sep/add_consumer_nodes.go

@@ -20,22 +20,22 @@ type AddConsumerNodesRequest struct {
 }
 
 // AddConsumerNodes adds consumer nodes to SEP parameters
-func (s SEP) AddConsumerNodes(ctx context.Context, req AddConsumerNodesRequest) (bool, error) {
+func (s SEP) AddConsumerNodes(ctx context.Context, req AddConsumerNodesRequest) (uint64, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return 0, validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudbroker/sep/addConsumerNodes"
 
 	res, err := s.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
-		return false, err
+		return 0, err
 	}
 
-	result, err := strconv.ParseBool(string(res))
+	result, err := strconv.ParseUint(string(res), 10, 64)
 	if err != nil {
-		return false, err
+		return 0, err
 	}
 
 	return result, nil

pkg/cloudbroker/sep/add_provider_nodes.go

@@ -20,22 +20,22 @@ type AddProviderNodesRequest struct {
 }
 
 // AddProviderNodes adds provider nodes to SEP parameters
-func (s SEP) AddProviderNodes(ctx context.Context, req AddProviderNodesRequest) (bool, error) {
+func (s SEP) AddProviderNodes(ctx context.Context, req AddProviderNodesRequest) (uint64, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return false, validators.ValidationErrors(validators.GetErrors(err))
+		return 0, validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudbroker/sep/addProviderNodes"
 
 	res, err := s.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
-		return false, err
+		return 0, err
 	}
 
-	result, err := strconv.ParseBool(string(res))
+	result, err := strconv.ParseUint(string(res), 10, 64)
 	if err != nil {
-		return false, err
+		return 0, err
 	}
 
 	return result, nil

pkg/cloudbroker/sep/create.go

@@ -20,7 +20,7 @@ type CreateRequest struct {
 
 	// Type of storage
 	// Required: true
-	SEPType string `url:"sep_type" json:"sep_type" validate:"required"`
+	SEPType string `url:"sep_type" json:"sep_type" validate:"required,sepType"`
 
 	// SEP config
 	// Required: true
@@ -30,14 +30,6 @@ type CreateRequest struct {
 	// Required: false
 	Description string `url:"description,omitempty" json:"description,omitempty"`
 
-	// List of provider node IDs
-	// Required: false
-	ProviderNIDs []uint64 `url:"provider_nids,omitempty" json:"provider_nids,omitempty"`
-
-	// List of consumer node IDs
-	// Required: false
-	ConsumerNIDs []uint64 `url:"consumer_nids,omitempty" json:"consumer_nids,omitempty"`
-
 	// Enable SEP after creation
 	// Required: false
 	Enable bool `url:"enable,omitempty" json:"enable,omitempty"`

pkg/cloudbroker/sep/del_consumer_nodes.go

@@ -20,8 +20,8 @@ type DelConsumerNodesRequest struct {
 
 	// The force flag must be set to true only if the node will never come back online
 	// Default: false
-	// Required: true
-	Force bool `url:"force" json:"force" validate:"required"`
+	// Required: false
+	Force bool `url:"force" json:"force"`
 }
 
 // DelConsumerNodes excludes consumer nodes from SEP parameters

pkg/cloudbroker/stpolicy/models.go

@@ -22,8 +22,8 @@ type InfoStoragePolicyWithID struct {
 	// Max IOPS for the sotrage policy
 	LimitIOPS uint64 `json:"limit_iops"`
 
-	// ID of the storage policy
-	StoragePolicyID uint64 `json:"storage_policy_id"`
+	// Which accounts and resource groups use the storage policy
+	Usage Usage `json:"usage"`
 }
 
 type ListStoragePolicies struct {

pkg/cloudbroker/stpolicy/update.go

@@ -15,8 +15,8 @@ type UpdateRequest struct {
 	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
 
 	// List of storage endpoint access objects
-	// Required: true
-	AccessSEPsPools []AccessSEPsPool `url:"access_seps_pools" json:"access_seps_pools" validate:"required"`
+	// Required: false
+	AccessSEPsPools []AccessSEPsPool `url:"access_seps_pools,omitempty" json:"access_seps_pools,omitempty"`
 
 	// New name for the storage policy
 	// Required: false

pkg/cloudbroker/trunk/update.go

@@ -15,12 +15,12 @@ type UpdateRequest struct {
 	TrunkID uint64 `url:"id" json:"id" validate:"required"`
 
 	// New name of the trunk
-	// Required: true
-	Name string `url:"name" json:"name" validate:"required"`
+	// Required: false
+	Name string `url:"name,omitempty" json:"name,omitempty"`
 
 	// List of trunk tags (values between 1-4095)
-	// Required: true
-	TrunkTags string `url:"trunk_tags" json:"trunk_tags" validate:"required,trunkTags"`
+	// Required: false
+	TrunkTags string `url:"trunk_tags,omitempty" json:"trunk_tags,omitempty" validate:"omitempty,trunkTags"`
 
 	// New description of the trunk
 	// Required: false

pkg/cloudbroker/user/get_matching_usernames.go

@@ -15,8 +15,8 @@ type GetMatchingUsernamesRequest struct {
 	UsernameRegex string `url:"usernameregex" json:"usernameregex" validate:"required"`
 
 	// The number of usernames to return.
-	// Required: true
-	Limit uint64 `url:"limit" json:"limit" validate:"required"`
+	// Required: false
+	Limit uint64 `url:"limit,omitempty" json:"limit,omitempty"`
 }
 
 // GetMatchingUsernames gets a list of the matching usernames for a given string.

pkg/cloudbroker/zone/create.go

@@ -17,6 +17,14 @@ type CreateRequest struct {
 	// Description
 	// Required: false
 	Description string `url:"description,omitempty" json:"description,omitempty"`
+
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	// Required: false
+	AutoStart interface{} `url:"autostart,omitempty" json:"autostart,omitempty" validate:"omitempty,isBool"`
+
+	// Enables Distributed Resource Scheduler (DRS) functionality for the zone
+	// Required: false
+	DRS interface{} `url:"drs,omitempty" json:"drs,omitempty" validate:"omitempty,isBool"`
 }
 
 // Create creates zone object

pkg/cloudbroker/zone/filter.go

@@ -2,7 +2,7 @@ package zone
 
 // FilterByID returns ListZones with specified ID.
 func (list ListZones) FilterByID(id uint64) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.ID == id
 	}
 
@@ -11,7 +11,7 @@ func (list ListZones) FilterByID(id uint64) ListZones {
 
 // FilterByName returns ListZones with specified Name.
 func (list ListZones) FilterByName(name string) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.Name == name
 	}
 
@@ -20,7 +20,7 @@ func (list ListZones) FilterByName(name string) ListZones {
 
 // FilterByStatus returns ListZones with specified Status.
 func (list ListZones) FilterByStatus(status string) ListZones {
-	predicate := func(izone RecordZone) bool {
+	predicate := func(izone ItemZone) bool {
 		return izone.Status == status
 	}
 
@@ -28,7 +28,7 @@ func (list ListZones) FilterByStatus(status string) ListZones {
 }
 
 // FilterFunc allows filtering ListZones based on a user-specified predicate.
-func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
+func (list ListZones) FilterFunc(predicate func(ItemZone) bool) ListZones {
 	var result ListZones
 
 	for _, item := range list.Data {
@@ -42,11 +42,11 @@ func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
 	return result
 }
 
-// FindOne returns first found RecordZone
+// FindOne returns first found ItemZone
 // If none was found, returns an empty struct.
-func (list ListZones) FindOne() RecordZone {
+func (list ListZones) FindOne() ItemZone {
 	if list.EntryCount == 0 {
-		return RecordZone{}
+		return ItemZone{}
 	}
 
 	return list.Data[0]

pkg/cloudbroker/zone/filter_test.go

@@ -3,7 +3,7 @@ package zone
 import "testing"
 
 var zones = ListZones{
-	Data: []RecordZone{
+	Data: []ItemZone{
 
 		{
 			ID:          2,
@@ -76,7 +76,7 @@ func TestFilterByStatus(t *testing.T) {
 }
 
 func TestFilterFunc(t *testing.T) {
-	actual := zones.FilterFunc(func(ien RecordZone) bool {
+	actual := zones.FilterFunc(func(ien ItemZone) bool {
 		return ien.Deletable == true
 	})
 

pkg/cloudbroker/zone/models.go

@@ -5,11 +5,14 @@ type ListZones struct {
 	EntryCount uint64 `json:"entryCount"`
 
 	// Data
-	Data []RecordZone `json:"data"`
+	Data []ItemZone `json:"data"`
 }
 
 // Detailed information about the zone record
 type RecordZone struct {
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	AutoStart bool `json:"autostart"`
+
 	// ID
 	ID uint64 `json:"id"`
 
@@ -60,4 +63,76 @@ type RecordZone struct {
 
 	// List of associated VINS IDs
 	VinsIDs []uint64 `json:"vinsIds"`
+
+	// DRS
+	DRS bool `json:"drs"`
+
+	// DRS UID
+	DRSUID string `json:"drs_uid"`
+
+	// App ID
+	AppID string `json:"app_id"`
+
+	// Decort URL
+	DecortURL string `json:"decort_url"`
+
+	// DRS Name
+	DRSName string `json:"drs_name"`
+
+	// SSO URL
+	SSOURL string `json:"sso_url"`
+}
+
+// A zone item from a list
+type ItemZone struct {
+	// App ID
+	AppID string `json:"app_id"`
+
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	AutoStart bool `json:"autostart"`
+
+	// Created timestamp
+	CreatedTime uint64 `json:"createdTime"`
+
+	// Decort URL
+	DecortURL string `json:"decort_url"`
+
+	// Deletable flag
+	Deletable bool `json:"deletable"`
+
+	// Description
+	Description string `json:"description"`
+
+	// DRS
+	DRS bool `json:"drs"`
+
+	// DRS Name
+	DRSName string `json:"drs_name"`
+
+	// DRS UID
+	DRSUID string `json:"drs_uid"`
+
+	// GID
+	GID uint64 `json:"gid"`
+
+	// GUID
+	GUID uint64 `json:"guid"`
+
+	// ID
+	ID uint64 `json:"id"`
+
+	// Name
+	Name string `json:"name"`
+
+	// List of associated Node IDs
+	NodeIDs []uint64 `json:"nodeIds"`
+
+	// SSO URL
+	SSOURL string `json:"sso_url"`
+
+	// Status
+	Status string `json:"status"`
+
+	// Updated timestamp
+	UpdatedTime uint64 `json:"updatedTime"`
 }

pkg/cloudbroker/zone/node_autostart.go

@@ -0,0 +1,43 @@
+package zone
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// NodeAutoStartRequest struct to set node autostart in zone
+type NodeAutoStartRequest struct {
+	// ID of zone
+	// Required: true
+	ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
+
+	// AutoStart nodes in zone
+	// Required: true
+	AutoStart bool `url:"autostart" json:"autostart" validate:"required"`
+}
+
+// NodeAutoStart sets node autostart in zone
+func (e Zone) NodeAutoStart(ctx context.Context, req NodeAutoStartRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/zone/node_autostart"
+
+	res, err := e.client.DecortApiCall(ctx, http.MethodPost, url, req)
+
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/zone/update.go

@@ -21,6 +21,10 @@ type UpdateRequest struct {
 	// Description
 	// Required: false
 	Description string `url:"description,omitempty" json:"description,omitempty"`
+
+	// If true, all nodes belonging to the given zone will be marked for autostart
+	// Required: false
+	AutoStart interface{} `url:"autostart,omitempty" json:"autostart,omitempty" validate:"omitempty,isBool"`
 }
 
 // Update updates zone object