v1.12.8

CHANGELOG.md

@@ -1,75 +1,12 @@
-## Version 1.12.3
+## Version 1.12.8
 
-### Добавлено
-
-#### account
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-606 | Поле `policies` в структуру ответа `Resource` в cloudapi/account и в cloudbroker/account |
-
-#### compute
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-603 | Поле `OSVersion` в структуры ответа `RecordCompute` и `ItemCompute` в cloudapi/compute и `RecordCompute` и `InfoCompute` в cloudbroker/compute |
-| BGOS-603 | Опциональное поле `OSVersion` в структуры запроса `RedeployRequest` и `UpdateRequest` в cloudapi/compute и cloudbroker/compute |
-| BGOS-611 | Методы `StartMigrationIN`, `StopMigrationIN`, `MigrateStorageList` и структуры запросов `StartMigrationINRequest`, `StopMigrationINRequest` и `MigrateStorageListRequest` в cloudbroker/compute |
-
-#### disks
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-609 | Опциональное поле `StoragePolicyID` в структуры запроса `ListUnattachedRequest` и `ListRequest` в cloudapi/disk и cloudbroker/disk |
-
-#### kvmx86
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-603 | Опциональное поле `OSVersion` в структуры запроса `CreateRequest` и `CreateBlankRequest` в cloudapi/compute и cloudbroker/compute |
-| BGOS-603 | Опциональное поле `OSVersion` в структуру запроса `MassCreateRequest` в cloudbroker/compute |
-
-#### node
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-608 | Методы `AddSSHIdentity`, `GetSSHIdentity` и структуры запросов `AddSSHIdentityRequest` и `GetSSHIdentityRequest` в cloudbroker/node |
-
-#### security group
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-601 | Добавлены комментарии к структурам ответов |
-
-#### storage policy
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-598 | Поле `sep_name` в структуре ответа `AccessSEPPool` в cloudapi/stpolicy и в cloudbroker/stpolicy |
-| BGOS-600 | Добавлены комментарии к структурам ответов |
+Методы `Audits` в cloudapi/compute, cloudbroker/compute, cloudapi/account, cloudbroker/account, cloudapi/vins, cloudbroker/vins, cloudapi/rg и cloudbroker/rg  стали deprecated и в следующих версиях будут удалены, вместо них необходимо использовать метод `List` в cloudapi/audit и cloudbroker/audit с соответствующими фильтрами  
+Метод `ListStacks` в cloudbroker/image стал deprecated и в следующих версиях будет удалён  
+Методы `AccessGrant`, `AccessGrantToPool`, `AccessRevoke`, `AccessRevokeToPool` в cloudbroker/sep стали deprecated и в следующих версиях будут удалены
 
 ### Исправлено
 
-#### account
+#### Общие изменения
 | Идентификатор<br>задачи | Описание |
 | --- | --- |
-| BGOS-607 | Поле `StoragePolicies` в структуре запроса `CreateRequest` стало опциональным в cloudbroker/account |
-| BGOS-607 | Изменен тип поля `ID` в структуре запроса `StoragePolicy` с int64 на uint64 в cloudbroker/account |
-
-#### rg
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-607 | Изменен тип поля `ID` в структуре запроса `StoragePolicy` с int64 на uint64 в cloudapi/rg и в cloudbroker/rg |
-| BGOS-607 | Поле `StoragePolicies` в структуре запроса `CreateRequest` стало опциональным в cloudbroker/account |
-
-### Удалено
-
-#### account
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-605 | Поле `CKey` из структуры ответа `RecordAccount` в cloudapi/account и поля `CKey` из структуры ответа `InfoAccount` и `Meta` из структуры ответа `ItemAccount` в cloudbroker/account |
-
-#### compute
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-603 | Поля `VirtualImageID`, `VirtualImageName` из структуры ответа `RecordCompute` и `ItemCompute` в cloudapi/compute и `RecordCompute` и `InfoCompute` в cloudbroker/compute |
-| BGOS-603 | Поля `ImageID` из структуры ответа `ItemCompute` в cloudapi/compute и `InfoCompute` в cloudbroker/compute |
-| BGOS-612 | Поле `ImageID` из структуры запроса `ListRequest` в cloudbroker/compute |
-
-#### image
-| Идентификатор<br>задачи | Описание |
-| --- | --- |
-| BGOS-604 | Метод `UpdateNodes` и структура запроса `UpdateNodesRequest` в cloudbroker/image |
+| BGOS-644, BGOS-645, BGOS-646 | Исправлены уязвимости, обновлена версия go до v1.24.0 |

check.go

@@ -28,7 +28,13 @@ func (de DecortClient) Check() (*CheckInfo, error) {
 
 	err = json.Unmarshal([]byte(strings.Replace(strings.Trim(string(res), `"`), "\\", "", -1)), &info)
 	if err != nil {
-		return nil, err
+		var v string
+		json.Unmarshal([]byte(res), &v)
+		if _, exists := constants.VersionMap[v]; exists {
+			info.Version = v
+		} else {
+			return nil, fmt.Errorf("platform version isn't supported")
+		}
 	}
 
 	if v, ok := constants.VersionMap[info.Version]; ok {
@@ -51,7 +57,13 @@ func (bvs BVSDecortClient) Check() (*CheckInfo, error) {
 
 	err = json.Unmarshal([]byte(strings.Replace(strings.Trim(string(res), `"`), "\\", "", -1)), &info)
 	if err != nil {
-		return nil, err
+		var v string
+		json.Unmarshal([]byte(res), &v)
+		if _, exists := constants.VersionMap[v]; exists {
+			info.Version = v
+		} else {
+			return nil, fmt.Errorf("platform version isn't supported")
+		}
 	}
 
 	if v, ok := constants.VersionMap[info.Version]; ok {
@@ -74,7 +86,13 @@ func (ldc LegacyDecortClient) Check() (*CheckInfo, error) {
 
 	err = json.Unmarshal([]byte(strings.Replace(strings.Trim(string(res), `"`), "\\", "", -1)), &info)
 	if err != nil {
-		return nil, err
+		var v string
+		json.Unmarshal([]byte(res), &v)
+		if _, exists := constants.VersionMap[v]; exists {
+			info.Version = v
+		} else {
+			return nil, fmt.Errorf("platform version isn't supported")
+		}
 	}
 
 	if v, ok := constants.VersionMap[info.Version]; ok {

go.mod

@@ -1,21 +1,21 @@
 module repository.basistech.ru/BASIS/decort-golang-sdk
 
-go 1.20
+go 1.24.0
 
 require (
-	github.com/go-playground/validator/v10 v10.11.2
+	github.com/go-playground/validator/v10 v10.28.0
 	github.com/google/go-querystring v1.1.0
 	github.com/joho/godotenv v1.5.1
 	gopkg.in/yaml.v3 v3.0.1
 )
 
 require (
+	github.com/gabriel-vasile/mimetype v1.4.10 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/google/go-cmp v0.5.9 // indirect
-	github.com/kr/text v0.2.0 // indirect
-	github.com/leodido/go-urn v1.2.1 // indirect
-	golang.org/x/crypto v0.15.0 // indirect
-	golang.org/x/sys v0.14.0 // indirect
-	golang.org/x/text v0.14.0 // indirect
+	github.com/leodido/go-urn v1.4.0 // indirect
+	golang.org/x/crypto v0.42.0 // indirect
+	golang.org/x/sys v0.36.0 // indirect
+	golang.org/x/text v0.29.0 // indirect
 )

go.sum

@@ -1,6 +1,8 @@
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/gabriel-vasile/mimetype v1.4.10 h1:zyueNbySn/z8mJZHLt6IPw0KoZsiQNszIpU+bX4+ZK0=
+github.com/gabriel-vasile/mimetype v1.4.10/go.mod h1:d+9Oxyo1wTzWdyVUPMmXFvp4F9tea18J8ufA774AB3s=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
 github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
 github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
@@ -8,6 +10,9 @@ github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJn
 github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
 github.com/go-playground/validator/v10 v10.11.2 h1:q3SHpufmypg+erIExEKUmsgmhDTyhcJ38oeKGACXohU=
 github.com/go-playground/validator/v10 v10.11.2/go.mod h1:NieE624vt4SCTJtD87arVLvdmjPAeV8BQlHtMnw9D7s=
+github.com/go-playground/validator/v10 v10.27.0/go.mod h1:I5QpIEbmr8On7W0TktmJAumgzX4CA1XNl4ZmDuVHKKo=
+github.com/go-playground/validator/v10 v10.28.0 h1:Q7ibns33JjyW48gHkuFT91qX48KG0ktULL6FgHdG688=
+github.com/go-playground/validator/v10 v10.28.0/go.mod h1:GoI6I1SjPBh9p7ykNE/yj3fFYbyDOpwMn5KXd+m2hUU=
 github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
 github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
@@ -20,6 +25,8 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/leodido/go-urn v1.2.1 h1:BqpAaACuzVSgi/VLzGZIobT2z4v53pjosyNd9Yv6n/w=
 github.com/leodido/go-urn v1.2.1/go.mod h1:zt4jvISO2HfUBqxjfIshjdMTYS56ZS/qv49ictyFfxY=
+github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
+github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/rogpeppe/go-internal v1.8.0 h1:FCbCCtXNOY3UtUuHUYaghJg4y7Fd14rXifAYUAtL9R8=
@@ -28,10 +35,19 @@ github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
 github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
 golang.org/x/crypto v0.15.0 h1:frVn1TEaCEaZcn3Tmd7Y2b5KKPaZ+I32Q2OA3kYp5TA=
 golang.org/x/crypto v0.15.0/go.mod h1:4ChreQoLWfG3xLDer1WdlH5NdlQ3+mwnQq1YTKY+72g=
+golang.org/x/crypto v0.33.0/go.mod h1:bVdXmD7IV/4GdElGPozy6U7lWdRXA4qyRVGJV57uQ5M=
+golang.org/x/crypto v0.42.0 h1:chiH31gIWm57EkTXpwnqf8qeuMUi0yekh6mT2AvFlqI=
+golang.org/x/crypto v0.42.0/go.mod h1:4+rDnOTJhQCx2q7/j6rAN5XDw8kPjeaXEUR2eL94ix8=
 golang.org/x/sys v0.14.0 h1:Vz7Qs629MkJkGyHxUlRHizWJRG2j8fbQKjELVSNhy7Q=
 golang.org/x/sys v0.14.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.36.0 h1:KVRy2GtZBrk1cBYA7MKu5bEZFxQk4NIDV6RLVcC8o0k=
+golang.org/x/sys v0.36.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
 golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
 golang.org/x/text v0.14.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
+golang.org/x/text v0.22.0/go.mod h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
+golang.org/x/text v0.29.0 h1:1neNs90w9YzJ9BocxfsQNHKuAT4pkghyXc4nhZ6sJvk=
+golang.org/x/text v0.29.0/go.mod h1:7MhJOA9CD2qZyOKYazxdYMF85OwPdEr9jTtBpO7ydH4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=

internal/constants/constants.go

@@ -28,5 +28,9 @@ var FileName = map[string]string{
 var K8sValues = []string{"labels", "taints", "annotations, additionalSANs"}
 
 var VersionMap = map[string]string{
+	"4.4.0": "-",
 	"4.3.0": "-",
+	"4.2.0": "-",
+	"4.1.1": "-",
+	"4.1.0": "-",
 }

pkg/cloudapi/audit/filter.go

@@ -0,0 +1,81 @@
+package audit
+
+// FilterByID returns ListAudits with specified ID.
+func (la ListAudits) FilterByID(guid string) ListAudits {
+	predicate := func(ia ItemAudit) bool {
+		return ia.GUID == guid
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByCall returns ListAudits with specified call.
+func (la ListAudits) FilterByCall(call string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.Call == call
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByCorrelationID returns ListAudits with specified correlation id.
+func (la ListAudits) FilterByCorrelationID(correlationID string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.CorrelationID == correlationID
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByRemoteAddr returns ListAudits with specified remote address.
+func (la ListAudits) FilterByRemoteAddr(remoteAddr string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.RemoteAddr == remoteAddr
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByUser returns ListAudits with specified user name.
+func (la ListAudits) FilterByUser(user string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.User == user
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByStatusCode return ListAudits with specified status code.
+func (la ListAudits) FilterByStatusCode(statusCode uint64) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.StatusCode == statusCode
+	}
+
+	return la.FilterFunc(predicate)
+
+}
+
+// FilterFunc allows filtering ListAudits based on a user-specified predicate.
+func (la ListAudits) FilterFunc(predicate func(ItemAudit) bool) ListAudits {
+	var result ListAudits
+
+	for _, item := range la.Data {
+		if predicate(item) {
+			result.Data = append(result.Data, item)
+		}
+	}
+
+	result.EntryCount = uint64(len(result.Data))
+
+	return result
+}
+
+// FindOne returns first found ItemAudit
+// If none was found, returns an empty struct.
+func (la ListAudits) FindOne() ItemAudit {
+	if len(la.Data) == 0 {
+		return ItemAudit{}
+	}
+
+	return la.Data[0]
+}

pkg/cloudapi/audit/filter_test.go

@@ -0,0 +1,115 @@
+package audit
+
+import (
+	"testing"
+)
+
+var audits = ListAudits{
+	Data: []ItemAudit{
+		{
+			Args:          "[]",
+			Call:          "/restmachine/cloudapi/audit/linkedJobs",
+			GUID:          "550e8400-e29b-41d4-a716-446655440001",
+			CorrelationID: "550e8400-e29b-41d4-a716-446655440001",
+			Kwargs:        `{\"audit_guid\":\"dd8623a1-a887-48c1-a500-c10210d404cf\"}`,
+			RemoteAddr:    "192.168.1.100",
+			ResponseTime:  1,
+			Result:        `[]`,
+			StatusCode:    200,
+			Timestamp:     1640995200,
+			TimestampEnd:  1640995201,
+			User:          "test@example.com",
+			TTL:           "2025-07-31T14:22:57.028000",
+		},
+		{
+			Args:          "[]",
+			Call:          "/restmachine/cloudapi/audit/test",
+			GUID:          "550e8400-e29b-41d4-a716-446655440002",
+			CorrelationID: "550e8400-e29b-41d4-a716-446655440002",
+			Kwargs:        `{\"audit_guid\":\"dd8623a1-a887-48c1-a500-c10210d404cf\"}`,
+			RemoteAddr:    "192.168.1.105",
+			ResponseTime:  5,
+			Result:        `[]`,
+			StatusCode:    400,
+			Timestamp:     1640995200,
+			TimestampEnd:  1640995201,
+			User:          "test2@example.com",
+			TTL:           "2025-07-31T14:22:57.028000",
+		},
+	},
+	EntryCount: 2,
+}
+
+func TestFilterByID(t *testing.T) {
+	actual := audits.FilterByID("550e8400-e29b-41d4-a716-446655440002").FindOne()
+
+	if actual.GUID != "550e8400-e29b-41d4-a716-446655440002" {
+		t.Fatal("expected GUID 550e8400-e29b-41d4-a716-446655440002, found: ", actual.GUID)
+	}
+
+	actualEmpty := audits.FilterByID("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByCorrelationID(t *testing.T) {
+	actual := audits.FilterByCorrelationID("550e8400-e29b-41d4-a716-446655440002").FindOne()
+
+	if actual.CorrelationID != "550e8400-e29b-41d4-a716-446655440002" {
+		t.Fatal("expected GUID 550e8400-e29b-41d4-a716-446655440002, found: ", actual.CorrelationID)
+	}
+
+	actualEmpty := audits.FilterByCorrelationID("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByRemoteAddr(t *testing.T) {
+	actual := audits.FilterByRemoteAddr("192.168.1.100").FindOne()
+
+	if actual.RemoteAddr != "192.168.1.100" {
+		t.Fatal("expected remote address 192.168.1.100, found: ", actual.RemoteAddr)
+	}
+
+	actualEmpty := audits.FilterByRemoteAddr("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByUser(t *testing.T) {
+	actual := audits.FilterByUser("test@example.com").FindOne()
+
+	if actual.User != "test@example.com" {
+		t.Fatal("expected user test@example.com, found: ", actual.RemoteAddr)
+	}
+
+	actualEmpty := audits.FilterByUser("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByCall(t *testing.T) {
+	actual := audits.FilterByCall("/restmachine/cloudapi/audit/test").FindOne()
+
+	if actual.Call != "/restmachine/cloudapi/audit/test" {
+		t.Fatal("expected call /restmachine/cloudapi/audit/test, found: ", actual.Call)
+	}
+}
+
+func TestFilterByStatusCode(t *testing.T) {
+	actual := audits.FilterByStatusCode(200)
+
+	for _, item := range actual.Data {
+		if item.StatusCode != 200 {
+			t.Fatal("expected 200 status code, found: ", item.StatusCode)
+		}
+	}
+}

pkg/cloudapi/audit/list.go

@@ -0,0 +1,124 @@
+package audit
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// ListRequest struct to give list of account audits
+type ListRequest struct {
+
+	// Find all audits after point in time (unixtime)
+	// Required: false
+	TimestampAt uint64 `url:"timestamp_at,omitempty" json:"timestamp_at,omitempty"`
+
+	// Find all audits before point in time (unixtime)
+	// Required: false
+	TimestampTo uint64 `url:"timestamp_to,omitempty" json:"timestamp_to,omitempty"`
+
+	// Find by user (Mongo RegExp supported)
+	// Required: false
+	User string `url:"user,omitempty" json:"user,omitempty"`
+
+	// Find by api endpoint (Mongo RegExp supported)
+	// Required: false
+	Call string `url:"call,omitempty" json:"call,omitempty"`
+
+	// Find by request id
+	// Required: false
+	RequestID string `url:"request_id,omitempty" json:"request_id,omitempty"`
+
+	// Find by HTTP min status code
+	// Required: false
+	MinStatusCode uint64 `url:"min_status_code,omitempty" json:"min_status_code,omitempty"`
+
+	// Find by HTTP max status code
+	// Required: false
+	MaxStatusCode uint64 `url:"max_status_code,omitempty" json:"max_status_code,omitempty"`
+
+	// Sort by one of supported fields, format +|-(field)
+	// Required: false
+	SortBy string `url:"sort_by,omitempty" json:"sort_by,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"`
+
+	// Find by resource group id
+	// Required: false
+	RGID uint64 `url:"resgroup_id,omitempty" json:"resgroup_id,omitempty"`
+
+	// Find by compute id
+	// Required: false
+	ComputeID uint64 `url:"compute_id,omitempty" json:"compute_id,omitempty"`
+
+	// Find by account id
+	// Required: false
+	AccountID uint64 `url:"account_id,omitempty" json:"account_id,omitempty"`
+
+	// Find by vins id
+	// Required: false
+	VINSID uint64 `url:"vins_id,omitempty" json:"vins_id,omitempty"`
+
+	// Find by service id
+	// Required: false
+	ServiceID uint64 `url:"service_id,omitempty" json:"service_id,omitempty"`
+
+	// Find by k8s id
+	// Required: false
+	K8SID uint64 `url:"k8s_id,omitempty" json:"k8s_id,omitempty"`
+
+	// Find by flipgroup id
+	// Required: false
+	FLIPGroupID uint64 `url:"flipgroup_id,omitempty" json:"flipgroup_id,omitempty"`
+
+	// Find by load balancer id
+	// Required: false
+	LBID uint64 `url:"lb_id,omitempty" json:"lb_id,omitempty"`
+
+	// Find by sep id
+	// Required: false
+	SEPID uint64 `url:"sep_id,omitempty" json:"sep_id,omitempty"`
+
+	// Exclude audit lines from response
+	// Required: false
+	ExcludeAuditLines bool `url:"exclude_audit_lines,omitempty" json:"exclude_audit_lines,omitempty"`
+}
+
+// List gets audit records for the specified account object
+func (a Audit) List(ctx context.Context, req ListRequest) (*ListAudits, error) {
+
+	res, err := a.ListRaw(ctx, req)
+	if err != nil {
+		return nil, err
+	}
+
+	list := ListAudits{}
+
+	err = json.Unmarshal(res, &list)
+	if err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}
+
+// ListRaw gets list of audit records an array of bytes
+func (a Audit) ListRaw(ctx context.Context, req ListRequest) ([]byte, error) {
+
+	if err := validators.ValidateRequest(req); err != nil {
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudapi/audit/list"
+
+	res, err := a.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	return res, err
+}

pkg/cloudapi/audit/models.go

@@ -42,3 +42,54 @@ type RecordAudit struct {
 	// User
 	User string `json:"user"`
 }
+
+// Main info about audit
+type ItemAudit struct {
+	// Args
+	Args string `json:"args"`
+
+	// Call
+	Call string `json:"call"`
+
+	// GUID
+	GUID string `json:"guid"`
+
+	// Correlation ID
+	CorrelationID string `json:"correlation_id"`
+
+	// Kwargs
+	Kwargs string `json:"kwargs"`
+
+	// RemoteAddr
+	RemoteAddr string `json:"remote_addr"`
+
+	// Response time
+	ResponseTime float64 `json:"responsetime"`
+
+	// Result
+	Result string `json:"result"`
+
+	// Status code
+	StatusCode uint64 `json:"statuscode"`
+
+	// Timestamp
+	Timestamp float64 `json:"timestamp"`
+
+	// Timestamp End
+	TimestampEnd float64 `json:"timestampEnd"`
+
+	// User
+	User string `json:"user"`
+
+	// TTL
+	TTL string `json:"_ttl"`
+}
+
+// List of audits
+type ListAudits struct {
+	// Data
+	Data []ItemAudit `json:"data"`
+
+	// EntryCount
+	EntryCount uint64 `json:"entryCount"`
+}

pkg/cloudapi/compute/change_secutity_group.go

@@ -24,7 +24,7 @@ type ChangeSecGroupsRequest struct {
 
 	// Flag indicating whether security groups are enabled for this interface
 	// Required: false
-	EnableSecGroups bool `url:"enable_secgroups,omitempty" json:"enable_secgroups,omitempty"`
+	EnableSecGroups interface{} `url:"enable_secgroups,omitempty" json:"enable_secgroups,omitempty" validate:"omitempty,isBool"`
 }
 
 // ChangeSecGroups changes security groups for compute

pkg/cloudapi/compute/clone.go

@@ -3,8 +3,8 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
@@ -18,6 +18,10 @@ type CloneRequest struct {
 	// Required: true
 	Name string `url:"name" json:"name" validate:"required"`
 
+	// ID of the Storage Policy
+	// 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
 	SnapshotTimestamp uint64 `url:"snapshotTimestamp,omitempty" json:"snapshotTimestamp,omitempty"`
@@ -30,26 +34,29 @@ type CloneRequest struct {
 	// Default: false
 	// Required: false
 	Force bool `url:"force" json:"force"`
+
+	// The name of the pool to migrate disks to
+	// Required: false
+	PoolName string `url:"pool_name" json:"pool_name"`
+
+	// The ID of the SEP to migrate disks to
+	// Required: false
+	SEPID uint64 `url:"sep_id" json:"sep_id"`
 }
 
 // Clone clones compute instance
-func (c Compute) Clone(ctx context.Context, req CloneRequest) (uint64, error) {
+func (c Compute) Clone(ctx context.Context, req CloneRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return 0, validators.ValidationErrors(validators.GetErrors(err))
+		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudapi/compute/clone"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
 	if err != nil {
-		return 0, err
+		return "", err
 	}
 
-	result, err := strconv.ParseUint(string(res), 10, 64)
-	if err != nil {
-		return 0, err
-	}
-
-	return result, nil
+	return string(res), nil
 }

pkg/cloudapi/compute/clone_abort.go

@@ -0,0 +1,39 @@
+package compute
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// CloneAbortRequest struct to abort a compute clone
+type CloneAbortRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"compute_id" json:"compute_id" validate:"required"`
+}
+
+// CloneAbort aborts a compute clone
+func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, 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
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudapi/compute/clone_status.go

@@ -0,0 +1,40 @@
+package compute
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// GetCloneStatusRequest struct to get information about compute clone status
+type GetCloneStatusRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"compute_id" json:"compute_id" validate:"required"`
+}
+
+// GetCloneStatus gets information about compute clone status as a RecordCloneStatus struct
+func (c Compute) GetCloneStatus(ctx context.Context, req GetCloneStatusRequest) ([]RecordCloneStatus, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudapi/compute/clone_status"
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodGet, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	cloneStatus := make([]RecordCloneStatus, 0)
+
+	err = json.Unmarshal(res, &cloneStatus)
+	if err != nil {
+		return nil, err
+	}
+
+	return cloneStatus, nil
+}

pkg/cloudapi/compute/create_template.go

@@ -3,7 +3,6 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 	"strings"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
@@ -27,47 +26,15 @@ type wrapperCreateTemplateRequest struct {
 }
 
 // CreateTemplate create template from compute instance
-func (c Compute) CreateTemplate(ctx context.Context, req CreateTemplateRequest) (uint64, error) {
-	err := validators.ValidateRequest(req)
-	if err != nil {
-		return 0, validators.ValidationErrors(validators.GetErrors(err))
-	}
-
-	reqWrapped := wrapperCreateTemplateRequest{
-		CreateTemplateRequest: req,
-		AsyncMode:                 false,
-	}
-
-	url := "/cloudapi/compute/createTemplate"
-
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
-	if err != nil {
-		return 0, err
-	}
-
-	result, err := strconv.ParseUint(string(res), 10, 64)
-	if err != nil {
-		return 0, err
-	}
-
-	return result, nil
-}
-
-// CreateTemplateAsync create template from compute instance
-func (c Compute) CreateTemplateAsync(ctx context.Context, req CreateTemplateRequest) (string, error) {
+func (c Compute) CreateTemplate(ctx context.Context, req CreateTemplateRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
-	reqWrapped := wrapperCreateTemplateRequest{
-		CreateTemplateRequest: req,
-		AsyncMode:                 true,
-	}
-
 	url := "/cloudapi/compute/createTemplate"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
 		return "", err
 	}

pkg/cloudapi/compute/disk_add.go

@@ -50,6 +50,14 @@ type DiskAddRequest struct {
 	// Specify image id for create disk from template
 	// Required: false
 	ImageID uint64 `url:"imageId,omitempty" json:"imageId,omitempty"`
+
+	// Desired PCI slot (hex string, e.g. "0x1A")
+	// Required: false
+	PCISlot string `url:"pci_slot,omitempty" json:"pci_slot,omitempty"`
+
+	// Desired bus number (hex string, e.g. "0x03")
+	// Required: false
+	BusNumber string `url:"bus_number,omitempty" json:"bus_number,omitempty"`
 }
 
 // DiskAdd creates new disk and attach to compute

pkg/cloudapi/compute/disk_attach.go

@@ -21,6 +21,14 @@ type DiskAttachRequest struct {
 	// 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"`
+
+	// Desired bus number (hex string, e.g. "0x03")
+	// Required: false
+	BusNumber string `url:"bus_number,omitempty" json:"bus_number,omitempty"`
 }
 
 // DiskAttach attach disk to compute

pkg/cloudapi/compute/models.go

@@ -311,6 +311,9 @@ type RecordCompute struct {
 	// Architecture
 	Architecture string `json:"arch"`
 
+	// Boot image ID
+	BootImageID uint64 `json:"boot_image_id"`
+
 	// Boot order
 	BootOrder []string `json:"bootOrder"`
 
@@ -392,6 +395,9 @@ type RecordCompute struct {
 	// List interfaces
 	Interfaces ListInterfaces `json:"interfaces"`
 
+	// Loader meta iso information
+	LoaderMetaIso LoaderMetaIso `json:"loaderMetaIso"`
+
 	// Live migration job ID
 	LiveMigrationJobID uint64 `json:"live_migration_job_id"`
 
@@ -519,6 +525,13 @@ type RecordCompute struct {
 	// Required: false
 	ZoneID uint64 `json:"zoneId"`
 }
+type LoaderMetaIso struct {
+	// Name
+	DeviceName string `json:"devicename"`
+
+	// Path
+	Path string `json:"path"`
+}
 
 type QemuQuest struct {
 	Enabled              bool     `json:"enabled"`
@@ -758,9 +771,18 @@ type ItemComputeDisk struct {
 	// Bus number
 	BusNumber uint64 `json:"bus_number"`
 
+	// Created by
+	CreatedBy string `json:"createdBy"`
+
 	// Created time
 	CreatedTime uint64 `json:"createdTime"`
 
+	// Device name
+	DeviceName string `json:"devicename"`
+
+	// Deleted by
+	DeletedBy string `json:"deletedBy"`
+
 	// Deleted time
 	DeletedTime uint64 `json:"deletedTime"`
 
@@ -871,6 +893,9 @@ type ItemComputeDisk struct {
 
 	// Updated by
 	UpdatedBy string `json:"updatedBy"`
+
+	// UpdatedTime
+	UpdatedTime uint64 `json:"updatedTime"`
 }
 
 type ItemReplication struct {
@@ -991,6 +1016,9 @@ type ItemCompute struct {
 	// Architecture
 	Architecture string `json:"arch"`
 
+	// Boot image ID
+	BootImageID uint64 `json:"boot_image_id"`
+
 	// Boot order
 	BootOrder []string `json:"bootOrder"`
 
@@ -1300,3 +1328,31 @@ type ListPCIDevices struct {
 	// Entry count
 	EntryCount uint64 `json:"entryCount"`
 }
+
+type RecordCloneStatus struct {
+	// Disk ID
+	DiskID int `json:"disk_id"`
+
+	// Clone Status
+	Status CloneStatus `json:"status"`
+}
+
+type CloneStatus struct {
+	// Type
+	Type int `json:"type"`
+
+	// Copy speed
+	Bandwidth int `json:"bandwidth"`
+
+	// Current progress
+	Cur int `json:"cur"`
+
+	// Total size
+	End int `json:"end"`
+
+	// Operation status
+	Ready bool `json:"ready"`
+
+	// Progress percent
+	ProgressPercent int `json:"progress_percent"`
+}

pkg/cloudapi/disks/create.go

@@ -30,10 +30,6 @@ type CreateRequest struct {
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
 
-	// Max IOPS disk can perform defaults to 2000
-	// Required: false
-	IOPS uint64 `url:"iops,omitempty" json:"iops,omitempty"`
-
 	// Storage endpoint provider ID to create disk
 	// Required: false
 	SEPID uint64 `url:"sep_id,omitempty" json:"sep_id,omitempty"`

pkg/cloudapi/image/list.go

@@ -69,6 +69,10 @@ type ListRequest struct {
 	// Find by enabled True or False
 	// Required: false
 	Enabled interface{} `url:"enabled,omitempty" json:"enabled,omitempty" validate:"omitempty,isBool"`
+
+	// Find by storage policy id
+	// Required: false
+	StoragePolicyID uint64 `url:"storage_policy_id,omitempty" json:"storage_policy_id,omitempty"`
 }
 
 // List gets list of available images as a ListImages struct, optionally filtering by account ID

pkg/cloudapi/image/models.go

@@ -50,6 +50,9 @@ type ItemImage struct {
 	// Status
 	Status string `json:"status"`
 
+	// Storage policy ID
+	StoragePolicyID uint64 `json:"storage_policy_id"`
+
 	// Type
 	Type string `json:"type"`
 

pkg/cloudapi/rg/add_storage_policy.go

@@ -0,0 +1,46 @@
+package rg
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// AddStoragePolicyRequest struct for adding storage policy to the resource group
+type AddStoragePolicyRequest struct {
+	// ID of resource group to add to
+	// Required: true
+	RGID uint64 `url:"resgroup_id" json:"resgroup_id" validate:"required"`
+
+	// ID of the storage policy to which to connect resource group
+	// Required: true
+	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
+
+	// Limit storage resources GB. Or -1 unlimit
+	// Required: false
+	Limit int `url:"limit,omitempty" json:"limit,omitempty"`
+}
+
+// AddStoragePolicy add storage policy to the account.
+func (r RG) AddStoragePolicy(ctx context.Context, req AddStoragePolicyRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudapi/rg/add_storage_policy"
+
+	res, err := r.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/cloudapi/rg/del_storage_policy.go

@@ -0,0 +1,42 @@
+package rg
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// DelStoragePolicyRequest struct for deleting storage policy to the resource group
+type DelStoragePolicyRequest struct {
+	// ID of resource group
+	// Required: true
+	RGID uint64 `url:"resgroup_id" json:"resgroup_id" validate:"required"`
+
+	// ID of the storage policy to which to disconnect account
+	// Required: true
+	StoragePolicyID uint64 `url:"storage_policy_id" json:"storage_policy_id" validate:"required"`
+}
+
+// DelStoragePolicy delete storage policy to the account.
+func (r RG) DelStoragePolicy(ctx context.Context, req DelStoragePolicyRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudapi/rg/del_storage_policy"
+
+	res, err := r.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/cloudapi/stpolicy/list.go

@@ -9,10 +9,6 @@ import (
 )
 
 type ListRequest struct {
-	// ID of account ID
-	// Required: true
-	AccountID uint64 `url:"account_id" json:"account_id" validate:"required"`
-
 	// Page number
 	// Required: false
 	Page uint64 `url:"page,omitempty" json:"page,omitempty"`
@@ -45,6 +41,10 @@ type ListRequest struct {
 	// Required: false
 	SortBy string `url:"sort_by,omitempty" json:"sort_by,omitempty"`
 
+	// ID of account ID
+	// Required: false
+	AccountID uint64 `url:"account_id,omitempty" json:"account_id,omitempty"`
+
 	// Search by resgroup id
 	// Required: false
 	ResgroupID uint64 `url:"resgroup_id,omitempty" json:"resgroup_id,omitempty"`

pkg/cloudapi/stpolicy/models.go

@@ -30,6 +30,9 @@ type ItemStoragePolicy struct {
 	// Max IOPS for the sotrage policy
 	LimitIOPS uint64 `json:"limit_iops"`
 
+	// Storage policy ID
+	StoragePolicyID uint64 `json:"storage_policy_id"`
+
 	// Which accounts and resource groups use the storage policy
 	Usage Usage `json:"usage"`
 }
@@ -56,6 +59,9 @@ type InfoStoragePolicy 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"`
 }

pkg/cloudapi/vins/models.go

@@ -211,6 +211,12 @@ type RecordVNFDev struct {
 
 	// VNC password
 	VNCPassword string `json:"vncPasswd"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
+
+	// Live migration job ID
+	LiveMigrationJobID uint64 `json:"live_migration_job_id"`
 }
 
 // VNF config
@@ -269,6 +275,9 @@ type ItemVNFInterface struct {
 	// Enabled
 	Enabled bool `json:"enabled"`
 
+	// Enable security groups
+	EnableSecGroups bool `json:"enable_secgroups"`
+
 	// FLIPGroup ID
 	FLIPGroupID uint64 `json:"flipgroupId"`
 
@@ -305,6 +314,9 @@ type ItemVNFInterface struct {
 	// NodeID
 	NodeID int64 `json:"nodeId"`
 
+	// List of security groups
+	SecGroups []uint64 `json:"security_groups"`
+
 	// SDNInterfaceID
 	SDNInterfaceID string `json:"sdn_interface_id"`
 
@@ -418,6 +430,9 @@ type RecordNAT struct {
 
 	// Type
 	Type string `json:"type"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
 }
 
 // NAT configuration
@@ -486,6 +501,9 @@ type RecordGW struct {
 
 	// Type
 	Type string `json:"type"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
 }
 
 // GW configuration
@@ -576,6 +594,9 @@ type RecordDHCP struct {
 
 	// Type
 	Type string `json:"type"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
 }
 
 // DHCP configuration

pkg/cloudbroker/audit/filter.go

@@ -0,0 +1,81 @@
+package audit
+
+// FilterByID returns ListAudits with specified ID.
+func (la ListAudits) FilterByID(guid string) ListAudits {
+	predicate := func(ia ItemAudit) bool {
+		return ia.GUID == guid
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByCall returns ListAudits with specified call.
+func (la ListAudits) FilterByCall(call string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.Call == call
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByCorrelationID returns ListAudits with specified correlation id.
+func (la ListAudits) FilterByCorrelationID(correlationID string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.CorrelationID == correlationID
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByRemoteAddr returns ListAudits with specified remote address.
+func (la ListAudits) FilterByRemoteAddr(remoteAddr string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.RemoteAddr == remoteAddr
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByUser returns ListAudits with specified user name.
+func (la ListAudits) FilterByUser(user string) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.User == user
+	}
+
+	return la.FilterFunc(predicate)
+}
+
+// FilterByStatusCode return ListAudits with specified status code.
+func (la ListAudits) FilterByStatusCode(statusCode uint64) ListAudits {
+	predicate := func(ic ItemAudit) bool {
+		return ic.StatusCode == statusCode
+	}
+
+	return la.FilterFunc(predicate)
+
+}
+
+// FilterFunc allows filtering ListAudits based on a user-specified predicate.
+func (la ListAudits) FilterFunc(predicate func(ItemAudit) bool) ListAudits {
+	var result ListAudits
+
+	for _, item := range la.Data {
+		if predicate(item) {
+			result.Data = append(result.Data, item)
+		}
+	}
+
+	result.EntryCount = uint64(len(result.Data))
+
+	return result
+}
+
+// FindOne returns first found ItemAudit
+// If none was found, returns an empty struct.
+func (la ListAudits) FindOne() ItemAudit {
+	if len(la.Data) == 0 {
+		return ItemAudit{}
+	}
+
+	return la.Data[0]
+}

pkg/cloudbroker/audit/filter_test.go

@@ -0,0 +1,115 @@
+package audit
+
+import (
+	"testing"
+)
+
+var audits = ListAudits{
+	Data: []ItemAudit{
+		{
+			Args:          "[]",
+			Call:          "/restmachine/cloudapi/audit/linkedJobs",
+			GUID:          "550e8400-e29b-41d4-a716-446655440001",
+			CorrelationID: "550e8400-e29b-41d4-a716-446655440001",
+			Kwargs:        `{\"audit_guid\":\"dd8623a1-a887-48c1-a500-c10210d404cf\"}`,
+			RemoteAddr:    "192.168.1.100",
+			ResponseTime:  1,
+			Result:        `[]`,
+			StatusCode:    200,
+			Timestamp:     1640995200,
+			TimestampEnd:  1640995201,
+			User:          "test@example.com",
+			TTL:           "2025-07-31T14:22:57.028000",
+		},
+		{
+			Args:          "[]",
+			Call:          "/restmachine/cloudapi/audit/test",
+			GUID:          "550e8400-e29b-41d4-a716-446655440002",
+			CorrelationID: "550e8400-e29b-41d4-a716-446655440002",
+			Kwargs:        `{\"audit_guid\":\"dd8623a1-a887-48c1-a500-c10210d404cf\"}`,
+			RemoteAddr:    "192.168.1.105",
+			ResponseTime:  5,
+			Result:        `[]`,
+			StatusCode:    400,
+			Timestamp:     1640995200,
+			TimestampEnd:  1640995201,
+			User:          "test2@example.com",
+			TTL:           "2025-07-31T14:22:57.028000",
+		},
+	},
+	EntryCount: 2,
+}
+
+func TestFilterByID(t *testing.T) {
+	actual := audits.FilterByID("550e8400-e29b-41d4-a716-446655440002").FindOne()
+
+	if actual.GUID != "550e8400-e29b-41d4-a716-446655440002" {
+		t.Fatal("expected GUID 550e8400-e29b-41d4-a716-446655440002, found: ", actual.GUID)
+	}
+
+	actualEmpty := audits.FilterByID("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByCorrelationID(t *testing.T) {
+	actual := audits.FilterByCorrelationID("550e8400-e29b-41d4-a716-446655440002").FindOne()
+
+	if actual.CorrelationID != "550e8400-e29b-41d4-a716-446655440002" {
+		t.Fatal("expected GUID 550e8400-e29b-41d4-a716-446655440002, found: ", actual.CorrelationID)
+	}
+
+	actualEmpty := audits.FilterByCorrelationID("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByRemoteAddr(t *testing.T) {
+	actual := audits.FilterByRemoteAddr("192.168.1.100").FindOne()
+
+	if actual.RemoteAddr != "192.168.1.100" {
+		t.Fatal("expected remote address 192.168.1.100, found: ", actual.RemoteAddr)
+	}
+
+	actualEmpty := audits.FilterByRemoteAddr("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByUser(t *testing.T) {
+	actual := audits.FilterByUser("test@example.com").FindOne()
+
+	if actual.User != "test@example.com" {
+		t.Fatal("expected user test@example.com, found: ", actual.RemoteAddr)
+	}
+
+	actualEmpty := audits.FilterByUser("")
+
+	if len(actualEmpty.Data) != 0 {
+		t.Fatal("expected empty, actual: ", len(actualEmpty.Data))
+	}
+}
+
+func TestFilterByCall(t *testing.T) {
+	actual := audits.FilterByCall("/restmachine/cloudapi/audit/test").FindOne()
+
+	if actual.Call != "/restmachine/cloudapi/audit/test" {
+		t.Fatal("expected call /restmachine/cloudapi/audit/test, found: ", actual.Call)
+	}
+}
+
+func TestFilterByStatusCode(t *testing.T) {
+	actual := audits.FilterByStatusCode(200)
+
+	for _, item := range actual.Data {
+		if item.StatusCode != 200 {
+			t.Fatal("expected 200 status code, found: ", item.StatusCode)
+		}
+	}
+}

pkg/cloudbroker/audit/list.go

@@ -50,6 +50,50 @@ type ListRequest struct {
 	// Page size
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
+
+	// Find by resource group id
+	// Required: false
+	RGID uint64 `url:"resgroup_id,omitempty" json:"resgroup_id,omitempty"`
+
+	// Find by compute id
+	// Required: false
+	ComputeID uint64 `url:"compute_id,omitempty" json:"compute_id,omitempty"`
+
+	// Find by account id
+	// Required: false
+	AccountID uint64 `url:"account_id,omitempty" json:"account_id,omitempty"`
+
+	// Find by vins id
+	// Required: false
+	VINSID uint64 `url:"vins_id,omitempty" json:"vins_id,omitempty"`
+
+	// Find by service id
+	// Required: false
+	ServiceID uint64 `url:"service_id,omitempty" json:"service_id,omitempty"`
+
+	// Find by k8s id
+	// Required: false
+	K8SID uint64 `url:"k8s_id,omitempty" json:"k8s_id,omitempty"`
+
+	// Find by flipgroup id
+	// Required: false
+	FLIPGroupID uint64 `url:"flipgroup_id,omitempty" json:"flipgroup_id,omitempty"`
+
+	// Find by load balancer id
+	// Required: false
+	LBID uint64 `url:"lb_id,omitempty" json:"lb_id,omitempty"`
+
+	// Find by sep id
+	// Required: false
+	SEPID uint64 `url:"sep_id,omitempty" json:"sep_id,omitempty"`
+
+	// Find by node id
+	// Required: false
+	NodeID uint64 `url:"node_id,omitempty" json:"node_id,omitempty"`
+
+	// Exclude audit lines from response
+	// Required: false
+	ExcludeAuditLines bool `url:"exclude_audit_lines,omitempty" json:"exclude_audit_lines,omitempty"`
 }
 
 // List gets audit records for the specified account object

pkg/cloudbroker/audit/models.go

@@ -40,9 +40,6 @@ type ItemAudit struct {
 
 	// TTL
 	TTL string `json:"_ttl"`
-
-	// Tags
-	Tags string `json:"tags"`
 }
 
 // List of audits

pkg/cloudbroker/compute/change_secutity_group.go

@@ -24,7 +24,7 @@ type ChangeSecGroupsRequest struct {
 
 	// Flag indicating whether security groups are enabled for this interface
 	// Required: false
-	EnableSecGroups bool `url:"enable_secgroups,omitempty" json:"enable_secgroups,omitempty"`
+	EnableSecGroups interface{} `url:"enable_secgroups,omitempty" json:"enable_secgroups,omitempty" validate:"omitempty,isBool"`
 }
 
 // ChangeSecGroups changes security groups for compute

pkg/cloudbroker/compute/clone.go

@@ -3,8 +3,8 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
@@ -18,6 +18,10 @@ type CloneRequest struct {
 	// Required: true
 	Name string `url:"name" json:"name" validate:"required"`
 
+	// ID of the Storage Policy
+	// 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
 	SnapshotTimestamp uint64 `url:"snapshotTimestamp" json:"snapshotTimestamp"`
@@ -30,26 +34,29 @@ type CloneRequest struct {
 	// Default: false
 	// Required: false
 	Force bool `url:"force" json:"force"`
+
+	// The name of the pool to migrate disks to
+	// Required: false
+	PoolName string `url:"pool_name" json:"pool_name"`
+
+	// The ID of the SEP to migrate disks to
+	// Required: false
+	SEPID uint64 `url:"sep_id" json:"sep_id"`
 }
 
 // Clone clones compute instance
-func (c Compute) Clone(ctx context.Context, req CloneRequest) (uint64, error) {
+func (c Compute) Clone(ctx context.Context, req CloneRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
-		return 0, validators.ValidationErrors(validators.GetErrors(err))
+		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
 	url := "/cloudbroker/compute/clone"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
 	if err != nil {
-		return 0, err
+		return "", err
 	}
 
-	result, err := strconv.ParseUint(string(res), 10, 64)
-	if err != nil {
-		return 0, err
-	}
-
-	return result, nil
+	return string(res), nil
 }

pkg/cloudbroker/compute/clone_abort.go

@@ -0,0 +1,39 @@
+package compute
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// CloneAbortRequest struct to abort a compute clone
+type CloneAbortRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"compute_id" json:"compute_id" validate:"required"`
+}
+
+// CloneAbort aborts a compute clone
+func (c Compute) CloneAbort(ctx context.Context, req CloneAbortRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, 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
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/compute/clone_status.go

@@ -0,0 +1,40 @@
+package compute
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// GetCloneStatusRequest struct to get information about compute clone status
+type GetCloneStatusRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"compute_id" json:"compute_id" validate:"required"`
+}
+
+// GetCloneStatus gets information about compute clone status as a RecordCloneStatus struct
+func (c Compute) GetCloneStatus(ctx context.Context, req GetCloneStatusRequest) ([]RecordCloneStatus, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/compute/clone_status"
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodGet, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	cloneStatus := make([]RecordCloneStatus, 0)
+
+	err = json.Unmarshal(res, &cloneStatus)
+	if err != nil {
+		return nil, err
+	}
+
+	return cloneStatus, nil
+}

pkg/cloudbroker/compute/create_template.go

@@ -3,7 +3,6 @@ package compute
 import (
 	"context"
 	"net/http"
-	"strconv"
 	"strings"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
@@ -20,27 +19,16 @@ type CreateTemplateRequest struct {
 	Name string `url:"name" json:"name" validate:"required"`
 }
 
-type wrapperCreateTemplateRequest struct {
-	CreateTemplateRequest
-
-	AsyncMode bool `url:"asyncMode"`
-}
-
-// CreateTemplateAsync create template from compute instance
-func (c Compute) CreateTemplateAsync(ctx context.Context, req CreateTemplateRequest) (string, error) {
+// CreateTemplate create template from compute instance
+func (c Compute) CreateTemplate(ctx context.Context, req CreateTemplateRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		return "", validators.ValidationErrors(validators.GetErrors(err))
 	}
 
-	reqWrapped := wrapperCreateTemplateRequest{
-		CreateTemplateRequest: req,
-		AsyncMode:                 true,
-	}
-
 	url := "/cloudbroker/compute/createTemplate"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
 	if err != nil {
 		return "", err
 	}
@@ -49,30 +37,3 @@ func (c Compute) CreateTemplateAsync(ctx context.Context, req CreateTemplateRequ
 
 	return result, nil
 }
-
-// CreateTemplate create template from compute instance
-func (c Compute) CreateTemplate(ctx context.Context, req CreateTemplateRequest) (uint64, error) {
-	err := validators.ValidateRequest(req)
-	if err != nil {
-		return 0, validators.ValidationErrors(validators.GetErrors(err))
-	}
-
-	reqWrapped := wrapperCreateTemplateRequest{
-		CreateTemplateRequest: req,
-		AsyncMode:                 false,
-	}
-
-	url := "/cloudbroker/compute/createTemplate"
-
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
-	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/compute/disk_add.go

@@ -50,6 +50,14 @@ type DiskAddRequest struct {
 	// Specify image id for create disk from template
 	// Required: false
 	ImageID uint64 `url:"imageId,omitempty" json:"imageId,omitempty"`
+
+	// Desired PCI slot (hex string, e.g. "0x1A")
+	// Required: false
+	PCISlot string `url:"pci_slot,omitempty" json:"pci_slot,omitempty"`
+
+	// Desired bus number (hex string, e.g. "0x03")
+	// Required: false
+	BusNumber string `url:"bus_number,omitempty" json:"bus_number,omitempty"`
 }
 
 // DiskAdd creates new disk and attach to compute

pkg/cloudbroker/compute/disk_attach.go

@@ -21,6 +21,14 @@ type DiskAttachRequest struct {
 	// 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"`
+
+	// Desired bus number (hex string, e.g. "0x03")
+	// Required: false
+	BusNumber string `url:"bus_number,omitempty" json:"bus_number,omitempty"`
 }
 
 // DiskAttach attach disk to compute

pkg/cloudbroker/compute/migrate_storage_list.go

@@ -20,7 +20,7 @@ type MigrateStorageListRequest struct {
 
 	// Sort by one of supported fields, format +|-(field)
 	// Required: false
-	SortBy string `url:"sortBy,omitempty" json:"sortBy,omitempty" validate:"omitempty,sortBy"`
+	SortBy string `url:"sort_by,omitempty" json:"sort_by,omitempty" validate:"omitempty,sortBy"`
 
 	// Page number
 	// Required: false

pkg/cloudbroker/compute/models.go

@@ -373,9 +373,18 @@ type ItemDisk struct {
 	// Bus number
 	BusNumber uint64 `json:"bus_number"`
 
+	// Created by
+	CreatedBy string `json:"createdBy"`
+
 	// Created time
 	CreatedTime uint64 `json:"createdTime"`
 
+	// Device name
+	DeviceName string `json:"devicename"`
+
+	// Deleted by
+	DeletedBy string `json:"deletedBy"`
+
 	// Deleted time
 	DeletedTime uint64 `json:"deletedTime"`
 
@@ -495,6 +504,9 @@ type ItemDisk struct {
 
 	// Updated by
 	UpdatedBy string `json:"updatedBy"`
+
+	// UpdatedTime
+	UpdatedTime uint64 `json:"updatedTime"`
 }
 
 type ItemReplication struct {
@@ -651,6 +663,9 @@ type InfoCompute struct {
 	// Architecture
 	Arch string `json:"arch"`
 
+	// Boot image ID
+	BootImageID uint64 `json:"boot_image_id"`
+
 	// Boot order
 	BootOrder []string `json:"bootOrder"`
 
@@ -905,6 +920,9 @@ type RecordCompute struct {
 	// Architecture
 	Arch string `json:"arch"`
 
+	// Boot image ID
+	BootImageID uint64 `json:"boot_image_id"`
+
 	// Boot order
 	BootOrder []string `json:"bootOrder"`
 
@@ -980,12 +998,15 @@ type RecordCompute struct {
 	// Image ID
 	ImageID uint64 `json:"imageId"`
 
-	// ImageName
+	// Image name
 	ImageName string `json:"imageName"`
 
 	// List interfaces
 	Interfaces ListInterfaces `json:"interfaces"`
 
+	// Loader meta iso information
+	LoaderMetaIso LoaderMetaIso `json:"loaderMetaIso"`
+
 	// Live migration job ID
 	LiveMigrationJobID uint64 `json:"live_migration_job_id"`
 
@@ -1125,6 +1146,14 @@ type RecordCompute struct {
 	ZoneID uint64 `json:"zoneId"`
 }
 
+type LoaderMetaIso struct {
+	// Name
+	DeviceName string `json:"devicename"`
+
+	// Path
+	Path string `json:"path"`
+}
+
 type VGPUItem struct {
 	// ID
 	ID uint64 `json:"id"`
@@ -1397,3 +1426,31 @@ type MigrateStorageItem struct {
 	// Target stack ID
 	TargetStackID uint64 `json:"targetStackId"`
 }
+
+type RecordCloneStatus struct {
+	// Disk ID
+	DiskID int `json:"disk_id"`
+
+	// Clone Status
+	Status CloneStatus `json:"status"`
+}
+
+type CloneStatus struct {
+	// Type
+	Type int `json:"type"`
+
+	// Copy speed
+	Bandwidth int `json:"bandwidth"`
+
+	// Current progress
+	Cur int `json:"cur"`
+
+	// Total size
+	End int `json:"end"`
+
+	// Operation status
+	Ready bool `json:"ready"`
+
+	// Progress percent
+	ProgressPercent int `json:"progress_percent"`
+}

pkg/cloudbroker/compute/start_migration_out.go

@@ -0,0 +1,58 @@
+package compute
+
+import (
+	"context"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// StartMigrationOutRequest struct to start compute for external migration out
+type StartMigrationOutRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"compute_id" json:"compute_id" validate:"required"`
+
+	// Remote libvirt host to connect to
+	// Required: true
+	Target string `url:"target" json:"target" validate:"required"`
+
+	// Graphics handling on the destination
+	// Required: true
+	Graphics string `url:"graphics" json:"graphics" validate:"required"`
+
+	// Optional new domain name on the destination
+	// Required: false
+	NewName string `url:"new_name,omitempty" json:"new_name,omitempty"`
+
+	// When true, adds libvirt's UNSAFE flag to force migration even if libvirt marks it unsafe.
+	// Default: false
+	// Required: false
+	UseUnsafe bool `url:"use_unsafe,omitempty" json:"use_unsafe,omitempty"`
+
+	// 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"`
+
+	// Mapping for CD/DVD devices or their source paths to new ISO/device paths on the destination
+	// Required: false
+	CDROMMap map[string]string `url:"cdrommap,omitempty" json:"cdrommap,omitempty"`
+}
+
+// StartMigrationOut starts compute for external migration out
+func (c Compute) StartMigrationOut(ctx context.Context, req StartMigrationOutRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return "", validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/compute/start_migration_out"
+
+	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
+	if err != nil {
+		return "", err
+	}
+
+	return string(res), nil
+}

pkg/cloudbroker/compute/stop_migration_in.go

@@ -4,9 +4,26 @@ import (
 	"context"
 	"net/http"
 
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+// OSUsers struct contains OS user data for Guest OS.
+// Must be provided if NewVMUUID is provided.
+type OSUser struct {
+	// Login of a user
+	Login string `url:"login,omitempty" json:"login,omitempty"`
+
+	// Password of a user
+	Password string `url:"password,omitempty" json:"password,omitempty"`
+
+	// GUID
+	GUID string `url:"guid,omitempty" json:"guid,omitempty"`
+
+	// Pubkey
+	Pubkey string `url:"pubkey,omitempty" json:"pubkey,omitempty"`
+}
+
 // StopMigrationINRequest struct to stop compute for external migration in
 type StopMigrationINRequest struct {
 	// ID of compute instance
@@ -16,10 +33,14 @@ type StopMigrationINRequest struct {
 	// If provided, indicates the UUID of the VM on the target host and that migration completed.
 	// Required: false
 	NewVMUUID string `url:"new_vm_uuid,omitempty" json:"new_vm_uuid,omitempty"`
+
+	// OS user data for Guest OS
+	// Required: false
+	OSUsers []OSUser `url:"os_users,omitempty" json:"os_users,omitempty"`
 }
 
 // StopMigrationIN stops compute for external migration in
-func (c Compute) StopMigrationIN(ctx context.Context, req StartRequest) (string, error) {
+func (c Compute) StopMigrationIN(ctx context.Context, req StopMigrationINRequest) (string, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		return "", validators.ValidationErrors(validators.GetErrors(err))
@@ -27,7 +48,7 @@ func (c Compute) StopMigrationIN(ctx context.Context, req StartRequest) (string,
 
 	url := "/cloudbroker/compute/stop_migration_in"
 
-	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
 	if err != nil {
 		return "", err
 	}

pkg/cloudbroker/compute/stop_migration_out.go

@@ -0,0 +1,37 @@
+package compute
+
+import (
+	"context"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/constants"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// StopMigrationOutRequest struct to stop compute for external migration out
+type StopMigrationOutRequest struct {
+	// ID of compute instance
+	// Required: true
+	ComputeID uint64 `url:"computeId" json:"computeId" validate:"required"`
+
+	// Identifier of the agent-side external migration (LibvirtMigrateToURI3Request) job
+	// Required: false
+	MigrateToURI3JobID string `url:"migrate_to_uri3_job_id,omitempty" json:"migrate_to_uri3_job_id,omitempty"`
+}
+
+// StopMigrationOut stops compute for external migration out
+func (c Compute) StopMigrationOut(ctx context.Context, req StopMigrationOutRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return "", validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/compute/stop_migration_out"
+
+	res, err := c.client.DecortApiCallCtype(ctx, http.MethodPost, url, constants.MIMEJSON, req)
+	if err != nil {
+		return "", err
+	}
+
+	return string(res), nil
+}

pkg/cloudbroker/disks/create.go

@@ -30,10 +30,6 @@ type CreateRequest struct {
 	// Required: false
 	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
 
-	// Max IOPS disk can perform defaults to 2000
-	// Required: false
-	IOPS uint64 `url:"iops,omitempty" json:"iops,omitempty"`
-
 	// Storage endpoint provider ID to create disk
 	// Required: false
 	SEPID uint64 `url:"sep_id,omitempty" json:"sep_id,omitempty"`

pkg/cloudbroker/disks/migrate.go

@@ -0,0 +1,46 @@
+package disks
+
+import (
+	"context"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Migrate struct to move disk to another sep, pool and storage policy
+type MigrateRequest struct {
+	// ID of the disk
+	// Required: true
+	DiskID uint64 `url:"disk_id" json:"disk_id" validate:"required"`
+
+	// ID of the new SEP
+	// Required: true
+	SEPID uint64 `url:"sep_id" json:"sep_id" validate:"required"`
+
+	// New pool name
+	// Required: true
+	PoolName string `url:"pool_name" json:"pool_name" validate:"required"`
+
+	// ID if the storage policy
+	// Required: false
+	StoragePolicyID uint64 `url:"storage_policy_id,omitempty" json:"storage_policy_id,omitempty"`
+}
+
+// Move moves disk to another sep, pool and storage policy
+func (c Disks) Migrate(ctx context.Context, req MigrateRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return "", validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/disks/migrate"
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return "", err
+	}
+
+	result := string(res)
+
+	return result, nil
+}

pkg/cloudbroker/disks/migrate_abort.go

@@ -0,0 +1,38 @@
+package disks
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// MigrateAbortRequest struct to abort migration
+type MigrateAbortRequest struct {
+	// ID of the disk
+	// Required: true
+	DiskID uint64 `url:"disk_id" json:"disk_id" validate:"required"`
+}
+
+// MigrateAbort aborts disk migration
+func (c Disks) MigrateAbort(ctx context.Context, req MigrateAbortRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/disks/migrate_abort"
+
+	res, err := c.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/disks/migrate_status.go

@@ -0,0 +1,40 @@
+package disks
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// GetMigrateStatusRequest struct to get information about disk migrate status
+type GetMigrateStatusRequest struct {
+	// ID of disk
+	// Required: true
+	DiskID uint64 `url:"disk_id" json:"disk_id" validate:"required"`
+}
+
+// GetMigrateStatus gets information about disk migrate status
+func (c Disks) GetMigrateStatus(ctx context.Context, req GetMigrateStatusRequest) (*MigrateStatus, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return nil, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/disks/migrate_status"
+
+	res, err := c.client.DecortApiCall(ctx, http.MethodGet, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	status := MigrateStatus{}
+
+	err = json.Unmarshal(res, &status)
+	if err != nil {
+		return nil, err
+	}
+
+	return &status, nil
+}

pkg/cloudbroker/disks/models.go

@@ -320,3 +320,20 @@ type ListTypes struct {
 	// Entry count
 	EntryCount uint64 `json:"entryCount"`
 }
+
+type MigrateStatus struct {
+	// Type
+	Type int `json:"type"`
+
+	// Copy speed
+	Bandwidth int `json:"bandwidth"`
+
+	// Current progress
+	Cur interface{} `json:"cur"`
+
+	// Total size
+	End interface{} `json:"end"`
+
+	// Progress percent
+	ProgressPercent int `json:"progress_percent"`
+}

pkg/cloudbroker/image/create_cdrom_image.go

@@ -2,6 +2,7 @@ package image
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
 	"strconv"
 
@@ -43,6 +44,11 @@ type CreateCDROMImageRequest struct {
 	PasswordDl string `url:"passwordDL,omitempty" json:"passwordDL,omitempty"`
 }
 
+type asyncWrapperCreateCDROMImageRequest struct {
+	CreateCDROMImageRequest
+	AsyncMode bool `url:"asyncMode"`
+}
+
 // CreateCDROMImage creates CD-ROM image from an ISO identified by URL
 func (i Image) CreateCDROMImage(ctx context.Context, req CreateCDROMImageRequest) (uint64, error) {
 	err := validators.ValidateRequest(req)
@@ -52,7 +58,9 @@ func (i Image) CreateCDROMImage(ctx context.Context, req CreateCDROMImageRequest
 
 	url := "/cloudbroker/image/createCDROMImage"
 
-	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	syncReq := asyncWrapperCreateCDROMImageRequest{CreateCDROMImageRequest: req, AsyncMode: false}
+
+	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, syncReq)
 	if err != nil {
 		return 0, err
 	}
@@ -64,3 +72,29 @@ func (i Image) CreateCDROMImage(ctx context.Context, req CreateCDROMImageRequest
 
 	return result, nil
 }
+
+// AsyncCreateCDROMImage creates CD-ROM image from an ISO identified by URL in async mode
+func (i Image) AsyncCreateCDROMImage(ctx context.Context, req CreateCDROMImageRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return "", validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/image/createCDROMImage"
+
+	asyncReq := asyncWrapperCreateCDROMImageRequest{CreateCDROMImageRequest: req, AsyncMode: true}
+
+	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, asyncReq)
+	if err != nil {
+		return " ", err
+	}
+
+	var taskID string
+
+	err = json.Unmarshal(res, &taskID)
+	if err != nil {
+		return "", err
+	}
+
+	return taskID, nil
+}

pkg/cloudbroker/image/create_image.go

@@ -11,7 +11,7 @@ import (
 
 // CreateRequest struct to create image
 type CreateRequest struct {
-	// Name of the rescue disk
+	// Name of the image
 	// Required: true
 	Name string `url:"name" json:"name" validate:"required"`
 

pkg/cloudbroker/image/list.go

@@ -69,6 +69,10 @@ type ListRequest struct {
 	// Find by enabled True or False
 	// Required: false
 	Enabled interface{} `url:"enabled,omitempty" json:"enabled,omitempty" validate:"omitempty,isBool"`
+
+	// Find by storage policy id
+	// Required: false
+	StoragePolicyID uint64 `url:"storage_policy_id,omitempty" json:"storage_policy_id,omitempty"`
 }
 
 // List gets list of information about images as a ListImages struct

pkg/cloudbroker/node/update_description.go

@@ -0,0 +1,42 @@
+package node
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// UpdateDescriptionRequest struct to update description of the node
+type UpdateDescriptionRequest struct {
+	// Node ID
+	// Required: true
+	NID uint64 `url:"nid" json:"nid" validate:"required"`
+
+	// New description for the node
+	// Required: true
+	Description string `url:"description" json:"description" validate:"required"`
+}
+
+// UpdateDescription updates description of the node
+func (n Node) UpdateDescription(ctx context.Context, req UpdateDescriptionRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		return false, validators.ValidationErrors(validators.GetErrors(err))
+	}
+
+	url := "/cloudbroker/node/update_description"
+
+	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/stpolicy/models.go

@@ -56,6 +56,9 @@ type ItemStoragePolicy struct {
 	// Max IOPS for the sotrage policy
 	LimitIOPS uint64 `json:"limit_iops"`
 
+	// Storage policy ID
+	StoragePolicyID uint64 `json:"storage_policy_id"`
+
 	// Which accounts and resource groups use the storage policy
 	Usage Usage `json:"usage"`
 }
@@ -82,6 +85,9 @@ type InfoStoragePolicy struct {
 	// Max IOPS for the storage policy
 	LimitIOPS uint64 `json:"limit_iops"`
 
+	// Storage policy ID
+	StoragePolicyID uint64 `json:"storage_policy_id"`
+
 	// Which accounts and resource groups use the storage policy
 	Usage Usage `json:"usage"`
 }

pkg/cloudbroker/vins/models.go

@@ -122,6 +122,9 @@ type ItemInterface struct {
 	// Enabled
 	Enabled bool `json:"enabled"`
 
+	// Enable security groups
+	EnableSecGroups bool `json:"enable_secgroups"`
+
 	// FLIPGroup ID
 	FLIPGroupID uint64 `json:"flipgroupId"`
 
@@ -158,6 +161,9 @@ type ItemInterface struct {
 	// NodeID
 	NodeID int64 `json:"nodeId"`
 
+	// List of security groups
+	SecGroups []uint64 `json:"security_groups"`
+
 	// SDNInterfaceID
 	SDNInterfaceID string `json:"sdn_interface_id"`
 
@@ -241,6 +247,12 @@ type VNFDev struct {
 
 	// VNC password
 	VNCPassword string `json:"vncPasswd"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
+
+	// Live migration job ID
+	LiveMigrationJobID uint64 `json:"live_migration_job_id"`
 }
 
 // Main information about reservation
@@ -421,6 +433,9 @@ type InfoVNF struct {
 
 	// Type
 	Type string `json:"type"`
+
+	// Zone ID
+	ZoneID uint64 `json:"zoneId"`
 }
 
 // List of static routes

tests/platform_upgrade/request_map.go

@@ -94,7 +94,8 @@ func getRequestsMapCloudAPI() map[string]interface{} {
 		"/restmachine/cloudapi/account/updateUser":                  account.UpdateUserRequest{},
 
 		//audit
-		"/restmachine/cloudapi/audit/get": audit.GetRequest{},
+		"/restmachine/cloudapi/audit/get":  audit.GetRequest{},
+		"/restmachine/cloudapi/audit/list": audit.ListRequest{},
 
 		//bservice
 		"/restmachine/cloudapi/bservice/create":             bservice.CreateRequest{},
@@ -148,6 +149,8 @@ func getRequestsMapCloudAPI() map[string]interface{} {
 		"/restmachine/cloudapi/compute/changeLinkState":              compute.ChangeLinkStateRequest{},
 		"/restmachine/cloudapi/compute/change_security_groups":       compute.ChangeSecGroupsRequest{},
 		"/restmachine/cloudapi/compute/clone":                        compute.CloneRequest{},
+		"/restmachine/cloudapi/compute/clone_abort":                  compute.CloneAbortRequest{},
+		"/restmachine/cloudapi/compute/clone_status":                 compute.GetCloneStatusRequest{},
 		"/restmachine/cloudapi/compute/createTemplate":               compute.CreateTemplateRequest{},
 		"/restmachine/cloudapi/compute/createTemplateFromBlank":      compute.CreateTemplateFromBlankRequest{},
 		"/restmachine/cloudapi/compute/delete":                       compute.DeleteRequest{},
@@ -382,6 +385,8 @@ func getRequestsMapCloudAPI() map[string]interface{} {
 		"/restmachine/cloudapi/rg/update":                  rg.UpdateRequest{},
 		"/restmachine/cloudapi/rg/usage":                   rg.UsageRequest{},
 		"/restmachine/cloudapi/rg/removeDefNet":            rg.RemoveDefNetRequest{},
+		"/restmachine/cloudapi/rg/add_storage_policy":      rg.AddStoragePolicyRequest{},
+		"/restmachine/cloudapi/rg/del_storage_policy":      rg.DelStoragePolicyRequest{},
 
 		// security_group
 		"/restmachine/cloudapi/security_group/create":      secgroup.CreateRequest{},
@@ -528,111 +533,113 @@ func getRequestsMapCloudbroker() map[string]interface{} {
 		"/restmachine/cloudbroker/backup/restoreDisksFromBackup": backup_cb.RestoreDisksFromBackupRequest{},
 
 		// compute_cb
-		"/restmachine/cloudapi/compute/abort_shared_snapshot_merge":   compute.AbortSharedSnapshotMergeRequest{},
-		"/restmachine/cloudapi/compute/shared_snapshot_merge_status":  compute.SharedSnapshotMergeStatusRequest{},
-		"/restmachine/cloudbroker/compute/affinityGroupCheckStart":    compute_cb.AffinityGroupCheckStartRequest{},
-		"/restmachine/cloudbroker/compute/affinityLabelRemove":        compute_cb.AffinityLabelRemoveRequest{},
-		"/restmachine/cloudbroker/compute/affinityLabelSet":           compute_cb.AffinityLabelSetRequest{},
-		"/restmachine/cloudbroker/compute/affinityRelations":          compute_cb.AffinityRelationsRequest{},
-		"/restmachine/cloudbroker/compute/affinityRuleAdd":            compute_cb.AffinityRuleAddRequest{},
-		"/restmachine/cloudbroker/compute/affinityRuleRemove":         compute_cb.AffinityRuleRemoveRequest{},
-		"/restmachine/cloudbroker/compute/affinityRulesClear":         compute_cb.AffinityRulesClearRequest{},
-		"/restmachine/cloudbroker/compute/antiAffinityRuleAdd":        compute_cb.AntiAffinityRuleAddRequest{},
-		"/restmachine/cloudbroker/compute/antiAffinityRuleRemove":     compute_cb.AntiAffinityRuleRemoveRequest{},
-		"/restmachine/cloudbroker/compute/antiAffinityRulesClear":     compute_cb.AffinityRulesClearRequest{},
-		"/restmachine/cloudbroker/compute/attachGpu":                  compute_cb.AttachGPURequest{},
-		"/restmachine/cloudbroker/compute/attachPciDevice":            compute_cb.AttachPCIDeviceRequest{},
-		"/restmachine/cloudbroker/compute/audits":                     compute_cb.AuditsRequest{},
-		"/restmachine/cloudbroker/compute/bootDiskSet":                compute_cb.BootDiskSetRequest{},
-		"/restmachine/cloudbroker/compute/bootOrderGet":               compute_cb.BootOrderGetRequest{},
-		"/restmachine/cloudbroker/compute/bootOrderSet":               compute_cb.BootOrderSetRequest{},
-		"/restmachine/cloudbroker/compute/cdEject":                    compute_cb.CDEjectRequest{},
-		"/restmachine/cloudbroker/compute/cdInsert":                   compute_cb.CDInsertRequest{},
-		"/restmachine/cloudbroker/compute/changeLinkState":            compute_cb.ChangeLinkStateRequest{},
-		"/restmachine/cloudbroker/compute/change_mtu":                 compute_cb.ChangeMTURequest{},
-		"/restmachine/cloudbroker/compute/change_security_groups":     compute_cb.ChangeSecGroupsRequest{},
-		"/restmachine/cloudbroker/compute/clone":                      compute_cb.CloneRequest{},
-		"/restmachine/cloudbroker/compute/computeciSet":               compute_cb.ComputeCISetRequest{},
-		"/restmachine/cloudbroker/compute/computeciUnset":             compute_cb.ComputeCIUnsetRequest{},
-		"/restmachine/cloudbroker/compute/createTemplate":             compute_cb.CreateTemplateRequest{},
-		"/restmachine/cloudbroker/compute/createTemplateFromBlank":    compute_cb.CreateTemplateFromBlankRequest{},
-		"/restmachine/cloudbroker/compute/delete":                     compute_cb.DeleteRequest{},
-		"/restmachine/cloudbroker/compute/deleteCustomFields":         compute_cb.DeleteCustomFieldsRequest{},
-		"/restmachine/cloudbroker/compute/detachGpu":                  compute_cb.DetachGPURequest{},
-		"/restmachine/cloudbroker/compute/detachPciDevice":            compute_cb.DetachPCIDeviceRequest{},
-		"/restmachine/cloudbroker/compute/disable":                    compute_cb.DisableRequest{},
-		"/restmachine/cloudbroker/compute/diskAdd":                    compute_cb.DiskAddRequest{},
-		"/restmachine/cloudbroker/compute/diskAttach":                 compute_cb.DiskAttachRequest{},
-		"/restmachine/cloudbroker/compute/diskDel":                    compute_cb.DiskDelRequest{},
-		"/restmachine/cloudbroker/compute/diskDetach":                 compute_cb.DiskDetachRequest{},
-		"/restmachine/cloudbroker/compute/diskMigrate":                compute_cb.DiskMigrateRequest{},
-		"/restmachine/cloudbroker/compute/diskResize":                 compute_cb.DiskResizeRequest{},
-		"/restmachine/cloudbroker/compute/diskSwitchToReplication":    compute_cb.DiskSwitchToReplicationRequest{},
-		"/restmachine/cloudbroker/compute/diskQos":                    compute_cb.DiskQOSRequest{},
-		"/restmachine/cloudbroker/compute/enable":                     compute_cb.EnableRequest{},
-		"/restmachine/cloudbroker/compute/get":                        compute_cb.GetRequest{},
-		"/restmachine/cloudbroker/compute/getAudits":                  compute_cb.GetAuditsRequest{},
-		"/restmachine/cloudbroker/compute/getConsoleUrl":              compute_cb.GetConsoleURLRequest{},
-		"/restmachine/cloudbroker/compute/getCustomFields":            compute_cb.GetCustomFieldsRequest{},
-		"/restmachine/cloudbroker/compute/getLog":                     compute_cb.GetLogRequest{},
-		"/restmachine/cloudbroker/compute/list":                       compute_cb.ListRequest{},
-		"/restmachine/cloudbroker/compute/listDeleted":                compute_cb.ListDeletedRequest{},
-		"/restmachine/cloudbroker/compute/listPciDevice":              compute_cb.ListPCIDeviceRequest{},
-		"/restmachine/cloudbroker/compute/listVGpu":                   compute_cb.ListVGPURequest{},
-		"/restmachine/cloudbroker/compute/massDelete":                 compute_cb.MassDeleteRequest{},
-		"/restmachine/cloudbroker/compute/massStart":                  compute_cb.MassStartRequest{},
-		"/restmachine/cloudbroker/compute/massStop":                   compute_cb.MassStopRequest{},
-		"/restmachine/cloudbroker/compute/massReboot":                 compute_cb.MassRebootRequest{},
-		"/restmachine/cloudbroker/compute/migrate":                    compute_cb.MigrateRequest{},
-		"/restmachine/cloudbroker/compute/migrateStorage":             compute_cb.MigrateStorageRequest{},
-		"/restmachine/cloudbroker/compute/migrateStorageAbort":        compute_cb.MigrateStorageAbortRequest{},
-		"/restmachine/cloudbroker/compute/migrateStorageCleanup":      compute_cb.MigrateStorageCleanUpRequest{},
-		"/restmachine/cloudbroker/compute/migrateStorageInfo":         compute_cb.MigrateStorageInfoRequest{},
-		"/restmachine/cloudbroker/compute/migrate_storage_list":       compute_cb.MigrateStorageListRequest{},
-		"/restmachine/cloudbroker/compute/moveToRg":                   compute_cb.MoveToRGRequest{},
-		"/restmachine/cloudbroker/compute/netAttach":                  compute_cb.NetAttachRequest{},
-		"/restmachine/cloudbroker/compute/netDetach":                  compute_cb.NetDetachRequest{},
-		"/restmachine/cloudbroker/compute/netQos":                     compute_cb.NetQOSRequest{},
-		"/restmachine/cloudbroker/compute/pfwAdd":                     compute_cb.PFWAddRequest{},
-		"/restmachine/cloudbroker/compute/pfwDel":                     compute_cb.PFWDelRequest{},
-		"/restmachine/cloudbroker/compute/pfwList":                    compute_cb.PFWListRequest{},
-		"/restmachine/cloudbroker/compute/pause":                      compute_cb.PauseRequest{},
-		"/restmachine/cloudbroker/compute/pinToStack":                 compute_cb.PinToStackRequest{},
-		"/restmachine/cloudbroker/compute/powerCycle":                 compute_cb.PowerCycleRequest{},
-		"/restmachine/cloudbroker/compute/raiseDown":                  EmptyStruct{},
-		"/restmachine/cloudbroker/compute/reboot":                     compute_cb.RebootRequest{},
-		"/restmachine/cloudbroker/compute/redeploy":                   compute_cb.RedeployRequest{},
-		"/restmachine/cloudbroker/compute/reset":                      compute_cb.ResetRequest{},
-		"/restmachine/cloudbroker/compute/resize":                     compute_cb.ResizeRequest{},
-		"/restmachine/cloudbroker/compute/restore":                    compute_cb.RestoreRequest{},
-		"/restmachine/cloudbroker/compute/resume":                     compute_cb.ResumeRequest{},
-		"/restmachine/cloudbroker/compute/setCustomFields":            compute_cb.SetCustomFieldsRequest{},
-		"/restmachine/cloudbroker/compute/snapshotCreate":             compute_cb.SnapshotCreateRequest{},
-		"/restmachine/cloudbroker/compute/snapshotDelete":             compute_cb.SnapshotDeleteRequest{},
-		"/restmachine/cloudbroker/compute/snapshotEvictDisk":          compute_cb.SnapshotEvictDiskRequest{},
-		"/restmachine/cloudbroker/compute/snapshotList":               compute_cb.SnapshotListRequest{},
-		"/restmachine/cloudbroker/compute/snapshotRollback":           compute_cb.SnapshotRollbackRequest{},
-		"/restmachine/cloudbroker/compute/snapshotUsage":              compute_cb.SnapshotUsageRequest{},
-		"/restmachine/cloudbroker/compute/start":                      compute_cb.StartRequest{},
-		"/restmachine/cloudbroker/compute/start_migration_in":         compute_cb.StartMigrationINRequest{},
-		"/restmachine/cloudbroker/compute/stop":                       compute_cb.StopRequest{},
-		"/restmachine/cloudbroker/compute/stop_migration_in":          compute_cb.StopMigrationINRequest{},
-		"/restmachine/cloudbroker/compute/tagAdd":                     compute_cb.TagAddRequest{},
-		"/restmachine/cloudbroker/compute/tagRemove":                  compute_cb.TagRemoveRequest{},
-		"/restmachine/cloudbroker/compute/unpinFromStack":             compute_cb.UnpinFromStackRequest{},
-		"/restmachine/cloudbroker/compute/update":                     compute_cb.UpdateRequest{},
-		"/restmachine/cloudbroker/compute/userGrant":                  compute_cb.UserGrantRequest{},
-		"/restmachine/cloudbroker/compute/userList":                   compute_cb.UserListRequest{},
-		"/restmachine/cloudbroker/compute/userRevoke":                 compute_cb.UserRevokeRequest{},
-		"/restmachine/cloudbroker/compute/userUpdate":                 compute_cb.UserUpdateRequest{},
-		"/restmachine/cloudbroker/compute/changeIp":                   compute_cb.ChangeIPRequest{},
-		"/restmachine/cloudbroker/compute/changeMac":                  compute_cb.ChangeMACRequest{},
-		"/restmachine/cloudbroker/compute/setNetConfig":               compute_cb.SetNetConfigRequest{},
-		"/restmachine/cloudbroker/compute/guest_agent_disable":        compute_cb.GuestAgentDisableRequest{},
-		"/restmachine/cloudbroker/compute/guest_agent_enable":         compute_cb.GuestAgentEnableRequest{},
-		"/restmachine/cloudbroker/compute/guest_agent_execute":        compute_cb.GuestAgentExecuteRequest{},
-		"/restmachine/cloudbroker/compute/guest_agent_feature_get":    compute_cb.GuestAgentFeatureGetRequest{},
-		"/restmachine/cloudbroker/compute/guest_agent_feature_update": compute_cb.GuestAgentFeatureUpdateRequest{},
+		"/restmachine/cloudbroker/compute/abort_shared_snapshot_merge":  compute_cb.AbortSharedSnapshotMergeRequest{},
+		"/restmachine/cloudbroker/compute/shared_snapshot_merge_status": compute_cb.SharedSnapshotMergeStatusRequest{},
+		"/restmachine/cloudbroker/compute/affinityGroupCheckStart":      compute_cb.AffinityGroupCheckStartRequest{},
+		"/restmachine/cloudbroker/compute/affinityLabelRemove":          compute_cb.AffinityLabelRemoveRequest{},
+		"/restmachine/cloudbroker/compute/affinityLabelSet":             compute_cb.AffinityLabelSetRequest{},
+		"/restmachine/cloudbroker/compute/affinityRelations":            compute_cb.AffinityRelationsRequest{},
+		"/restmachine/cloudbroker/compute/affinityRuleAdd":              compute_cb.AffinityRuleAddRequest{},
+		"/restmachine/cloudbroker/compute/affinityRuleRemove":           compute_cb.AffinityRuleRemoveRequest{},
+		"/restmachine/cloudbroker/compute/affinityRulesClear":           compute_cb.AffinityRulesClearRequest{},
+		"/restmachine/cloudbroker/compute/antiAffinityRuleAdd":          compute_cb.AntiAffinityRuleAddRequest{},
+		"/restmachine/cloudbroker/compute/antiAffinityRuleRemove":       compute_cb.AntiAffinityRuleRemoveRequest{},
+		"/restmachine/cloudbroker/compute/antiAffinityRulesClear":       compute_cb.AffinityRulesClearRequest{},
+		"/restmachine/cloudbroker/compute/attachGpu":                    compute_cb.AttachGPURequest{},
+		"/restmachine/cloudbroker/compute/attachPciDevice":              compute_cb.AttachPCIDeviceRequest{},
+		"/restmachine/cloudbroker/compute/audits":                       compute_cb.AuditsRequest{},
+		"/restmachine/cloudbroker/compute/bootDiskSet":                  compute_cb.BootDiskSetRequest{},
+		"/restmachine/cloudbroker/compute/bootOrderGet":                 compute_cb.BootOrderGetRequest{},
+		"/restmachine/cloudbroker/compute/bootOrderSet":                 compute_cb.BootOrderSetRequest{},
+		"/restmachine/cloudbroker/compute/cdEject":                      compute_cb.CDEjectRequest{},
+		"/restmachine/cloudbroker/compute/cdInsert":                     compute_cb.CDInsertRequest{},
+		"/restmachine/cloudbroker/compute/changeLinkState":              compute_cb.ChangeLinkStateRequest{},
+		"/restmachine/cloudbroker/compute/change_mtu":                   compute_cb.ChangeMTURequest{},
+		"/restmachine/cloudbroker/compute/change_security_groups":       compute_cb.ChangeSecGroupsRequest{},
+		"/restmachine/cloudbroker/compute/clone":                        compute_cb.CloneRequest{},
+		"/restmachine/cloudbroker/compute/clone_abort":                  compute_cb.CloneAbortRequest{},
+		"/restmachine/cloudbroker/compute/clone_status":                 compute_cb.GetCloneStatusRequest{},
+		"/restmachine/cloudbroker/compute/computeciSet":                 compute_cb.ComputeCISetRequest{},
+		"/restmachine/cloudbroker/compute/computeciUnset":               compute_cb.ComputeCIUnsetRequest{},
+		"/restmachine/cloudbroker/compute/createTemplate":               compute_cb.CreateTemplateRequest{},
+		"/restmachine/cloudbroker/compute/createTemplateFromBlank":      compute_cb.CreateTemplateFromBlankRequest{},
+		"/restmachine/cloudbroker/compute/delete":                       compute_cb.DeleteRequest{},
+		"/restmachine/cloudbroker/compute/deleteCustomFields":           compute_cb.DeleteCustomFieldsRequest{},
+		"/restmachine/cloudbroker/compute/detachGpu":                    compute_cb.DetachGPURequest{},
+		"/restmachine/cloudbroker/compute/detachPciDevice":              compute_cb.DetachPCIDeviceRequest{},
+		"/restmachine/cloudbroker/compute/disable":                      compute_cb.DisableRequest{},
+		"/restmachine/cloudbroker/compute/diskAdd":                      compute_cb.DiskAddRequest{},
+		"/restmachine/cloudbroker/compute/diskAttach":                   compute_cb.DiskAttachRequest{},
+		"/restmachine/cloudbroker/compute/diskDel":                      compute_cb.DiskDelRequest{},
+		"/restmachine/cloudbroker/compute/diskDetach":                   compute_cb.DiskDetachRequest{},
+		"/restmachine/cloudbroker/compute/diskMigrate":                  compute_cb.DiskMigrateRequest{},
+		"/restmachine/cloudbroker/compute/diskResize":                   compute_cb.DiskResizeRequest{},
+		"/restmachine/cloudbroker/compute/diskSwitchToReplication":      compute_cb.DiskSwitchToReplicationRequest{},
+		"/restmachine/cloudbroker/compute/diskQos":                      compute_cb.DiskQOSRequest{},
+		"/restmachine/cloudbroker/compute/enable":                       compute_cb.EnableRequest{},
+		"/restmachine/cloudbroker/compute/get":                          compute_cb.GetRequest{},
+		"/restmachine/cloudbroker/compute/getAudits":                    compute_cb.GetAuditsRequest{},
+		"/restmachine/cloudbroker/compute/getConsoleUrl":                compute_cb.GetConsoleURLRequest{},
+		"/restmachine/cloudbroker/compute/getCustomFields":              compute_cb.GetCustomFieldsRequest{},
+		"/restmachine/cloudbroker/compute/getLog":                       compute_cb.GetLogRequest{},
+		"/restmachine/cloudbroker/compute/list":                         compute_cb.ListRequest{},
+		"/restmachine/cloudbroker/compute/listDeleted":                  compute_cb.ListDeletedRequest{},
+		"/restmachine/cloudbroker/compute/listPciDevice":                compute_cb.ListPCIDeviceRequest{},
+		"/restmachine/cloudbroker/compute/listVGpu":                     compute_cb.ListVGPURequest{},
+		"/restmachine/cloudbroker/compute/massDelete":                   compute_cb.MassDeleteRequest{},
+		"/restmachine/cloudbroker/compute/massStart":                    compute_cb.MassStartRequest{},
+		"/restmachine/cloudbroker/compute/massStop":                     compute_cb.MassStopRequest{},
+		"/restmachine/cloudbroker/compute/massReboot":                   compute_cb.MassRebootRequest{},
+		"/restmachine/cloudbroker/compute/migrate":                      compute_cb.MigrateRequest{},
+		"/restmachine/cloudbroker/compute/migrateStorage":               compute_cb.MigrateStorageRequest{},
+		"/restmachine/cloudbroker/compute/migrateStorageAbort":          compute_cb.MigrateStorageAbortRequest{},
+		"/restmachine/cloudbroker/compute/migrateStorageCleanup":        compute_cb.MigrateStorageCleanUpRequest{},
+		"/restmachine/cloudbroker/compute/migrateStorageInfo":           compute_cb.MigrateStorageInfoRequest{},
+		"/restmachine/cloudbroker/compute/migrate_storage_list":         compute_cb.MigrateStorageListRequest{},
+		"/restmachine/cloudbroker/compute/moveToRg":                     compute_cb.MoveToRGRequest{},
+		"/restmachine/cloudbroker/compute/netAttach":                    compute_cb.NetAttachRequest{},
+		"/restmachine/cloudbroker/compute/netDetach":                    compute_cb.NetDetachRequest{},
+		"/restmachine/cloudbroker/compute/netQos":                       compute_cb.NetQOSRequest{},
+		"/restmachine/cloudbroker/compute/pfwAdd":                       compute_cb.PFWAddRequest{},
+		"/restmachine/cloudbroker/compute/pfwDel":                       compute_cb.PFWDelRequest{},
+		"/restmachine/cloudbroker/compute/pfwList":                      compute_cb.PFWListRequest{},
+		"/restmachine/cloudbroker/compute/pause":                        compute_cb.PauseRequest{},
+		"/restmachine/cloudbroker/compute/pinToStack":                   compute_cb.PinToStackRequest{},
+		"/restmachine/cloudbroker/compute/powerCycle":                   compute_cb.PowerCycleRequest{},
+		"/restmachine/cloudbroker/compute/raiseDown":                    EmptyStruct{},
+		"/restmachine/cloudbroker/compute/reboot":                       compute_cb.RebootRequest{},
+		"/restmachine/cloudbroker/compute/redeploy":                     compute_cb.RedeployRequest{},
+		"/restmachine/cloudbroker/compute/reset":                        compute_cb.ResetRequest{},
+		"/restmachine/cloudbroker/compute/resize":                       compute_cb.ResizeRequest{},
+		"/restmachine/cloudbroker/compute/restore":                      compute_cb.RestoreRequest{},
+		"/restmachine/cloudbroker/compute/resume":                       compute_cb.ResumeRequest{},
+		"/restmachine/cloudbroker/compute/setCustomFields":              compute_cb.SetCustomFieldsRequest{},
+		"/restmachine/cloudbroker/compute/snapshotCreate":               compute_cb.SnapshotCreateRequest{},
+		"/restmachine/cloudbroker/compute/snapshotDelete":               compute_cb.SnapshotDeleteRequest{},
+		"/restmachine/cloudbroker/compute/snapshotEvictDisk":            compute_cb.SnapshotEvictDiskRequest{},
+		"/restmachine/cloudbroker/compute/snapshotList":                 compute_cb.SnapshotListRequest{},
+		"/restmachine/cloudbroker/compute/snapshotRollback":             compute_cb.SnapshotRollbackRequest{},
+		"/restmachine/cloudbroker/compute/snapshotUsage":                compute_cb.SnapshotUsageRequest{},
+		"/restmachine/cloudbroker/compute/start":                        compute_cb.StartRequest{},
+		"/restmachine/cloudbroker/compute/start_migration_in":           compute_cb.StartMigrationINRequest{},
+		"/restmachine/cloudbroker/compute/stop":                         compute_cb.StopRequest{},
+		"/restmachine/cloudbroker/compute/stop_migration_in":            compute_cb.StopMigrationINRequest{},
+		"/restmachine/cloudbroker/compute/tagAdd":                       compute_cb.TagAddRequest{},
+		"/restmachine/cloudbroker/compute/tagRemove":                    compute_cb.TagRemoveRequest{},
+		"/restmachine/cloudbroker/compute/unpinFromStack":               compute_cb.UnpinFromStackRequest{},
+		"/restmachine/cloudbroker/compute/update":                       compute_cb.UpdateRequest{},
+		"/restmachine/cloudbroker/compute/userGrant":                    compute_cb.UserGrantRequest{},
+		"/restmachine/cloudbroker/compute/userList":                     compute_cb.UserListRequest{},
+		"/restmachine/cloudbroker/compute/userRevoke":                   compute_cb.UserRevokeRequest{},
+		"/restmachine/cloudbroker/compute/userUpdate":                   compute_cb.UserUpdateRequest{},
+		"/restmachine/cloudbroker/compute/changeIp":                     compute_cb.ChangeIPRequest{},
+		"/restmachine/cloudbroker/compute/changeMac":                    compute_cb.ChangeMACRequest{},
+		"/restmachine/cloudbroker/compute/setNetConfig":                 compute_cb.SetNetConfigRequest{},
+		"/restmachine/cloudbroker/compute/guest_agent_disable":          compute_cb.GuestAgentDisableRequest{},
+		"/restmachine/cloudbroker/compute/guest_agent_enable":           compute_cb.GuestAgentEnableRequest{},
+		"/restmachine/cloudbroker/compute/guest_agent_execute":          compute_cb.GuestAgentExecuteRequest{},
+		"/restmachine/cloudbroker/compute/guest_agent_feature_get":      compute_cb.GuestAgentFeatureGetRequest{},
+		"/restmachine/cloudbroker/compute/guest_agent_feature_update":   compute_cb.GuestAgentFeatureUpdateRequest{},
 
 		// disks
 		"/restmachine/cloudbroker/disks/change_disk_storage_policy": disks_cb.ChangeDiskStoragePolicyRequest{},
@@ -663,6 +670,9 @@ func getRequestsMapCloudbroker() map[string]interface{} {
 		"/restmachine/cloudbroker/disks/snapshotDelete":             disks_cb.SnapshotDeleteRequest{},
 		"/restmachine/cloudbroker/disks/snapshotRollback":           disks_cb.SnapshotRollbackRequest{},
 		"/restmachine/cloudbroker/disks/unshare":                    disks_cb.UnshareRequest{},
+		"/restmachine/cloudbroker/disks/migrate":                    disks_cb.MigrateRequest{},
+		"/restmachine/cloudbroker/disks/migrate_abort":              disks_cb.MigrateAbortRequest{},
+		"/restmachine/cloudbroker/disks/migrate_status":             disks_cb.GetMigrateStatusRequest{},
 
 		// dpdknet
 		"/restmachine/cloudbroker/dpdknet/get":     dpdknet_cb.GetRequest{},
@@ -840,23 +850,24 @@ func getRequestsMapCloudbroker() map[string]interface{} {
 		"/restmachine/cloudbroker/lb/updateSysctlParams":    lb_cb.UpdateSysctParamsRequest{},
 
 		// node
-		"/restmachine/cloudbroker/node/add_ssh_identity": node_cb.AddSSHIdentityRequest{},
-		"/restmachine/cloudbroker/node/applyIpmiAction":  node_cb.ApplyIpmiActionRequest{},
-		"/restmachine/cloudbroker/node/consumption":      node_cb.ConsumptionRequest{},
-		"/restmachine/cloudbroker/node/decommission":     node_cb.DecommissionRequest{},
-		"/restmachine/cloudbroker/node/enable":           node_cb.EnableRequest{},
-		"/restmachine/cloudbroker/node/enableNodes":      node_cb.EnableNodesRequest{},
-		"/restmachine/cloudbroker/node/get":              node_cb.GetRequest{},
-		"/restmachine/cloudbroker/node/get_ssh_identity": node_cb.GetSSHIdentityRequest{},
-		"/restmachine/cloudbroker/node/list":             node_cb.ListRequest{},
-		"/restmachine/cloudbroker/node/maintenance":      node_cb.MaintenanceRequest{},
-		"/restmachine/cloudbroker/node/restrict":         node_cb.RestrictRequest{},
-		"/restmachine/cloudbroker/node/setCoreIsolation": node_cb.SetCoreIsolationRequest{},
-		"/restmachine/cloudbroker/node/setHugePages":     node_cb.SetHugePagesRequest{},
-		"/restmachine/cloudbroker/node/setsriovstatus":   node_cb.SetSRIOVStatusRequest{},
-		"/restmachine/cloudbroker/node/setVFsNumber":     node_cb.SetVFsNumberRequest{},
-		"/restmachine/cloudbroker/node/update":           node_cb.UpdateRequest{},
-		"/restmachine/cloudbroker/node/setVFsParams":     node_cb.VFParam{},
+		"/restmachine/cloudbroker/node/add_ssh_identity":   node_cb.AddSSHIdentityRequest{},
+		"/restmachine/cloudbroker/node/applyIpmiAction":    node_cb.ApplyIpmiActionRequest{},
+		"/restmachine/cloudbroker/node/consumption":        node_cb.ConsumptionRequest{},
+		"/restmachine/cloudbroker/node/decommission":       node_cb.DecommissionRequest{},
+		"/restmachine/cloudbroker/node/enable":             node_cb.EnableRequest{},
+		"/restmachine/cloudbroker/node/enableNodes":        node_cb.EnableNodesRequest{},
+		"/restmachine/cloudbroker/node/get":                node_cb.GetRequest{},
+		"/restmachine/cloudbroker/node/get_ssh_identity":   node_cb.GetSSHIdentityRequest{},
+		"/restmachine/cloudbroker/node/list":               node_cb.ListRequest{},
+		"/restmachine/cloudbroker/node/maintenance":        node_cb.MaintenanceRequest{},
+		"/restmachine/cloudbroker/node/restrict":           node_cb.RestrictRequest{},
+		"/restmachine/cloudbroker/node/setCoreIsolation":   node_cb.SetCoreIsolationRequest{},
+		"/restmachine/cloudbroker/node/setHugePages":       node_cb.SetHugePagesRequest{},
+		"/restmachine/cloudbroker/node/setsriovstatus":     node_cb.SetSRIOVStatusRequest{},
+		"/restmachine/cloudbroker/node/setVFsNumber":       node_cb.SetVFsNumberRequest{},
+		"/restmachine/cloudbroker/node/update":             node_cb.UpdateRequest{},
+		"/restmachine/cloudbroker/node/update_description": node_cb.UpdateDescriptionRequest{},
+		"/restmachine/cloudbroker/node/setVFsParams":       node_cb.VFParam{},
 
 		// pcidevice
 		"/restmachine/cloudbroker/pcidevice/create":  pcidevice_cb.CreateRequest{},