v1.6.0

CHANGELOG.md

@@ -1,7 +1,52 @@
-## Version 1.5.12
+## Version 1.6.0
 
 ### Bugfix
-- Fix unhandled error in do() method for client and legacy-client
+- Fix client and legacy-client, the cyclicity of sending requests has been removed
-
+- Edit description field SSLSkipVerify in config/config and config/legacy-config
+- Remove tags required fields ExtNetID VINSID Start in model CreateRequest in cloudapi/lb/create and cloudbroker/lb/create
+- Add tags required fields BindingName BindingAddress BindingPort in model FrontendBindRequest in cloudapi/lb/frontend_bind 
+- Add tags required fields BindingAddress BindingPort in model FrontendBindUpdateRequest in cloudapi/lb/frontend_bind_update
+- Remove tags omitempty in field Start in model kvmx86 and kvmppc in cloudapi and cloudbroker /create /mass_create
+- Add field Driver in models cloudbroker/kvmx86/create and cloudbroker/kvmx86/create_blank
+- Add field ExternalIp in model ItemDetailedInfo cloudbroker/k8s/models and cloudapi/k8s/models 
+- Add fields StackID and Reason in model CreateRequest cloudbroker/kvmppc
+
+### Feature
+- Add field UserData in cloudapi/bservice/group_add
+- Add fields VinsId, LbSysctlParams, HighlyAvailable, AdditionalSANs, InitConfiguration, ClusterConfiguration, KubeletConfiguration, KubeProxyConfiguration, JoinConfiguration, UserData, ExtNetOnly, OidcCertificate in model request cloudapi/k8s/create and cloudbroker/k8s/create  
+- Add fields SysctlParams, HighlyAvailable in model CreateRequest in cloudapi/lb/create and cloudbroker/lb/create
+- Add fields BackendHAIP, FrontendHAIP, PartK8s, SysctlParams in model RecordLB in cloudapi/lb/models and cloudbroker/lb/models
+- Add models InfoStack, ItemStack, ListStacks cloudapi/stack/models
+- Add field Routes and type Route in CreateInAccountRequest and CreateInRGRequest models in cloudapi/vins/create_in_rg and /cloudapi/vins/create_in_account
+- Add field Enabled in model ItemVNFInterface in cloudapi/vins/models 
+- Add fields Routes in models RecordNAT, RecordDHCP, RecordGW and add type ListStaticRoutes, ListRoutes, ItemRoutes in cloudapi/vins/models 
+
+- Added new endpoints:
+- cloudapi/k8s/get_worker_nodes_meta_data
+- cloudapi/k8s/update_worker_nodes_meta_data
+- cloudapi/lb/make_highly_available
+- cloudapi/lb/updateSysctParams
+- cloudapi/stack/get
+- cloudapi/stack/list
+- cloudapi/vins/static_route_list
+- cloudapi/vins/static_route_access_grant
+- cloudapi/vins/static_route_access_revoke
+- cloudapi/vins/static_route_add
+- cloudapi/vins/static_route_del
+- cloudbroker/compute/set_custom_fields
+- cloudbroker/k8s/get_worker_nodes_meta_data
+- cloudbroker/k8s/update_worker_nodes_meta_data
+- cloudbroker/lb/make_highly_available
+- cloudbroker/lb/updateSysctParams
+- cloudbroker/vins/static_route_list
+- cloudbroker/vins/static_route_access_grant
+- cloudbroker/vins/static_route_access_revoke
+- cloudbroker/vins/static_route_add
+- cloudbroker/vins/static_route_del
+- cloudbroker/extnet/static_route_list
+- cloudbroker/extnet/static_route_access_grant
+- cloudbroker/extnet/static_route_access_revoke
+- cloudbroker/extnet/static_route_add
+- cloudbroker/extnet/static_route_del
 
 

README.md

@@ -10,6 +10,7 @@ Decort SDK - это библиотека, написанная на языке G
     - Версия 1.3.x Decort-SDK соответствует 3.8.5 версии платформы
     - Версия 1.4.x Decort-SDK соответствует 3.8.6 версии платформы
     - Версия 1.5.x Decort-SDK соответствует 3.8.7 версии платформы
+    - Версия 1.6.x Decort-SDK соответствует 3.8.8 версии платформы
 
 ## Оглавление
 
@@ -74,6 +75,7 @@ go get -u repository.basistech.ru/BASIS/decort-golang-sdk
 - `Locations` - получение информации о grid площадки;
 - `RG` - управление ресурсными группами аккаунта;
 - `Sizes` - получение информации о потребляемых ресурсах виртуальными машинами и дисками;
+- `Stack` - получение информации о вычислительных узлах;
 - `Tasks` - получение информации о ходе выполнения асинхронных задач (например, создание кластера);
 - `VINS` - управление виртуальными изолированными сетями.
 
@@ -100,7 +102,7 @@ go get -u repository.basistech.ru/BASIS/decort-golang-sdk
 - `PCIDevice` - управление устройствами;
 - `RG` - управление ресурсными группами аккаунта;
 - `SEP` - управление storage endpoint (sep);
-- `Stack` - получение информации о стеках;
+- `Stack` - получение информации о вычислительных узлах;
 - `Tasks` - получение информации о ходе выполнения асинхронных задач (например, создание кластера);
 - `User` - управление пользователями (индивидуально);
 - `VGPU` - управление виртуальными графическими процессорами;
@@ -250,7 +252,8 @@ func main() {
   - `pkg/cloudapi/lb` - для `LB`
   - `pkg/cloudapi/locations` - для `Locations`
   - `pkg/cloudapi/rg` - для `RG`
-  - `pkg/cloudapi/sizes` - для `RG`
+  - `pkg/cloudapi/sizes` - для `Sizes`
+  - `pkg/cloudapi/stack` - для `Stack`
   - `pkg/cloudapi/tasks` - для `Tasks`
   - `pkg/cloudapi/vins` - для `VINS`
 - **cloudbroker**:
@@ -412,7 +415,7 @@ func main() {
 
 Чтобы выполнить запрос, необходимо:
 
-1. Вызвать у клиента метод, отвечаеющий за определение группы API для взаимодействия, это может быть `.CloudAPI()`, либо `.CloudBroker()`. Данные методы возвращаеют соответствующие структуры, с помощью которых можно соверать запросы.
+1. Вызвать у клиента метод, отвечаеющий за определение группы API для взаимодействия, это может быть `.CloudAPI()`, либо `.CloudBroker()`. Данные методы возвращаеют соответствующие структуры, с помощью которых можно совершать запросы.
 2. Вызвать у возвращенной структуры метод, определяющий группу ручек для взаимодействия.
 
    Доступные методы для `.CloudAPI()`:
@@ -432,6 +435,7 @@ func main() {
    - `.Locations()` - для работы с `Locations`
    - `.RG()` - для работы с `RG`
    - `.Sizes()` - для работы с `Sizes`
+   - `.Stack()` - для работы с `Stack`
    - `.Tasks()` - для работы с `Tasks`
    - `.VINS()` - для работы с `VINS`
 
@@ -465,7 +469,7 @@ func main() {
 
 - контекст;
 - структуру запроса.
-  У кождой группы ручек API имеются свои доступные методы, которые определяются платформой.
+  У каждой группы ручек API имеются свои доступные методы, которые определяются платформой.
 
 4. Обработать результат и ошибки.
 

client.go

@@ -7,14 +7,17 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"mime/multipart"
 	"net/http"
+	"strconv"
 	"strings"
 	"sync"
 	"time"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi"
+	k8s_ca "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/k8s"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker"
-
+	k8s_cb"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/k8s"
 	"github.com/google/go-querystring/query"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/config"
 )
@@ -68,6 +71,283 @@ func (dc *DecortClient) CloudBroker() *cloudbroker.CloudBroker {
 
 // DecortApiCall method for sending requests to the platform
 func (dc *DecortClient) DecortApiCall(ctx context.Context, method, url string, params interface{}) ([]byte, error) {
+	k8sCaCreateReq, okCa := params.(k8s_ca.CreateRequest)
+	k8sCbCreateReq, okCb := params.(k8s_cb.CreateRequest)
+
+	if okCa {
+		reqBody := &bytes.Buffer{}
+		writer := multipart.NewWriter(reqBody)
+		if k8sCaCreateReq.OidcCertificate != "" {
+			part, _ := writer.CreateFormFile("oidcCertificate", "ca.crt")
+			_, _ = io.Copy(part, strings.NewReader(k8sCaCreateReq.OidcCertificate))
+		}
+
+		_ = writer.WriteField("name", k8sCaCreateReq.Name)
+		_ = writer.WriteField("rgId", strconv.FormatUint(k8sCaCreateReq.RGID, 10))
+		_ = writer.WriteField("k8ciId", strconv.FormatUint(k8sCaCreateReq.K8SCIID, 10))
+		_ = writer.WriteField("workerGroupName", k8sCaCreateReq.WorkerGroupName)
+		_ = writer.WriteField("networkPlugin", k8sCaCreateReq.NetworkPlugin)
+
+		if k8sCaCreateReq.MasterSEPID != 0 {
+			_ = writer.WriteField("masterSepId", strconv.FormatUint(k8sCaCreateReq.MasterSEPID, 10))
+		}
+		if k8sCaCreateReq.MasterSEPPool != "" {
+			_ = writer.WriteField("masterSepPool", k8sCaCreateReq.MasterSEPPool)
+		}
+		if k8sCaCreateReq.WorkerSEPID != 0 {
+			_ = writer.WriteField("workerSepId", strconv.FormatUint(k8sCaCreateReq.WorkerSEPID, 10))
+		}
+		if k8sCaCreateReq.WorkerSEPPool != "" {
+			_ = writer.WriteField("workerSepPool", k8sCaCreateReq.WorkerSEPPool)
+		}
+
+		if k8sCaCreateReq.Labels != nil {
+			for _, v := range k8sCaCreateReq.Labels {
+				_ = writer.WriteField("labels", v)
+			}
+		}
+		if k8sCaCreateReq.Taints != nil {
+			for _, v := range k8sCaCreateReq.Taints {
+				_ = writer.WriteField("taints", v)
+			}
+		}
+		if k8sCaCreateReq.Annotations != nil {
+			for _, v := range k8sCaCreateReq.Annotations {
+				_ = writer.WriteField("annotations", v)
+			}
+		}
+
+		if k8sCaCreateReq.MasterCPU != 0 {
+			_ = writer.WriteField("masterCpu", strconv.FormatUint(uint64(k8sCaCreateReq.MasterCPU), 10))
+		}
+		if k8sCaCreateReq.MasterNum != 0 {
+			_ = writer.WriteField("masterNum", strconv.FormatUint(uint64(k8sCaCreateReq.MasterNum), 10))
+		}
+		if k8sCaCreateReq.MasterRAM != 0 {
+			_ = writer.WriteField("masterRam", strconv.FormatUint(uint64(k8sCaCreateReq.MasterRAM), 10))
+		}
+		if k8sCaCreateReq.MasterDisk != 0 {
+			_ = writer.WriteField("masterDisk", strconv.FormatUint(uint64(k8sCaCreateReq.MasterDisk), 10))
+		}
+		if k8sCaCreateReq.WorkerCPU != 0 {
+			_ = writer.WriteField("workerCpu", strconv.FormatUint(uint64(k8sCaCreateReq.WorkerCPU), 10))
+		}
+		if k8sCaCreateReq.WorkerNum != 0 {
+			_ = writer.WriteField("workerNum", strconv.FormatUint(uint64(k8sCaCreateReq.WorkerNum), 10))
+		}
+		if k8sCaCreateReq.WorkerRAM != 0 {
+			_ = writer.WriteField("workerRam", strconv.FormatUint(uint64(k8sCaCreateReq.WorkerRAM), 10))
+		}
+		if k8sCaCreateReq.WorkerDisk != 0 {
+			_ = writer.WriteField("workerDisk", strconv.FormatUint(uint64(k8sCaCreateReq.WorkerDisk), 10))
+		}
+		if k8sCaCreateReq.ExtNetID != 0 {
+			_ = writer.WriteField("extnetId", strconv.FormatUint(k8sCaCreateReq.ExtNetID, 10))
+		}
+		if k8sCaCreateReq.VinsId != 0 {
+			_ = writer.WriteField("vinsId", strconv.FormatUint(k8sCaCreateReq.VinsId, 10))
+		}
+		if !k8sCaCreateReq.WithLB {
+			_ = writer.WriteField("withLB", strconv.FormatBool(k8sCaCreateReq.WithLB))
+		}
+
+		_ = writer.WriteField("highlyAvailable", strconv.FormatBool(k8sCaCreateReq.HighlyAvailable))
+
+		if k8sCaCreateReq.AdditionalSANs != nil {
+			for _, v := range k8sCaCreateReq.AdditionalSANs {
+				_ = writer.WriteField("additionalSANs", v)
+			}
+		}
+		if k8sCaCreateReq.InitConfiguration != "" {
+			_ = writer.WriteField("initConfiguration", k8sCaCreateReq.InitConfiguration)
+		}
+		if k8sCaCreateReq.ClusterConfiguration != "" {
+			_ = writer.WriteField("clusterConfiguration", k8sCaCreateReq.ClusterConfiguration)
+		}
+		if k8sCaCreateReq.KubeletConfiguration != "" {
+			_ = writer.WriteField("kubeletConfiguration", k8sCaCreateReq.KubeletConfiguration)
+		}
+		if k8sCaCreateReq.KubeProxyConfiguration != "" {
+			_ = writer.WriteField("kubeProxyConfiguration", k8sCaCreateReq.KubeProxyConfiguration)
+		}
+		if k8sCaCreateReq.JoinConfiguration != "" {
+			_ = writer.WriteField("joinConfiguration", k8sCaCreateReq.JoinConfiguration)
+		}
+		if k8sCaCreateReq.Description != "" {
+			_ = writer.WriteField("desc", k8sCaCreateReq.Description)
+		}
+		if k8sCaCreateReq.UserData != "" {
+			_ = writer.WriteField("userData", k8sCaCreateReq.UserData)
+		}
+
+		_ = writer.WriteField("extnetOnly", strconv.FormatBool(k8sCaCreateReq.ExtNetOnly))
+		_ = writer.FormDataContentType()
+
+		ct := writer.FormDataContentType()
+
+		writer.Close()
+		req, err := http.NewRequestWithContext(ctx, method, dc.decortURL+"/restmachine"+url, reqBody)
+		if err != nil {
+			return nil, err
+		}
+		if err = dc.getToken(ctx); err != nil {
+			return nil, err
+		}
+
+		resp, err := dc.domp(req, ct)
+		if err != nil {
+			return nil, err
+		}
+		defer resp.Body.Close()
+
+		respBytes, err := io.ReadAll(resp.Body)
+		if err != nil {
+			return nil, err
+		}
+
+		if resp.StatusCode != 200 {
+			return nil, errors.New(string(respBytes))
+		}
+
+		return respBytes, nil
+	} else if okCb {
+		reqBody := &bytes.Buffer{}
+		writer := multipart.NewWriter(reqBody)
+		if k8sCbCreateReq.OidcCertificate != "" {
+			part, _ := writer.CreateFormFile("oidcCertificate", "ca.crt")
+			_, _ = io.Copy(part, strings.NewReader(k8sCbCreateReq.OidcCertificate))
+		}
+
+		_ = writer.WriteField("name", k8sCbCreateReq.Name)
+		_ = writer.WriteField("rgId", strconv.FormatUint(k8sCbCreateReq.RGID, 10))
+		_ = writer.WriteField("k8ciId", strconv.FormatUint(k8sCbCreateReq.K8CIID, 10))
+		_ = writer.WriteField("workerGroupName", k8sCbCreateReq.WorkerGroupName)
+		_ = writer.WriteField("networkPlugin", k8sCbCreateReq.NetworkPlugin)
+
+		if k8sCbCreateReq.MasterSEPID != 0 {
+			_ = writer.WriteField("masterSepId", strconv.FormatUint(k8sCbCreateReq.MasterSEPID, 10))
+		}
+		if k8sCbCreateReq.MasterSEPPool != "" {
+			_ = writer.WriteField("masterSepPool", k8sCbCreateReq.MasterSEPPool)
+		}
+		if k8sCbCreateReq.WorkerSEPID != 0 {
+			_ = writer.WriteField("workerSepId", strconv.FormatUint(k8sCbCreateReq.WorkerSEPID, 10))
+		}
+		if k8sCbCreateReq.WorkerSEPPool != "" {
+			_ = writer.WriteField("workerSepPool", k8sCbCreateReq.WorkerSEPPool)
+		}
+
+		if k8sCbCreateReq.Labels != nil {
+			for _, v := range k8sCbCreateReq.Labels {
+				_ = writer.WriteField("labels", v)
+			}
+		}
+		if k8sCbCreateReq.Taints != nil {
+			for _, v := range k8sCbCreateReq.Taints {
+				_ = writer.WriteField("taints", v)
+			}
+		}
+		if k8sCbCreateReq.Annotations != nil {
+			for _, v := range k8sCbCreateReq.Annotations {
+				_ = writer.WriteField("annotations", v)
+			}
+		}
+
+		if k8sCbCreateReq.MasterCPU != 0 {
+			_ = writer.WriteField("masterCpu", strconv.FormatUint(k8sCbCreateReq.MasterCPU, 10))
+		}
+		if k8sCbCreateReq.MasterNum != 0 {
+			_ = writer.WriteField("masterNum", strconv.FormatUint(k8sCbCreateReq.MasterNum, 10))
+		}
+		if k8sCbCreateReq.MasterRAM != 0 {
+			_ = writer.WriteField("masterRam", strconv.FormatUint(k8sCbCreateReq.MasterRAM, 10))
+		}
+		if k8sCbCreateReq.MasterDisk != 0 {
+			_ = writer.WriteField("masterDisk", strconv.FormatUint(k8sCbCreateReq.MasterDisk, 10))
+		}
+		if k8sCbCreateReq.WorkerCPU != 0 {
+			_ = writer.WriteField("workerCpu", strconv.FormatUint(k8sCbCreateReq.WorkerCPU, 10))
+		}
+		if k8sCbCreateReq.WorkerNum != 0 {
+			_ = writer.WriteField("workerNum", strconv.FormatUint(k8sCbCreateReq.WorkerNum, 10))
+		}
+		if k8sCbCreateReq.WorkerRAM != 0 {
+			_ = writer.WriteField("workerRam", strconv.FormatUint(k8sCbCreateReq.WorkerRAM, 10))
+		}
+		if k8sCbCreateReq.WorkerDisk != 0 {
+			_ = writer.WriteField("workerDisk", strconv.FormatUint(k8sCbCreateReq.WorkerDisk, 10))
+		}
+		if k8sCbCreateReq.ExtNetID != 0 {
+			_ = writer.WriteField("extnetId", strconv.FormatUint(k8sCbCreateReq.ExtNetID, 10))
+		}
+		if k8sCbCreateReq.VinsId != 0 {
+			_ = writer.WriteField("vinsId", strconv.FormatUint(k8sCbCreateReq.VinsId, 10))
+		}
+		if !k8sCbCreateReq.WithLB {
+			_ = writer.WriteField("withLB", strconv.FormatBool(k8sCbCreateReq.WithLB))
+		}
+
+		_ = writer.WriteField("highlyAvailable", strconv.FormatBool(k8sCbCreateReq.HighlyAvailable))
+
+		if k8sCbCreateReq.AdditionalSANs != nil {
+			for _, v := range k8sCbCreateReq.AdditionalSANs {
+				_ = writer.WriteField("additionalSANs", v)
+			}
+		}
+		if k8sCbCreateReq.InitConfiguration != "" {
+			_ = writer.WriteField("initConfiguration", k8sCbCreateReq.InitConfiguration)
+		}
+		if k8sCbCreateReq.ClusterConfiguration != "" {
+			_ = writer.WriteField("clusterConfiguration", k8sCbCreateReq.ClusterConfiguration)
+		}
+		if k8sCbCreateReq.KubeletConfiguration != "" {
+			_ = writer.WriteField("kubeletConfiguration", k8sCbCreateReq.KubeletConfiguration)
+		}
+		if k8sCbCreateReq.KubeProxyConfiguration != "" {
+			_ = writer.WriteField("kubeProxyConfiguration", k8sCbCreateReq.KubeProxyConfiguration)
+		}
+		if k8sCbCreateReq.JoinConfiguration != "" {
+			_ = writer.WriteField("joinConfiguration", k8sCbCreateReq.JoinConfiguration)
+		}
+		if k8sCbCreateReq.Description != "" {
+			_ = writer.WriteField("desc", k8sCbCreateReq.Description)
+		}
+		if k8sCbCreateReq.UserData != "" {
+			_ = writer.WriteField("userData", k8sCbCreateReq.UserData)
+		}
+
+		_ = writer.WriteField("extnetOnly", strconv.FormatBool(k8sCbCreateReq.ExtNetOnly))
+		_ = writer.FormDataContentType()
+
+		ct := writer.FormDataContentType()
+
+		writer.Close()
+		req, err := http.NewRequestWithContext(ctx, method, dc.decortURL+"/restmachine"+url, reqBody)
+		if err != nil {
+			return nil, err
+		}
+		if err = dc.getToken(ctx); err != nil {
+			return nil, err
+		}
+
+		resp, err := dc.domp(req, ct)
+		if err != nil {
+			return nil, err
+		}
+		defer resp.Body.Close()
+
+		respBytes, err := io.ReadAll(resp.Body)
+		if err != nil {
+			return nil, err
+		}
+
+		if resp.StatusCode != 200 {
+			return nil, errors.New(string(respBytes))
+		}
+
+		return respBytes, nil
+	}
+
 	values, err := query.Values(params)
 	if err != nil {
 		return nil, err
@@ -143,37 +423,48 @@ func (dc *DecortClient) do(req *http.Request) (*http.Response, error) {
 	// var resp *http.Response
 	// var err error
 	buf, _ := io.ReadAll(req.Body)
+	// req = req.Clone(req.Context())
 
 	// for i := uint64(0); i < dc.cfg.Retries; i++ {
-	// req = req.Clone(req.Context())
 	req.Body = io.NopCloser(bytes.NewBuffer(buf))
 	resp, err := dc.client.Do(req)
-	if err != nil || resp == nil {
+
-		if strings.Contains(err.Error(),"connection reset by peer") {
+	// if err == nil {
-			resp.Body.Close()
+	if resp.StatusCode == 200 {
-			for i := uint64(0); i < dc.cfg.Retries; i++ {
-				time.Sleep(5 *time.Second)
-				resp, err = dc.client.Do(req)
-				if strings.Contains(err.Error(),"connection reset by peer") {
-					resp.Body.Close()
-					continue
-				} else if err == nil {
-					break 
-				} else if err != nil {
-					return nil, err
-				}
-			}
-		}
 		return resp, err
 	}
-
-	if resp.StatusCode == 200 {
-		return resp, nil
-	}
-
 	respBytes, _ := io.ReadAll(resp.Body)
 	err = fmt.Errorf("%s", respBytes)
 	resp.Body.Close()
-	
+	// }
+	// }
+
+	return nil, fmt.Errorf("could not execute request: %w", err)
+}
+
+func (dc *DecortClient) domp(req *http.Request, ctype string) (*http.Response, error) {
+	req.Header.Add("Content-Type", ctype)
+	req.Header.Add("Authorization", "bearer "+dc.cfg.Token)
+	req.Header.Set("Accept", "application/json")
+
+	// var resp *http.Response
+	// var err error
+	buf, _ := io.ReadAll(req.Body)
+	// req = req.Clone(req.Context())
+
+	// for i := uint64(0); i < dc.cfg.Retries; i++ {
+	req.Body = io.NopCloser(bytes.NewBuffer(buf))
+	resp, err := dc.client.Do(req)
+
+	// if err == nil {
+	if resp.StatusCode == 200 {
+		return resp, err
+	}
+	respBytes, _ := io.ReadAll(resp.Body)
+	err = fmt.Errorf("%s", respBytes)
+	resp.Body.Close()
+	// }
+	// }
+
 	return nil, fmt.Errorf("could not execute request: %w", err)
 }

config/config.go

@@ -42,7 +42,7 @@ type Config struct {
 	// Required: false
 	Retries uint64 `json:"retries" yaml:"retries"`
 
-	// Skip verify, true by default
+	// Skip verify
 	// Required: false
 	SSLSkipVerify bool `json:"sslSkipVerify" yaml:"sslSkipVerify"`
 

config/legacy-config.go

@@ -36,7 +36,7 @@ type LegacyConfig struct {
 	// Required: false
 	Retries uint64 `json:"retries" yaml:"retries"`
 
-	// Skip verify, true by default
+	// Skip verify
 	// Required: false
 	SSLSkipVerify bool `json:"sslSkipVerify" yaml:"sslSkipVerify"`
 

config/timeouts.go

@@ -23,7 +23,7 @@ func (d *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error {
 		*d = Duration(tmp)
 		return nil
 	default:
-		return fmt.Errorf("Invalid duration %v", value)
+		return fmt.Errorf("invalid duration %v", value)
 	}
 }
 
@@ -41,7 +41,7 @@ func (d *Duration) UnmarshalJSON(b []byte) error {
 		*d = Duration(tmp)
 		return nil
 	default:
-		return fmt.Errorf("Invalid duration %v", value)
+		return fmt.Errorf("invalid duration %v", value)
 	}
 }
 

legacy-client.go

@@ -7,8 +7,10 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"mime/multipart"
 	"net/http"
 	"net/url"
+	"strconv"
 	"strings"
 	"sync"
 	"time"
@@ -16,6 +18,7 @@ import (
 	"github.com/google/go-querystring/query"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/config"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi"
+	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/k8s"
 	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker"
 )
 
@@ -68,6 +71,148 @@ func (ldc *LegacyDecortClient) CloudBroker() *cloudbroker.CloudBroker {
 
 // DecortApiCall method for sending requests to the platform
 func (ldc *LegacyDecortClient) DecortApiCall(ctx context.Context, method, url string, params interface{}) ([]byte, error) {
+	if k8sCreateReq, ok := params.(k8s.CreateRequest); ok {
+		reqBody := &bytes.Buffer{}
+		writer := multipart.NewWriter(reqBody)
+		if k8sCreateReq.OidcCertificate != "" {
+			part, _ := writer.CreateFormFile("oidcCertificate", "ca.crt")
+			_, _ = io.Copy(part, strings.NewReader(k8sCreateReq.OidcCertificate))
+		}
+
+		_ = writer.WriteField("name", k8sCreateReq.Name)
+		_ = writer.WriteField("rgId", strconv.FormatUint(k8sCreateReq.RGID, 10))
+		_ = writer.WriteField("k8ciId", strconv.FormatUint(k8sCreateReq.K8SCIID, 10))
+		_ = writer.WriteField("workerGroupName", k8sCreateReq.WorkerGroupName)
+		_ = writer.WriteField("networkPlugin", k8sCreateReq.NetworkPlugin)
+
+		if k8sCreateReq.MasterSEPID != 0 {
+			_ = writer.WriteField("masterSepId", strconv.FormatUint(k8sCreateReq.MasterSEPID, 10))
+		}
+		if k8sCreateReq.MasterSEPPool != "" {
+			_ = writer.WriteField("masterSepPool", k8sCreateReq.MasterSEPPool)
+		}
+		if k8sCreateReq.WorkerSEPID != 0 {
+			_ = writer.WriteField("workerSepId", strconv.FormatUint(k8sCreateReq.WorkerSEPID, 10))
+		}
+		if k8sCreateReq.WorkerSEPPool != "" {
+			_ = writer.WriteField("workerSepPool", k8sCreateReq.WorkerSEPPool)
+		}
+
+		if k8sCreateReq.Labels != nil {
+			for _, v := range k8sCreateReq.Labels {
+				_ = writer.WriteField("labels", v)
+			}
+		}
+		if k8sCreateReq.Taints != nil {
+			for _, v := range k8sCreateReq.Taints {
+				_ = writer.WriteField("taints", v)
+			}
+		}
+		if k8sCreateReq.Annotations != nil {
+			for _, v := range k8sCreateReq.Annotations {
+				_ = writer.WriteField("annotations", v)
+			}
+		}
+
+		if k8sCreateReq.MasterCPU != 0 {
+			_ = writer.WriteField("masterCpu", strconv.FormatUint(uint64(k8sCreateReq.MasterCPU), 10))
+		}
+		if k8sCreateReq.MasterNum != 0 {
+			_ = writer.WriteField("masterNum", strconv.FormatUint(uint64(k8sCreateReq.MasterNum), 10))
+		}
+		if k8sCreateReq.MasterRAM != 0 {
+			_ = writer.WriteField("masterRam", strconv.FormatUint(uint64(k8sCreateReq.MasterRAM), 10))
+		}
+		if k8sCreateReq.MasterDisk != 0 {
+			_ = writer.WriteField("masterDisk", strconv.FormatUint(uint64(k8sCreateReq.MasterDisk), 10))
+		}
+		if k8sCreateReq.WorkerCPU != 0 {
+			_ = writer.WriteField("workerCpu", strconv.FormatUint(uint64(k8sCreateReq.WorkerCPU), 10))
+		}
+		if k8sCreateReq.WorkerNum != 0 {
+			_ = writer.WriteField("workerNum", strconv.FormatUint(uint64(k8sCreateReq.WorkerNum), 10))
+		}
+		if k8sCreateReq.WorkerRAM != 0 {
+			_ = writer.WriteField("workerRam", strconv.FormatUint(uint64(k8sCreateReq.WorkerRAM), 10))
+		}
+		if k8sCreateReq.WorkerDisk != 0 {
+			_ = writer.WriteField("workerDisk", strconv.FormatUint(uint64(k8sCreateReq.WorkerDisk), 10))
+		}
+		if k8sCreateReq.ExtNetID != 0 {
+			_ = writer.WriteField("extnetId", strconv.FormatUint(k8sCreateReq.ExtNetID, 10))
+		}
+		if k8sCreateReq.VinsId != 0 {
+			_ = writer.WriteField("vinsId", strconv.FormatUint(k8sCreateReq.VinsId, 10))
+		}
+		if !k8sCreateReq.WithLB {
+			_ = writer.WriteField("withLB", strconv.FormatBool(k8sCreateReq.WithLB))
+		}
+
+		_ = writer.WriteField("highlyAvailable", strconv.FormatBool(k8sCreateReq.HighlyAvailable))
+
+		if k8sCreateReq.AdditionalSANs != nil {
+			for _, v := range k8sCreateReq.AdditionalSANs {
+				_ = writer.WriteField("additionalSANs", v)
+			}
+		}
+		if k8sCreateReq.InitConfiguration != "" {
+			_ = writer.WriteField("initConfiguration", k8sCreateReq.InitConfiguration)
+		}
+		if k8sCreateReq.ClusterConfiguration != "" {
+			_ = writer.WriteField("clusterConfiguration", k8sCreateReq.ClusterConfiguration)
+		}
+		if k8sCreateReq.KubeletConfiguration != "" {
+			_ = writer.WriteField("kubeletConfiguration", k8sCreateReq.KubeletConfiguration)
+		}
+		if k8sCreateReq.KubeProxyConfiguration != "" {
+			_ = writer.WriteField("kubeProxyConfiguration", k8sCreateReq.KubeProxyConfiguration)
+		}
+		if k8sCreateReq.JoinConfiguration != "" {
+			_ = writer.WriteField("joinConfiguration", k8sCreateReq.JoinConfiguration)
+		}
+		if k8sCreateReq.Description != "" {
+			_ = writer.WriteField("desc", k8sCreateReq.Description)
+		}
+		if k8sCreateReq.UserData != "" {
+			_ = writer.WriteField("userData", k8sCreateReq.UserData)
+		}
+
+		_ = writer.WriteField("extnetOnly", strconv.FormatBool(k8sCreateReq.ExtNetOnly))
+		_ = writer.FormDataContentType()
+
+		ct := writer.FormDataContentType()
+
+		if err := ldc.getToken(ctx); err != nil {
+			return nil, err
+		}
+
+		_ = writer.WriteField("authkey", ldc.cfg.Token)
+
+		writer.Close()
+
+		req, err := http.NewRequestWithContext(ctx, method, ldc.decortURL+"/restmachine"+url, reqBody)
+		if err != nil {
+			return nil, err
+		}
+
+		resp, err := ldc.domp(req, ct)
+		if err != nil {
+			return nil, err
+		}
+		defer resp.Body.Close()
+
+		respBytes, err := io.ReadAll(resp.Body)
+		if err != nil {
+			return nil, err
+		}
+
+		if resp.StatusCode != 200 {
+			return nil, errors.New(string(respBytes))
+		}
+
+		return respBytes, nil
+	}
+
 	values, err := query.Values(params)
 	if err != nil {
 		return nil, err
@@ -140,37 +285,49 @@ func (ldc *LegacyDecortClient) do(req *http.Request) (*http.Response, error) {
 	// var resp *http.Response
 	// var err error
 	buf, _ := io.ReadAll(req.Body)
+	// req = req.Clone(req.Context())
 
 	// for i := uint64(0); i < ldc.cfg.Retries; i++ {
-	// req = req.Clone(req.Context())
+
 	req.Body = io.NopCloser(bytes.NewBuffer(buf))
 	resp, err := ldc.client.Do(req)
-	if err != nil || resp == nil {
+
-		if strings.Contains(err.Error(),"connection reset by peer") {
+	// if err == nil {
-			resp.Body.Close()
+	if resp.StatusCode == 200 {
-			for i := uint64(0); i < ldc.cfg.Retries; i++ {
-				time.Sleep(5 *time.Second)
-				resp, err = ldc.client.Do(req)
-				if strings.Contains(err.Error(),"connection reset by peer") {
-					resp.Body.Close()
-					continue
-				} else if err == nil {
-					break 
-				} else if err != nil {
-					return nil, err
-				}
-			}
-		}
 		return resp, err
 	}
-
-	if resp.StatusCode == 200 {
-		return resp, nil
-	}
-
 	respBytes, _ := io.ReadAll(resp.Body)
 	err = fmt.Errorf("%s", respBytes)
 	resp.Body.Close()
-	
+	// 	}
+	// }
+
+	return nil, fmt.Errorf("could not execute request: %w", err)
+}
+
+func (ldc *LegacyDecortClient) domp(req *http.Request, ctype string) (*http.Response, error) {
+	req.Header.Add("Content-Type", ctype)
+	req.Header.Add("Authorization", "bearer "+ldc.cfg.Token)
+	req.Header.Set("Accept", "application/json")
+
+	// var resp *http.Response
+	// var err error
+	buf, _ := io.ReadAll(req.Body)
+	// req = req.Clone(req.Context())
+
+	// for i := uint64(0); i < ldc.cfg.Retries; i++ {
+	req.Body = io.NopCloser(bytes.NewBuffer(buf))
+	resp, err := ldc.client.Do(req)
+
+	// if err == nil {
+	if resp.StatusCode == 200 {
+		return resp, err
+	}
+	respBytes, _ := io.ReadAll(resp.Body)
+	err = fmt.Errorf("%s", respBytes)
+	resp.Body.Close()
+	// }
+	// }
+
 	return nil, fmt.Errorf("could not execute request: %w", err)
 }

pkg/cloudapi/bservice/group_add.go

@@ -68,6 +68,10 @@ type GroupAddRequest struct {
 	// Time of Compute Group readiness
 	// Required: false
 	TimeoutStart uint64 `url:"timeoutStart,omitempty" json:"timeoutStart,omitempty"`
+
+	// Meta data for working group computes, format YAML "user_data": 1111
+	// Required: false
+	UserData string `url:"userData,omitempty" json:"userData,omitempty"`
 }
 
 // GroupAdd creates new Compute Group within BasicService.

pkg/cloudapi/k8s/create.go

@@ -8,6 +8,8 @@ import (
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+// type Params []string
+
 // Request struct for create kubernetes cluster
 type CreateRequest struct {
 	// Name of Kubernetes cluster
@@ -98,18 +100,80 @@ type CreateRequest struct {
 	// Required: false
 	ExtNetID uint64 `url:"extnetId,omitempty" json:"extnetId,omitempty"`
 
+	// ID of the ViNS to connect k8s cluster. If nothing is specified, ViNS will be created automatically
+	// Required: false
+	VinsId uint64 `url:"vinsId,omitempty" json:"vinsId,omitempty"`
+
 	// Create Kubernetes cluster with masters nodes behind load balancer if true.
 	// Otherwise give all cluster nodes direct external addresses from selected ExtNet
 	// Required: false
 	WithLB bool `url:"withLB" json:"withLB"`
 
+	// Custom sysctl values for Load Balancer instance. Applied on boot
+	// Required: false
+	LbSysctlParams string `url:"lbSysctlParams,omitempty" json:"lbSysctlParams,omitempty"`
+
+	// Use Highly Available schema for LB deploy
+	// Required: false
+	HighlyAvailable bool `url:"highlyAvailable,omitempty" json:"highlyAvailable,omitempty"`
+
+	// Optional extra Subject Alternative Names (SANs) to use for the API Server serving certificate. Can be both IP addresses and DNS names
+	// Required: false
+	AdditionalSANs []string `url:"additionalSANs,omitempty" json:"additionalSANs,omitempty"`
+
+	// Is used to define settings and actions that should be performed before any other component in the cluster starts.
+	// It allows you to configure things like node registration, network setup, and other initialization tasks. insert a valid JSON string with all levels of nesting
+	// Required: false
+	InitConfiguration string `url:"initConfiguration,omitempty" json:"initConfiguration,omitempty"`
+
+	// Is used to define global settings and configurations for the entire cluster.
+	// It includes parameters such as cluster name, DNS settings, authentication methods, and other cluster-wide configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	ClusterConfiguration string `url:"clusterConfiguration,omitempty" json:"clusterConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings of the Kubelet, which is the primary node agent that runs on each node in the cluster.
+	// It includes parameters such as node IP address, resource allocation, pod eviction policies, and other Kubelet-specific configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	KubeletConfiguration string `url:"kubeletConfiguration,omitempty" json:"kubeletConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings of the Kube-proxy, which is responsible for network proxying and load balancing within the cluster.
+	// It includes parameters such as proxy mode, cluster IP ranges, and other Kube-proxy specific configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	KubeProxyConfiguration string `url:"kubeProxyConfiguration,omitempty" json:"kubeProxyConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings for joining a node to a cluster.
+	// It includes parameters such as the cluster's control plane endpoint, token, and certificate key. insert a valid JSON string with all levels of nesting
+	// Required: false
+	JoinConfiguration string `url:"joinConfiguration,omitempty" json:"joinConfiguration,omitempty"`
+
 	// Text description of this Kubernetes cluster
 	// Required: false
 	Description string `url:"desc,omitempty" json:"desc,omitempty"`
+
+	// Meta data for working group computes, format YAML "user_data": 1111
+	// Required: false
+	UserData string `url:"userData,omitempty" json:"userData,omitempty"`
+
+	// Use only selected ExtNet for infrastructure connections
+	// Required: false
+	ExtNetOnly bool `url:"extnetOnly,omitempty" json:"extnetOnly,omitempty"`
+
+	// Insert ssl certificate in x509 pem format
+	// Required: false
+	OidcCertificate string `url:"oidcCertificate,omitempty" json:"oidcCertificate,omitempty"`
 }
 
+// type wrapperCreateRequest struct {
+// 	CreateRequest
+// 	Params []string `url:"lbSysctlParams,omitempty"`
+// }
+
 // Create creates a new Kubernetes cluster in the specified Resource Group
 func (k8s K8S) Create(ctx context.Context, req CreateRequest) (string, error) {
+
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		for _, validationError := range validators.GetErrors(err) {
@@ -117,6 +181,28 @@ func (k8s K8S) Create(ctx context.Context, req CreateRequest) (string, error) {
 		}
 	}
 
+	// var params []string
+
+	// if len(req.LbSysctlParams) != 0 {
+	// 	params = make([]string, 0, len(req.LbSysctlParams))
+
+	// 	for r := range req.LbSysctlParams {
+	// 		b, err := json.Marshal(req.LbSysctlParams[r])
+	// 		if err != nil {
+	// 			return "", err
+	// 		}
+
+	// 		params = append(params, string(b))
+	// 	}
+	// } else {
+	// 	params = []string{"[]"}
+	// }
+
+	// reqWrapped := wrapperCreateRequest{
+	// 	CreateRequest: req,
+	// 	Params:        params,
+	// }
+
 	url := "/cloudapi/k8s/create"
 
 	res, err := k8s.client.DecortApiCall(ctx, http.MethodPost, url, req)

pkg/cloudapi/k8s/get_worker_nodes_meta_data.go

@@ -0,0 +1,38 @@
+package k8s
+
+import (
+	"context"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for get worker group metadata by ID
+type GetWorkerNodesMetaDataRequest struct {
+	// Kubernetes cluster ID
+	// Required: true
+	K8SID uint64 `url:"k8sId" json:"k8sId" validate:"required"`
+
+	// ID of the workers compute group
+	// Required: true
+	WorkersGroupID uint64 `url:"workersGroupId" json:"workersGroupId" validate:"required"`
+}
+
+// Get worker group metadata by ID
+func (k K8S) GetWorkerNodesMetaData(ctx context.Context, req GetWorkerNodesMetaDataRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return "", validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/k8s/getWorkerNodesMetaData"
+
+	res, err := k.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return "", err
+	}
+
+	return string(res), nil
+}

pkg/cloudapi/k8s/models.go

@@ -41,6 +41,9 @@ type ListK8SGroups []ItemK8SGroup
 
 // Detailed information
 type ItemDetailedInfo struct {
+	// Externalip
+	Externalip string `json:"externalip"`
+
 	// ID
 	ID uint64 `json:"id"`
 

pkg/cloudapi/k8s/update_worker_nodes_meta_data.go

@@ -0,0 +1,48 @@
+package k8s
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for add worker to a kubernetes cluster
+type UpdateWorkerNodesMetaDataRequest struct {
+	// Kubernetes cluster ID
+	// Required: true
+	K8SID uint64 `url:"k8sId" json:"k8sId" validate:"required"`
+
+	// ID of the workers compute group
+	// Required: true
+	WorkersGroupID uint64 `url:"workersGroupId" json:"workersGroupId" validate:"required"`
+
+	// Meta data for working group computes, format YAML "user_data": 1111
+	// Required: true
+	UserData string `url:"userData" json:"userData" validate:"required"`
+}
+
+// WorkerAdd adds worker nodes to a kubernetes cluster
+func (k K8S) UpdateWorkerNodesMetaData(ctx context.Context, req UpdateWorkerNodesMetaDataRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/k8s/updateWorkerNodesMetaData"
+
+	res, err := k.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/kvmppc/create.go

@@ -79,7 +79,7 @@ type CreateRequest struct {
 
 	// Start VM upon success
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
 
 	// System name
 	// Required: false

pkg/cloudapi/kvmx86/create.go

@@ -79,7 +79,7 @@ type CreateRequest struct {
 
 	// Start VM upon success
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
 
 	// System name
 	// Required: false

pkg/cloudapi/lb/create.go

@@ -2,12 +2,16 @@ package lb
 
 import (
 	"context"
+	"encoding/json"
+	"errors"
 	"net/http"
-	"strings"
+	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+type Params []string
+
 // Request struct for create load balancer
 type CreateRequest struct {
 	// ID of the resource group where this load balancer instance will be located
@@ -20,39 +24,81 @@ type CreateRequest struct {
 	Name string `url:"name" json:"name" validate:"required"`
 
 	// External network to connect this load balancer to
-	// Required: true
+	// Required: false
-	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+	ExtNetID uint64 `url:"extnetId" json:"extnetId"`
 
 	// Internal network (VINS) to connect this load balancer to
-	// Required: true
+	// Required: false
-	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+	VINSID uint64 `url:"vinsId" json:"vinsId"`
+
+	// Custom  sysctl values for Load Balancer instance. Applied on boot
+	// Required: false
+	SysctlParams Params `url:"-" json:"sysctlParams,omitempty" validate:"omitempty,dive"`
+
+	// Use Highly Available schema for LB deploy
+	// Required: false
+	HighlyAvailable bool `url:"highlyAvailable,omitempty" json:"highlyAvailable,omitempty"`
 
 	// Start now Load balancer
-	// Required: true
+	// Required: false
-	Start bool `url:"start" json:"start" validate:"required"`
+	Start bool `url:"start" json:"start"`
 
 	// Text description of this load balancer
 	// Required: false
 	Description string `url:"desc,omitempty" json:"desc,omitempty"`
 }
 
+type wrapperCreateRequest struct {
+	CreateRequest
+	Params []string `url:"sysctlParams,omitempty"`
+}
+
 // Create method will create a new load balancer instance
-func (l LB) Create(ctx context.Context, req CreateRequest) (string, error) {
+func (l LB) Create(ctx context.Context, req CreateRequest) (uint64, error) {
 	err := validators.ValidateRequest(req)
 	if err != nil {
 		for _, validationError := range validators.GetErrors(err) {
-			return "", validators.ValidationError(validationError)
+			return 0, validators.ValidationError(validationError)
 		}
 	}
 
+	if req.ExtNetID == 0 && req.VINSID == 0 {
+		return 0, errors.New("vinsId and extNetId cannot be both in the value 0")
+	}
+
+	var params []string
+
+	if len(req.SysctlParams) != 0 {
+		params = make([]string, 0, len(req.SysctlParams))
+
+		for r := range req.SysctlParams {
+			b, err := json.Marshal(req.SysctlParams[r])
+			if err != nil {
+				return 0, err
+			}
+
+			params = append(params, string(b))
+		}
+	} else {
+		params = []string{}
+	}
+
+	reqWrapped := wrapperCreateRequest{
+		CreateRequest: req,
+		Params:        params,
+	}
+
 	url := "/cloudapi/lb/create"
 
-	res, err := l.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := l.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
 	if err != nil {
-		return "", err
+		return 0, err
 	}
 
-	result := strings.ReplaceAll(string(res), "\"", "")
+	result, err := strconv.ParseUint(string(res), 10, 64)
+	if err != nil {
+		return 0, err
+	}
 
 	return result, nil
 }

pkg/cloudapi/lb/frontend_bind.go

@@ -20,18 +20,18 @@ type FrontendBindRequest struct {
 
 	// Name of the binding to update
 	// Required: true
-	BindingName string `url:"bindingName" json:"bindingName"`
+	BindingName string `url:"bindingName" json:"bindingName" validate:"required"`
 
 	// If specified must be within the IP range of either Ext Net or ViNS,
 	// where this load balancer is connected - new IP address to use for this binding.
 	// If omitted, current IP address is retained
-	// Required: false
+	// Required: true
-	BindingAddress string `url:"bindingAddress,omitempty" json:"bindingAddress,omitempty"`
+	BindingAddress string `url:"bindingAddress" json:"bindingAddress" validate:"required"`
 
 	// New port number to use for this binding.
 	// If omitted, current port number is retained
-	// Required: false
+	// Required: true
-	BindingPort uint64 `url:"bindingPort,omitempty" json:"bindingPort,omitempty"`
+	BindingPort uint64 `url:"bindingPort" json:"bindingPort" validate:"required"`
 }
 
 // FrontendBind bind frontend from specified load balancer instance

pkg/cloudapi/lb/frontend_bind_update.go

@@ -25,13 +25,13 @@ type FrontendBindUpdateRequest struct {
 	// If specified must be within the IP range of either Ext Net or ViNS,
 	// where this load balancer is connected - new IP address to use for this binding.
 	// If omitted, current IP address is retained
-	// Required: false
+	// Required: true
-	BindingAddress string `url:"bindingAddress,omitempty" json:"bindingAddress,omitempty"`
+	BindingAddress string `url:"bindingAddress" json:"bindingAddress" validate:"required"`
 
 	// New port number to use for this binding.
 	// If omitted, current port number is retained
-	// Required: false
+	// Required: true
-	BindingPort uint64 `url:"bindingPort,omitempty" json:"bindingPort,omitempty"`
+	BindingPort uint64 `url:"bindingPort" json:"bindingPort" validate:"required"`
 }
 
 // FrontendBindUpdate updates binding for the specified load balancer frontend

pkg/cloudapi/lb/make_highly_available.go

@@ -0,0 +1,40 @@
+package lb
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for make Load Balancer Highly available
+type HighlyAvailableRequest struct {
+	// ID of the LB instance
+	// Required: true
+	LBID uint64 `url:"lbId" json:"lbId" validate:"required"`
+}
+
+// Make Load Balancer Highly available
+func (l LB) HighlyAvailable(ctx context.Context, req HighlyAvailableRequest) (uint64, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return 0, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/lb/makeHighlyAvailable"
+
+	res, err := l.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return 0, err
+	}
+
+	result, err := strconv.ParseUint(string(res), 10, 64)
+	if err != nil {
+		return 0, err
+	}
+
+	return result, nil
+}

pkg/cloudapi/lb/models.go

@@ -6,7 +6,10 @@ type RecordLB struct {
 	HAMode bool `json:"HAmode"`
 
 	// Access Control List
-	ACL interface{} `json:"acl"`
+	ACL []interface{} `json:"acl"`
+
+	// BackendHAIP
+	BackendHAIP string `json:"backendHAIP"`
 
 	// List of load balancer backends
 	Backends ListBackends `json:"backends"`
@@ -32,6 +35,9 @@ type RecordLB struct {
 	// External network ID
 	ExtNetID uint64 `json:"extnetId"`
 
+	// FrontendHAIP
+	FrontendHAIP string `json:"frontendHAIP"`
+
 	// List of load balancer frontends
 	Frontends ListFrontends `json:"frontends"`
 
@@ -53,6 +59,9 @@ type RecordLB struct {
 	// Name
 	Name string `json:"name"`
 
+	// Part K8s
+	PartK8s bool `json:"partK8s"`
+
 	// Primary node
 	PrimaryNode RecordNode `json:"primaryNode"`
 
@@ -68,6 +77,9 @@ type RecordLB struct {
 	// Status
 	Status string `json:"status"`
 
+	// Sysctl Params
+	SysctlParams []interface{} `json:"sysctlParams"`
+
 	// Tech status
 	TechStatus string `json:"techStatus"`
 

pkg/cloudapi/lb/updateSysctParams.go

@@ -0,0 +1,72 @@
+package lb
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for update sysct params for lb
+type UpdateSysctParamsRequest struct {
+	// ID of the LB instance
+	// Required: true
+	LBID uint64 `url:"lbId" json:"lbId" validate:"required"`
+
+	// Custom sysctl values for Load Balancer instance. Applied on boot
+	// Required: true
+	SysctlParams Params `url:"-" json:"sysctlParams" validate:"required,dive"`
+}
+
+type wrapperUpdateSysctParamsRequest struct {
+	UpdateSysctParamsRequest
+	Params []string `url:"sysctlParams" validate:"required"`
+}
+
+// Create method will create a new load balancer instance
+func (l LB) UpdateSysctParams(ctx context.Context, req UpdateSysctParamsRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	var params []string
+
+	if len(req.SysctlParams) != 0 {
+		params = make([]string, 0, len(req.SysctlParams))
+
+		for r := range req.SysctlParams {
+			b, err := json.Marshal(req.SysctlParams[r])
+			if err != nil {
+				return false, err
+			}
+
+			params = append(params, string(b))
+		}
+	} else {
+		params = []string{}
+	}
+
+	reqWrapped := wrapperUpdateSysctParamsRequest{
+		UpdateSysctParamsRequest: req,
+		Params:                   params,
+	}
+
+	url := "/cloudapi/lb/updateSysctParams"
+
+	res, err := l.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudapi/stack.go

@@ -0,0 +1,10 @@
+package cloudapi
+
+import (
+	"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudapi/stack"
+)
+
+// Accessing the Stack method group
+func (ca *CloudAPI) Stack() *stack.Stack {
+	return stack.New(ca.client)
+}

pkg/cloudapi/stack/get.go

@@ -0,0 +1,42 @@
+package stack
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for get info of stack
+type GetRequest struct {
+	// Find by ID
+	// Required: true
+	StackId uint64 `url:"stackId" json:"stackId" validate:"required"`
+}
+
+// Get stack details by ID
+func (i Stack) Get(ctx context.Context, req GetRequest) (*InfoStack, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return nil, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/stack/get"
+
+	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	info := InfoStack{}
+
+	err = json.Unmarshal(res, &info)
+	if err != nil {
+		return nil, err
+	}
+
+	return &info, nil
+}

pkg/cloudapi/stack/list.go

@@ -0,0 +1,53 @@
+package stack
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+)
+
+// Request struct for get list stack
+type ListRequest struct {
+	// Find by ID
+	// Required: false
+	ByID uint64 `url:"by_id,omitempty" json:"by_id,omitempty"`
+
+	// Find by name
+	// Required: false
+	Name string `url:"name,omitempty" json:"name,omitempty"`
+
+	// Find by type
+	// Required: false
+	Type string `url:"type,omitempty" json:"type,omitempty"`
+
+	// Find by status
+	// Required: false
+	Status string `url:"status,omitempty" json:"status,omitempty"`
+
+	// Page number
+	// Required: false
+	Page uint64 `url:"page,omitempty" json:"page,omitempty"`
+
+	// Page size
+	// Required: false
+	Size uint64 `url:"size,omitempty" json:"size,omitempty"`
+}
+
+// ListStacks gets list stack
+func (i Stack) List(ctx context.Context, req ListRequest) (*ListStacks, error) {
+	url := "/cloudapi/stack/list"
+
+	res, err := i.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	list := ListStacks{}
+
+	err = json.Unmarshal(res, &list)
+	if err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}

pkg/cloudapi/stack/models.go

@@ -0,0 +1,53 @@
+package stack
+
+// Main information about stack
+type InfoStack struct {
+	// CPU allocation ratio
+	CPUAllocationRatio float64 `json:"cpu_allocation_ratio"`
+
+	// Descr
+	Descr string `json:"descr"`
+
+	// Drivers
+	Drivers []string `json:"drivers"`
+
+	// ID
+	ID uint64 `json:"id"`
+
+	// Mem allocation ratio
+	MemAllocationRatio float64 `json:"mem_allocation_ratio"`
+
+	// Name
+	Name string `json:"name"`
+
+	// Status
+	Status string `json:"status"`
+
+	// Type
+	Type string `json:"type"`
+}
+
+// Information about stack in list
+type ItemStack struct {
+	// ID
+	ID uint64 `json:"id"`
+
+	// Name
+	Name string `json:"name"`
+
+	// Status
+	Status string `json:"status"`
+
+	// Type
+	Type string `json:"type"`
+}
+
+// List of stacks
+type ListStacks struct {
+
+	//List
+	Data []ItemStack `json:"data"`
+
+	//Entry count
+	EntryCount uint64 `json:"entryCount"`
+}

pkg/cloudapi/stack/stack.go

@@ -0,0 +1,16 @@
+// Lists all the stack.
+package stack
+
+import "repository.basistech.ru/BASIS/decort-golang-sdk/interfaces"
+
+// Structure for creating request to stack
+type Stack struct {
+	client interfaces.Caller
+}
+
+// Builder for stack endpoint
+func New(client interfaces.Caller) *Stack {
+	return &Stack{
+		client: client,
+	}
+}

pkg/cloudapi/vins/create_in_account.go

@@ -2,12 +2,24 @@ package vins
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
 	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+type Route struct {
+	// Destination network
+	Destination string `url:"destination" json:"destination" validate:"required"`
+
+	//Destination network mask in 255.255.255.255 format
+	Netmask string `url:"netmask" json:"netmask" validate:"required"`
+
+	//Next hop host, IP address from ViNS ID free IP pool
+	Gateway string `url:"gateway" json:"gateway" validate:"required"`
+}
+
 // Request struct for create VINS in account
 type CreateInAccountRequest struct {
 	// VINS name
@@ -33,6 +45,15 @@ type CreateInAccountRequest struct {
 	// Number of pre created reservations
 	// Required: false
 	PreReservationsNum uint64 `url:"preReservationsNum,omitempty" json:"preReservationsNum,omitempty"`
+
+	// List of static routes, each item must have destination, netmask, and gateway fields
+	// Required: false
+	Routes []Route `url:"-" json:"routes,omitempty" validate:"omitempty,dive"`
+}
+
+type wrapperCreateRequestInAcc struct {
+	CreateInAccountRequest
+	Routes []string `url:"routes,omitempty"`
 }
 
 // CreateInAccount creates VINS in account level
@@ -44,9 +65,31 @@ func (v VINS) CreateInAccount(ctx context.Context, req CreateInAccountRequest) (
 		}
 	}
 
+	var routes []string
+
+	if len(req.Routes) != 0 {
+		routes = make([]string, 0, len(req.Routes))
+
+		for r := range req.Routes {
+			b, err := json.Marshal(req.Routes[r])
+			if err != nil {
+				return 0, err
+			}
+
+			routes = append(routes, string(b))
+		}
+	} else {
+		routes = []string{}
+	}
+
+	reqWrapped := wrapperCreateRequestInAcc{
+		CreateInAccountRequest: req,
+		Routes:                 routes,
+	}
+
 	url := "/cloudapi/vins/createInAccount"
 
-	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
 	if err != nil {
 		return 0, err
 	}

pkg/cloudapi/vins/create_in_rg.go

@@ -2,6 +2,7 @@ package vins
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
 	"strconv"
 
@@ -37,6 +38,15 @@ type CreateInRGRequest struct {
 	// Number of pre created reservations
 	// Required: false
 	PreReservationsNum uint64 `url:"preReservationsNum,omitempty" json:"preReservationsNum,omitempty"`
+
+	// List of static routes, each item must have destination, netmask, and gateway fields
+	// Required: false
+	Routes []Route `url:"-" json:"routes,omitempty" validate:"omitempty,dive"`
+}
+
+type wrapperCreateRequestInRG struct {
+	CreateInRGRequest
+	Routes []string `url:"routes,omitempty"`
 }
 
 // CreateInRG creates VINS in resource group level
@@ -48,9 +58,31 @@ func (v VINS) CreateInRG(ctx context.Context, req CreateInRGRequest) (uint64, er
 		}
 	}
 
+	var routes []string
+
+	if len(req.Routes) != 0 {
+		routes = make([]string, 0, len(req.Routes))
+
+		for r := range req.Routes {
+			b, err := json.Marshal(req.Routes[r])
+			if err != nil {
+				return 0, err
+			}
+
+			routes = append(routes, string(b))
+		}
+	} else {
+		routes = []string{}
+	}
+
+	reqWrapped := wrapperCreateRequestInRG{
+		CreateInRGRequest: req,
+		Routes:            routes,
+	}
+
 	url := "/cloudapi/vins/createInRG"
 
-	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
 	if err != nil {
 		return 0, err
 	}

pkg/cloudapi/vins/models.go

@@ -252,6 +252,9 @@ type ItemVNFInterface struct {
 	// Default GW
 	DefGW string `json:"defGw"`
 
+	// Enabled
+	Enabled bool `json:"enabled"`
+
 	// FLIPGroup ID
 	FLIPGroupID uint64 `json:"flipgroupId"`
 
@@ -378,6 +381,9 @@ type RecordNAT struct {
 	// Pure virtual
 	PureVirtual bool `json:"pureVirtual"`
 
+	// Routes
+	Routes ListRoutes `json:"routes"`
+
 	// Status
 	Status string `json:"status"`
 
@@ -443,6 +449,9 @@ type RecordGW struct {
 	// Pure virtual
 	PureVirtual bool `json:"pureVirtual"`
 
+	// Routes
+	Routes ListRoutes `json:"routes"`
+
 	// Status
 	Status string `json:"status"`
 
@@ -530,6 +539,9 @@ type RecordDHCP struct {
 	// Pure virtual
 	PureVirtual bool `json:"pureVirtual"`
 
+	// Routes
+	Routes ListRoutes `json:"routes"`
+
 	// Status
 	Status string `json:"status"`
 
@@ -567,6 +579,39 @@ type RecordDHCPConfig struct {
 	Reservations ListReservations `json:"reservations"`
 }
 
+// List of static routes
+type ListStaticRoutes struct {
+	// Data
+	Data []ItemRoutes `json:"data"`
+
+	// Entry count
+	EntryCount uint64 `json:"entryCount"`
+}
+
+// List of Routes
+type ListRoutes []ItemRoutes
+
+// Detailed information about Routes
+type ItemRoutes struct {
+	//Compute Id
+	ComputeIds []uint64 `json:"computeIds"`
+
+	// Destination network
+	Destination string `json:"destination"`
+
+	//Next hop host, IP address from ViNS ID free IP pool
+	Gateway string `json:"gateway"`
+
+	// GUID
+	GUID string `json:"guid"`
+
+	// ID
+	ID uint64 `json:"id"`
+
+	//Destination network mask in 255.255.255.255 format
+	Netmask string `json:"netmask"`
+}
+
 // Detailed information about VINS
 type RecordVINS struct {
 	// Main information about VNF device

pkg/cloudapi/vins/static_route_access_grant.go

@@ -0,0 +1,48 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for grant access to static route to Compute/ViNS
+type StaticRouteAccessGrantRequest struct {
+	// ViNS ID to grant access
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to grant access, can be found in staticRouteList
+	// Required: true
+	RouteId  uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to grant access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Grant access to static route to Compute/ViNS
+func (v VINS) StaticRouteAccessGrant(ctx context.Context, req StaticRouteAccessGrantRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/vins/staticRouteAccessGrant"
+
+	res, err := v.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/vins/static_route_access_revoke.go

@@ -0,0 +1,48 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for revoke access to static route to Compute/ViNS
+type StaticRouteAccessRevokeRequest struct {
+	// ViNS ID to revoke access
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to revoke access, can be found in staticRouteList
+	// Required: true
+	RouteId  uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to revoke access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Revoke access to static route to Compute/ViNS
+func (v VINS) StaticRouteAccessRevoke(ctx context.Context, req StaticRouteAccessRevokeRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/vins/staticRouteAccessRevoke"
+
+	res, err := v.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/vins/static_route_add.go

@@ -0,0 +1,56 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for add static route
+type StaticRouteAddRequest struct {
+	// VINS ID
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Destination network
+	// Required: true
+	Destination string `url:"destination" json:"destination" validate:"required"`
+
+	// Destination network mask in 255.255.255.255 format
+	// Required: true
+	Netmask string `url:"netmask" json:"netmask" validate:"required"`
+
+	// Next hop host, IP address from ViNS ID free IP pool
+	// Required: true
+	Gateway string `url:"gateway" json:"gateway" validate:"required"`
+
+	// List of Compute IDs which have access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// StaticRouteAdd add new static route to ViNS 
+func (v VINS) StaticRouteAdd(ctx context.Context, req StaticRouteAddRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/vins/staticRouteAdd"
+
+	res, err := v.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/vins/static_route_del.go

@@ -0,0 +1,44 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for remove static route from ViNS
+type StaticRouteDelRequest struct {
+	// ViNS ID to remove static route from
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to remove, can be found in staticRouteList
+	// Required: true
+	RouteId  uint64 `url:"routeId" json:"routeId" validate:"required"`
+}
+
+// Remove static route from ViNS
+func (v VINS) StaticRouteDel(ctx context.Context, req StaticRouteDelRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/vins/staticRouteDel"
+
+	res, err := v.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/vins/static_route_list.go

@@ -0,0 +1,42 @@
+package vins
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for static route list
+type StaticRouteListRequest struct {
+	// ViNS ID to show list of static routes
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+}
+
+// Show list of static routes for ViNS
+func (v VINS) StaticRouteList(ctx context.Context, req StaticRouteListRequest) (*ListStaticRoutes, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return nil, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudapi/vins/staticRouteList"
+
+	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	list := ListStaticRoutes{}
+
+	err = json.Unmarshal(res, &list)
+	if err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}

pkg/cloudbroker/compute/set_custom_fields.go

@@ -0,0 +1,43 @@
+package compute
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+// Request struct for setting customFields values for the Compute
+type SetCustomFieldsRequest struct {
+	// ID of the compute
+	// Required: true
+	ComputeID uint64 `url:"computeId" json:"computeId" validate:"required"`
+
+	// Custom fields for Compute. Must be dict.
+	// Required: true
+	CustomFields string `url:"customFields" json:"customFields" validate:"required"`
+}
+
+// SetCustomFields sets customFields values for the Compute
+func (c Compute) SetCustomFields(ctx context.Context, req SetCustomFieldsRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/compute/setCustomFields"
+
+	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/extnet/create.go

@@ -2,12 +2,24 @@ package extnet
 
 import (
 	"context"
+	"encoding/json"
 	"net/http"
 	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+type Route struct {
+	// Destination network
+	Destination string `url:"destination" json:"destination" validate:"required"`
+
+	//Destination network mask in 255.255.255.255 format
+	Netmask string `url:"netmask" json:"netmask" validate:"required"`
+
+	//Next hop host, IP address from ViNS ID free IP pool
+	Gateway string `url:"gateway" json:"gateway" validate:"required"`
+}
+
 // Request struct for create external network
 type CreateRequest struct {
 	// External network name
@@ -70,6 +82,15 @@ type CreateRequest struct {
 	// OpenvSwith bridge name for ExtNet connection
 	// Required: false
 	OVSBridge string `url:"ovsBridge,omitempty" json:"ovsBridge,omitempty"`
+
+	// List of static routes, each item must have destination, netmask, and gateway fields
+	// Required: false
+	Routes []Route `url:"-" json:"routes,omitempty" validate:"omitempty,dive"`
+}
+
+type wrapperCreateRequest struct {
+	CreateRequest
+	Routes []string `url:"routes,omitempty"`
 }
 
 // Create creates new external network into platform
@@ -81,9 +102,31 @@ func (e ExtNet) Create(ctx context.Context, req CreateRequest) (uint64, error) {
 		}
 	}
 
+	var routes []string
+
+	if len(req.Routes) != 0 {
+		routes = make([]string, 0, len(req.Routes))
+
+		for r := range req.Routes {
+			b, err := json.Marshal(req.Routes[r])
+			if err != nil {
+				return 0, err
+			}
+
+			routes = append(routes, string(b))
+		}
+	} else {
+		routes = []string{}
+	}
+
+	reqWrapped := wrapperCreateRequest{
+		CreateRequest: req,
+		Routes:        routes,
+	}
+
 	url := "/cloudbroker/extnet/create"
 
-	res, err := e.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := e.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
 	if err != nil {
 		return 0, err
 	}

pkg/cloudbroker/extnet/models.go

@@ -151,3 +151,33 @@ type RecordExtNet struct {
 	// List reservations
 	Reservations ListReservations `json:"reservations"`
 }
+
+// List of static routes
+type ListStaticRoutes struct {
+	// Data
+	Data []ItemRoutes `json:"data"`
+
+	// Entry count
+	EntryCount uint64 `json:"entryCount"`
+}
+
+// Detailed information about Routes
+type ItemRoutes struct {
+	//Compute Id
+	ComputeIds []uint64 `json:"computeIds"`
+
+	// Destination network
+	Destination string `json:"destination"`
+
+	//Next hop host, IP address from ViNS ID free IP pool
+	Gateway string `json:"gateway"`
+
+	// GUID
+	GUID string `json:"guid"`
+
+	// ID
+	ID uint64 `json:"id"`
+
+	//Destination network mask in 255.255.255.255 format
+	Netmask string `json:"netmask"`
+}

pkg/cloudbroker/extnet/static_route_access_grant.go

@@ -0,0 +1,48 @@
+package extnet
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for grant access to static route to Compute/ViNS
+type StaticRouteAccessGrantRequest struct {
+	// ExtNet ID to grant access
+	// Required: true
+	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+
+	// Route ID to grant access, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to grant access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Grant access to static route to Compute/ViNS
+func (v ExtNet) StaticRouteAccessGrant(ctx context.Context, req StaticRouteAccessGrantRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/extnet/staticRouteAccessGrant"
+
+	res, err := v.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/extnet/static_route_access_revoke.go

@@ -0,0 +1,48 @@
+package extnet
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for revoke access to static route to Compute/ViNS
+type StaticRouteAccessRevokeRequest struct {
+	// ExtNet ID to revoke access
+	// Required: true
+	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+
+	// Route ID to revoke access, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to revoke access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Revoke access to static route to Compute/ViNS
+func (v ExtNet) StaticRouteAccessRevoke(ctx context.Context, req StaticRouteAccessRevokeRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/extnet/staticRouteAccessRevoke"
+
+	res, err := v.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/extnet/static_route_add.go

@@ -0,0 +1,56 @@
+package extnet
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for add static route
+type StaticRouteAddRequest struct {
+	// ExtNet ID to add static route
+	// Required: true
+	ExtNetId  uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+
+	// Destination network
+	// Required: true
+	Destination string `url:"destination" json:"destination" validate:"required"`
+
+	// Destination network mask in 255.255.255.255 format
+	// Required: true
+	Netmask string `url:"netmask" json:"netmask" validate:"required"`
+
+	// Next hop host, IP address from ViNS ID free IP pool
+	// Required: true
+	Gateway string `url:"gateway" json:"gateway" validate:"required"`
+
+	// List of Compute IDs which have access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// StaticRouteAdd add new static route to ViNS
+func (v ExtNet) StaticRouteAdd(ctx context.Context, req StaticRouteAddRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/extnet/staticRouteAdd"
+
+	res, err := v.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/extnet/static_route_del.go

@@ -0,0 +1,44 @@
+package extnet
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for remove static route from ViNS
+type StaticRouteDelRequest struct {
+	// ExtNet ID to remove static route from
+	// Required: true
+	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+
+	// Route ID to remove, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+}
+
+// Remove static route from ViNS
+func (v ExtNet) StaticRouteDel(ctx context.Context, req StaticRouteDelRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/extnet/staticRouteDel"
+
+	res, err := v.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/extnet/static_route_list.go

@@ -0,0 +1,42 @@
+package extnet
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for static route list
+type StaticRouteListRequest struct {
+	// ExtNet ID to show list of static routes
+	// Required: true
+	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+}
+
+// Show list of static routes for ViNS
+func (v ExtNet) StaticRouteList(ctx context.Context, req StaticRouteListRequest) (*ListStaticRoutes, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return nil, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/extnet/staticRouteList"
+
+	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	list := ListStaticRoutes{}
+
+	err = json.Unmarshal(res, &list)
+	if err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}

pkg/cloudbroker/k8s/create.go

@@ -8,6 +8,8 @@ import (
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+// type Params []string
+
 // Request struct for create K8S
 type CreateRequest struct {
 	// Name of kubernetes cluster
@@ -24,7 +26,7 @@ type CreateRequest struct {
 
 	// Name for first worker group created with cluster
 	// Required: true
-	WorkerGroupName string `url:"workerGroupName" json:"workerGroupName" validate:"required, workerGroupName"`
+	WorkerGroupName string `url:"workerGroupName" json:"workerGroupName" validate:"required,workerGroupName"`
 
 	// Network plugin
 	// Must be one of these values: flunnel, weawenet, calico
@@ -100,16 +102,77 @@ type CreateRequest struct {
 	// Required: false
 	ExtNetID uint64 `url:"extnetId,omitempty" json:"extnetId,omitempty"`
 
+	// ID of the ViNS to connect k8s cluster. If nothing is specified, ViNS will be created automatically
+	// Required: false
+	VinsId uint64 `url:"vinsId,omitempty" json:"vinsId,omitempty"`
+
 	// Create kubernetes cluster with masters nodes behind load balancer if true.
 	// Otherwise give all cluster nodes direct external addresses from selected external network
 	// Required: false
 	WithLB bool `url:"withLB" json:"withLB"`
 
+	// Custom sysctl values for Load Balancer instance. Applied on boot
+	// Required: false
+	LbSysctlParams string `url:"lbSysctlParams,omitempty" json:"lbSysctlParams,omitempty"`
+
+	// Use Highly Available schema for LB deploy
+	// Required: false
+	HighlyAvailable bool `url:"highlyAvailable,omitempty" json:"highlyAvailable,omitempty"`
+
+	// Optional extra Subject Alternative Names (SANs) to use for the API Server serving certificate. Can be both IP addresses and DNS names
+	// Required: false
+	AdditionalSANs []string `url:"additionalSANs,omitempty" json:"additionalSANs,omitempty"`
+
+	// Is used to define settings and actions that should be performed before any other component in the cluster starts.
+	// It allows you to configure things like node registration, network setup, and other initialization tasks. insert a valid JSON string with all levels of nesting
+	// Required: false
+	InitConfiguration string `url:"initConfiguration,omitempty" json:"initConfiguration,omitempty"`
+
+	// Is used to define global settings and configurations for the entire cluster.
+	// It includes parameters such as cluster name, DNS settings, authentication methods, and other cluster-wide configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	ClusterConfiguration string `url:"clusterConfiguration,omitempty" json:"clusterConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings of the Kubelet, which is the primary node agent that runs on each node in the cluster.
+	// It includes parameters such as node IP address, resource allocation, pod eviction policies, and other Kubelet-specific configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	KubeletConfiguration string `url:"kubeletConfiguration,omitempty" json:"kubeletConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings of the Kube-proxy, which is responsible for network proxying and load balancing within the cluster.
+	// It includes parameters such as proxy mode, cluster IP ranges, and other Kube-proxy specific configurations.
+	// Insert a valid JSON string with all levels of nesting
+	// Required: false
+	KubeProxyConfiguration string `url:"kubeProxyConfiguration,omitempty" json:"kubeProxyConfiguration,omitempty"`
+
+	// Is used to configure the behavior and settings for joining a node to a cluster.
+	// It includes parameters such as the cluster's control plane endpoint, token, and certificate key. insert a valid JSON string with all levels of nesting
+	// Required: false
+	JoinConfiguration string `url:"joinConfiguration,omitempty" json:"joinConfiguration,omitempty"`
+
 	// Text description of this kubernetes cluster
 	// Required: false
 	Description string `url:"desc,omitempty" json:"desc,omitempty"`
+
+	// Meta data for working group computes, format YAML "user_data": 1111
+	// Required: false
+	UserData string `url:"userData,omitempty" json:"userData,omitempty"`
+
+	// Use only selected ExtNet for infrastructure connections
+	// Required: false
+	ExtNetOnly bool `url:"extnetOnly,omitempty" json:"extnetOnly,omitempty"`
+
+	// Insert ssl certificate in x509 pem format
+	// Required: false
+	OidcCertificate string `url:"oidcCertificate,omitempty" json:"oidcCertificate,omitempty"`
 }
 
+// type wrapperCreateRequest struct {
+// 	CreateRequest
+// 	Params []string `url:"lbSysctlParams,omitempty"`
+// }
+
 // Create creates a new kubernetes cluster in the specified resource group
 func (k K8S) Create(ctx context.Context, req CreateRequest) (string, error) {
 	err := validators.ValidateRequest(req)
@@ -119,6 +182,28 @@ func (k K8S) Create(ctx context.Context, req CreateRequest) (string, error) {
 		}
 	}
 
+	// var params []string
+
+	// if len(req.LbSysctlParams) != 0 {
+	// 	params = make([]string, 0, len(req.LbSysctlParams))
+
+	// 	for r := range req.LbSysctlParams {
+	// 		b, err := json.Marshal(req.LbSysctlParams[r])
+	// 		if err != nil {
+	// 			return "", err
+	// 		}
+
+	// 		params = append(params, string(b))
+	// 	}
+	// } else {
+	// 	params = []string{}
+	// }
+
+	// reqWrapped := wrapperCreateRequest{
+	// 	CreateRequest: req,
+	// 	Params:        params,
+	// }
+
 	url := "/cloudbroker/k8s/create"
 
 	res, err := k.client.DecortApiCall(ctx, http.MethodPost, url, req)

pkg/cloudbroker/k8s/get_worker_nodes_meta_data.go

@@ -0,0 +1,38 @@
+package k8s
+
+import (
+	"context"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for get worker group metadata by ID
+type GetWorkerNodesMetaDataRequest struct {
+	// Kubernetes cluster ID
+	// Required: true
+	K8SID uint64 `url:"k8sId" json:"k8sId" validate:"required"`
+
+	// ID of the workers compute group
+	// Required: true
+	WorkersGroupID uint64 `url:"workersGroupId" json:"workersGroupId" validate:"required"`
+}
+
+// Get worker group metadata by ID
+func (k K8S) GetWorkerNodesMetaData(ctx context.Context, req GetWorkerNodesMetaDataRequest) (string, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return "", validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/k8s/getWorkerNodesMetaData"
+
+	res, err := k.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return "", err
+	}
+
+	return string(res), nil
+}

pkg/cloudbroker/k8s/models.go

@@ -2,6 +2,9 @@ package k8s
 
 // Deteiled information
 type ItemDetailedInfo struct {
+	// External Ip
+	ExternalIp string `json:"externalip"`
+
 	// ID
 	ID uint64 `json:"id"`
 
@@ -11,7 +14,7 @@ type ItemDetailedInfo struct {
 	// Status
 	Status string `json:"status"`
 
-	// Status
+	// Tech status
 	TechStatus string `json:"techStatus"`
 }
 

pkg/cloudbroker/k8s/update_worker_nodes_meta_data.go

@@ -0,0 +1,48 @@
+package k8s
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for add worker to a kubernetes cluster
+type UpdateWorkerNodesMetaDataRequest struct {
+	// Kubernetes cluster ID
+	// Required: true
+	K8SID uint64 `url:"k8sId" json:"k8sId" validate:"required"`
+
+	// ID of the workers compute group
+	// Required: true
+	WorkersGroupID uint64 `url:"workersGroupId" json:"workersGroupId" validate:"required"`
+
+	// Meta data for working group computes, format YAML "user_data": 1111
+	// Required: true
+	UserData string `url:"userData" json:"userData" validate:"required"`
+}
+
+// WorkerAdd adds worker nodes to a kubernetes cluster
+func (k K8S) UpdateWorkerNodesMetaData(ctx context.Context, req UpdateWorkerNodesMetaDataRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/k8s/updateWorkerNodesMetaData"
+
+	res, err := k.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/kvmppc/create.go

@@ -79,7 +79,11 @@ type CreateRequest struct {
 
 	// Start VM upon success
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
+
+	// Stack ID
+	// Required: false
+	StackID uint64 `url:"stackId,omitempty" json:"stackId,omitempty"`
 
 	// System name
 	// Required: false
@@ -88,6 +92,10 @@ type CreateRequest struct {
 	// Compute purpose
 	// Required: false
 	IPAType string `url:"ipaType,omitempty" json:"ipaType,omitempty"`
+
+	// Reason for action
+	// Required: false
+	Reason string `url:"reason,omitempty" json:"reason,omitempty"`
 }
 
 type wrapperCreateRequest struct {

pkg/cloudbroker/kvmppc/mass_create.go

@@ -64,7 +64,7 @@ type MassCreateRequest struct {
 
 	// Start after create of not
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
 
 	// Reason to action
 	// Required: false

pkg/cloudbroker/kvmx86/create.go

@@ -79,7 +79,7 @@ type CreateRequest struct {
 
 	// Start VM upon success
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
 
 	// Stack ID
 	// Required: false
@@ -97,6 +97,10 @@ type CreateRequest struct {
 	// Required: false
 	CustomField string `url:"customFields,omitempty" json:"customFields,omitempty"`
 
+	//Type of compute Stateful (KVM_X86) or Stateless (SVA_KVM_X86)
+	// Required: false
+	Driver string `url:"driver,omitempty" json:"driver,omitempty"` 
+
 	// Reason for action
 	// Required: false
 	Reason string `url:"reason,omitempty" json:"reason,omitempty"`

pkg/cloudbroker/kvmx86/create_blank.go

@@ -50,6 +50,10 @@ type CreateBlankRequest struct {
 	// Text description of this VM
 	// Required: false
 	Description string `url:"desc,omitempty" json:"desc,omitempty"`
+
+	//Type of compute Stateful (KVM_X86) or Stateless (SVA_KVM_X86)
+	// Required: false
+	Driver string `url:"driver,omitempty" json:"driver,omitempty"` 
 }
 
 type wrapperCreateBlankRequest struct {

pkg/cloudbroker/kvmx86/mass_create.go

@@ -64,7 +64,7 @@ type MassCreateRequest struct {
 
 	// Start after create of not
 	// Required: false
-	Start bool `url:"start,omitempty" json:"start,omitempty"`
+	Start bool `url:"start" json:"start"`
 
 	// Reason to action
 	// Required: false

pkg/cloudbroker/lb/create.go

@@ -2,12 +2,16 @@ package lb
 
 import (
 	"context"
+	"encoding/json"
+	"errors"
 	"net/http"
 	"strconv"
 
 	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 )
 
+type Params []string
+
 // Request struct for create load balancer
 type CreateRequest struct {
 	// ID of the resource group where this load balancer instance will be located
@@ -20,12 +24,20 @@ type CreateRequest struct {
 	Name string `url:"name" json:"name" validate:"required"`
 
 	// External network to connect this load balancer to
-	// Required: true
+	// Required: false
-	ExtNetID uint64 `url:"extnetId" json:"extnetId" validate:"required"`
+	ExtNetID uint64 `url:"extnetId" json:"extnetId"`
 
 	// Internal network (VINS) to connect this load balancer to
-	// Required: true
+	// Required: false
-	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+	VINSID uint64 `url:"vinsId" json:"vinsId"`
+
+	// Custom  sysctl values for Load Balancer instance. Applied on boot
+	// Required: false
+	SysctlParams Params `url:"-" json:"sysctlParams,omitempty" validate:"omitempty,dive"`
+
+	// Use Highly Available schema for LB deploy
+	// Required: false
+	HighlyAvailable bool `url:"highlyAvailable,omitempty" json:"highlyAvailable,omitempty"`
 
 	// Start now Load balancer
 	// Required: false
@@ -36,6 +48,11 @@ type CreateRequest struct {
 	Description string `url:"desc,omitempty" json:"desc,omitempty"`
 }
 
+type wrapperCreateRequest struct {
+	CreateRequest
+	Params []string `url:"sysctlParams,omitempty"`
+}
+
 // Create method will create a new load balancer instance
 func (lb LB) Create(ctx context.Context, req CreateRequest) (uint64, error) {
 	err := validators.ValidateRequest(req)
@@ -45,9 +62,35 @@ func (lb LB) Create(ctx context.Context, req CreateRequest) (uint64, error) {
 		}
 	}
 
+	if req.ExtNetID == 0 && req.VINSID == 0 {
+		return 0, errors.New("vinsId and extNetId cannot be both in the value 0")
+	}
+
+	var params []string
+
+	if len(req.SysctlParams) != 0 {
+		params = make([]string, 0, len(req.SysctlParams))
+
+		for r := range req.SysctlParams {
+			b, err := json.Marshal(req.SysctlParams[r])
+			if err != nil {
+				return 0, err
+			}
+
+			params = append(params, string(b))
+		}
+	} else {
+		params = []string{}
+	}
+
+	reqWrapped := wrapperCreateRequest{
+		CreateRequest: req,
+		Params:        params,
+	}
+
 	url := "/cloudbroker/lb/create"
 
-	res, err := lb.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	res, err := lb.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
 	if err != nil {
 		return 0, err
 	}

pkg/cloudbroker/lb/make_highly_available.go

@@ -0,0 +1,40 @@
+package lb
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for make Load Balancer Highly available
+type HighlyAvailableRequest struct {
+	// ID of the LB instance
+	// Required: true
+	LBID uint64 `url:"lbId" json:"lbId" validate:"required"`
+}
+
+// Make Load Balancer Highly available
+func (l LB) HighlyAvailable(ctx context.Context, req HighlyAvailableRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/lb/makeHighlyAvailable"
+
+	res, err := l.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/lb/models.go

@@ -156,6 +156,9 @@ type RecordLB struct {
 	// Access Control List
 	ACL []interface{} `json:"acl"`
 
+	// BackendHAIP
+	BackendHAIP string `json:"backendHAIP"`
+
 	// List of load balancer backends
 	Backends ListBackends `json:"backends"`
 
@@ -171,6 +174,9 @@ type RecordLB struct {
 	// External network ID
 	ExtNetID uint64 `json:"extnetId"`
 
+	// FrontendHAIP
+	FrontendHAIP string `json:"frontendHAIP"`
+
 	// List of load balancer frontends
 	Frontends ListFrontends `json:"frontends"`
 
@@ -192,6 +198,9 @@ type RecordLB struct {
 	// Name
 	Name string `json:"name"`
 
+	// Part K8s
+	PartK8s bool `json:"partK8s"`
+
 	// Primary node
 	PrimaryNode Node `json:"primaryNode"`
 
@@ -204,6 +213,9 @@ type RecordLB struct {
 	// Status
 	Status string `json:"status"`
 
+	// Sysctl Params
+	SysctlParams []string `json:"sysctlParams"`
+
 	// Tech status
 	TechStatus string `json:"techStatus"`
 
@@ -219,6 +231,9 @@ type ItemLBList struct {
 	// Access Control List
 	ACL []interface{} `json:"acl"`
 
+	// BackendHAIP
+	BackendHAIP string `json:"backendHAIP"`
+
 	// List of load balancer backends
 	Backends ListBackends `json:"backends"`
 
@@ -246,6 +261,9 @@ type ItemLBList struct {
 	// External network ID
 	ExtNetID uint64 `json:"extnetId"`
 
+	// FrontendHAIP
+	FrontendHAIP string `json:"frontendHAIP"`
+
 	// List of load balancer frontends
 	Frontends ListFrontends `json:"frontends"`
 
@@ -279,6 +297,9 @@ type ItemLBList struct {
 	// Status
 	Status string `json:"status"`
 
+	// Sysctl Params
+	SysctlParams []string `json:"sysctlParams"`
+
 	// Tech status
 	TechStatus string `json:"techStatus"`
 

pkg/cloudbroker/lb/updateSysctParams.go

@@ -0,0 +1,72 @@
+package lb
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for update sysct params for lb
+type UpdateSysctParamsRequest struct {
+	// ID of the LB instance
+	// Required: true
+	LBID uint64 `url:"lbId" json:"lbId" validate:"required"`
+
+	// Custom sysctl values for Load Balancer instance. Applied on boot
+	// Required: true
+	SysctlParams Params `url:"-" json:"sysctlParams" validate:"required,dive"`
+}
+
+type wrapperUpdateSysctParamsRequest struct {
+	UpdateSysctParamsRequest
+	Params []string `url:"sysctlParams" validate:"required"`
+}
+
+// Create method will create a new load balancer instance
+func (l LB) UpdateSysctParams(ctx context.Context, req UpdateSysctParamsRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	var params []string
+
+	if len(req.SysctlParams) != 0 {
+		params = make([]string, 0, len(req.SysctlParams))
+
+		for r := range req.SysctlParams {
+			b, err := json.Marshal(req.SysctlParams[r])
+			if err != nil {
+				return false, err
+			}
+
+			params = append(params, string(b))
+		}
+	} else {
+		params = []string{}
+	}
+
+	reqWrapped := wrapperUpdateSysctParamsRequest{
+		UpdateSysctParamsRequest: req,
+		Params:                   params,
+	}
+
+	url := "/cloudbroker/lb/updateSysctParams"
+
+	res, err := l.client.DecortApiCall(ctx, http.MethodPost, url, reqWrapped)
+	if err != nil {
+		return false, err
+	}
+
+	result, err := strconv.ParseBool(string(res))
+	if err != nil {
+		return false, err
+	}
+
+	return result, nil
+}

pkg/cloudbroker/vins/models.go

@@ -411,8 +411,19 @@ type InfoVNF struct {
 	Type string `json:"type"`
 }
 
+// List of static routes
+type ListStaticRoutes struct {
+	// Data
+	Data []ItemRoutes `json:"data"`
+
+	// Entry count
+	EntryCount uint64 `json:"entryCount"`
+}
+
+// List of Routes
 type ListRoutes []ItemRoutes
 
+// Detailed information about Routes
 type ItemRoutes struct {
 	//Compute Id
 	ComputeIds []uint64 `json:"computeIds"`
@@ -424,7 +435,7 @@ type ItemRoutes struct {
 	Gateway string `json:"gateway"`
 
 	// GUID
-	GUID uint64 `json:"guid"`
+	GUID string `json:"guid"`
 
 	// ID
 	ID uint64 `json:"id"`

pkg/cloudbroker/vins/static_route_access_grant.go

@@ -0,0 +1,48 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for grant access to static route to Compute/ViNS
+type StaticRouteAccessGrantRequest struct {
+	// ViNS ID to grant access
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to grant access, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to grant access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Grant access to static route to Compute/ViNS
+func (v VINS) StaticRouteAccessGrant(ctx context.Context, req StaticRouteAccessGrantRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/vins/staticRouteAccessGrant"
+
+	res, err := v.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/vins/static_route_access_revoke.go

@@ -0,0 +1,48 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for revoke access to static route to Compute/ViNS
+type StaticRouteAccessRevokeRequest struct {
+	// ViNS ID to revoke access
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to revoke access, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+
+	// List of Compute IDs to revoke access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// Revoke access to static route to Compute/ViNS
+func (v VINS) StaticRouteAccessRevoke(ctx context.Context, req StaticRouteAccessRevokeRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/vins/staticRouteAccessRevoke"
+
+	res, err := v.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/vins/static_route_add.go

@@ -0,0 +1,56 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for add static route
+type StaticRouteAddRequest struct {
+	// VINS ID
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Destination network
+	// Required: true
+	Destination string `url:"destination" json:"destination" validate:"required"`
+
+	// Destination network mask in 255.255.255.255 format
+	// Required: true
+	Netmask string `url:"netmask" json:"netmask" validate:"required"`
+
+	// Next hop host, IP address from ViNS ID free IP pool
+	// Required: true
+	Gateway string `url:"gateway" json:"gateway" validate:"required"`
+
+	// List of Compute IDs which have access to this route
+	// Required: false
+	ComputeIds []uint64 `url:"computeIds,omitempty" json:"computeIds,omitempty"`
+}
+
+// StaticRouteAdd add new static route to ViNS
+func (v VINS) StaticRouteAdd(ctx context.Context, req StaticRouteAddRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/vins/staticRouteAdd"
+
+	res, err := v.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/vins/static_route_del.go

@@ -0,0 +1,44 @@
+package vins
+
+import (
+	"context"
+	"net/http"
+	"strconv"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for remove static route from ViNS
+type StaticRouteDelRequest struct {
+	// ViNS ID to remove static route from
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+
+	// Route ID to remove, can be found in staticRouteList
+	// Required: true
+	RouteId uint64 `url:"routeId" json:"routeId" validate:"required"`
+}
+
+// Remove static route from ViNS
+func (v VINS) StaticRouteDel(ctx context.Context, req StaticRouteDelRequest) (bool, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return false, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/vins/staticRouteDel"
+
+	res, err := v.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/vins/static_route_list.go

@@ -0,0 +1,42 @@
+package vins
+
+import (
+	"context"
+	"encoding/json"
+	"net/http"
+
+	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
+)
+
+// Request struct for static route list
+type StaticRouteListRequest struct {
+	// ViNS ID to show list of static routes
+	// Required: true
+	VINSID uint64 `url:"vinsId" json:"vinsId" validate:"required"`
+}
+
+// Show list of static routes for ViNS
+func (v VINS) StaticRouteList(ctx context.Context, req StaticRouteListRequest) (*ListStaticRoutes, error) {
+	err := validators.ValidateRequest(req)
+	if err != nil {
+		for _, validationError := range validators.GetErrors(err) {
+			return nil, validators.ValidationError(validationError)
+		}
+	}
+
+	url := "/cloudbroker/vins/staticRouteList"
+
+	res, err := v.client.DecortApiCall(ctx, http.MethodPost, url, req)
+	if err != nil {
+		return nil, err
+	}
+
+	list := ListStaticRoutes{}
+
+	err = json.Unmarshal(res, &list)
+	if err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}