v1.14.5
This commit is contained in:
52
CHANGELOG.md
52
CHANGELOG.md
@@ -1,4 +1,4 @@
|
||||
## Version 1.14.4
|
||||
## Version 1.14.5
|
||||
|
||||
Методы `Audits` в cloudapi/compute, cloudbroker/compute, cloudapi/account, cloudbroker/account, cloudapi/vins, cloudbroker/vins, cloudapi/rg и cloudbroker/rg стали deprecated и в следующих версиях будут удалены, вместо них необходимо использовать метод `List` в cloudapi/audit и cloudbroker/audit с соответствующими фильтрами
|
||||
Методы `AccessGrant`, `AccessGrantToPool`, `AccessRevoke`, `AccessRevokeToPool` в cloudbroker/sep стали deprecated и в следующих версиях будут удалены
|
||||
@@ -9,27 +9,41 @@
|
||||
|
||||
### Добавлено
|
||||
|
||||
#### image
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-812 | Методы `CreateMultiImage`, `MultiImageAddLinks`, `MultiImageDelLinks` и `MultiImageExport` в cloudbroker/image |
|
||||
| BGOS-812 | Структуры запросов `CreateMultiImageRequest`, `MultiImageAddLinksRequest`, `MultiImageDelLinksRequest` и `MultiImageExportRequest` в cloudbroker/image |
|
||||
| BGOS-813 | Вычисляемое поле `LinksTo` в структуры ответа `RecordImage` и `ItemImage` в cloudbroker/image и в структуру ответа `RecordImage` в cloudapi/image |
|
||||
|
||||
### node
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-811 | Вычисляемое поле `ThreadCount` в структуру ответа `CpuInfo` в cloudbroker/node |
|
||||
|
||||
|
||||
### Изменено
|
||||
|
||||
#### compute
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-814 | Тип возвращаемого значения метода `CheckComputePlacement` с `map[string]CheckComputePlacementItem` на `map[uint64]CheckComputePlacementItem` в cloudbroker/compute |
|
||||
| BGOS-360 | Валидация поля `Label` в структуре запроса `SnapshotCreateRequest` в cloudapi/compute и cloudbroker/compute |
|
||||
|
||||
#### rg
|
||||
#### image
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-815 | JSON-тэг у поля `RGID` в структуре ответа `ItemResourceConsumption` с `rgid` на `id` в cloudbroker/rg |
|
||||
| BGOS-820 | Обязательное поле `SEPID` в структуру запроса `MultiImageExportRequest` в cloudbroker/image |
|
||||
|
||||
#### locations
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-823 | Вычисляемое поле `ZeroAccessEnabled` в структуру ответа `ItemLocation` в cloudapi/locations |
|
||||
|
||||
#### resource_optimizer
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-818 | Группа методов `cloudbroker/resource_optimizer` для управления инструментом оптимизации ресурсов (DRS) |
|
||||
|
||||
### zone
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-819 | Вычисляемые поля `DRS`, `DRSUID`, `AppID`, `DecortURL`, `DRSName` и `SSOURL` в структуру ответа `RecordZone` в cloudapi/zone и в cloudbroker/zone |
|
||||
| BGOS-819 | Структура ответа `ItemZone` в cloudapi/zone и в cloudbroker/zone |
|
||||
| BGOS-819 | Опциональное поле `DRS` в структуру запроса `CreateRequest` в cloudbroker/zone |
|
||||
|
||||
### Изменено
|
||||
|
||||
#### image
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-822 | Тип полей `HotResize` и `Bootable` в структуре запроса `EditRequest` с bool на interface в cloudbroker/image |
|
||||
|
||||
#### node
|
||||
| Идентификатор<br>задачи | Описание |
|
||||
| --- | --- |
|
||||
| BGOS-821 | Тип вычисляемого поля `VCPU` с `uint64` на `float64` в структуре ответа `FreeResourcesInfo` в cloudbroker/node |
|
||||
@@ -160,6 +160,7 @@ go get -u repository.basistech.ru/BASIS/decort-golang-sdk
|
||||
- `PCIDevice` - управление устройствами;
|
||||
- `Prometheus` - получение статистики prometheus;
|
||||
- `Resmon` - получение статистики resource monitoring;
|
||||
- `ResourceOptimizer` - управление инструментом оптимизации ресурсов (DRS);
|
||||
- `RG` - управление ресурсными группами аккаунта;
|
||||
- `Security group` – управление группами безопасности;
|
||||
- `SEP` - управление storage endpoint (sep);
|
||||
@@ -365,6 +366,7 @@ func main() {
|
||||
- `pkg/cloudbroker/pcidevice` - для `PCIDevice`
|
||||
- `pkg/cloudbroker/prometheus` - для `Prometheus`
|
||||
- `pkg/cloudbroker/resmon` - для `Resmon`
|
||||
- `pkg/cloudbroker/resource_optimizer` - для `ResourceOptimizer`
|
||||
- `pkg/cloudbroker/rg` - для `RG`
|
||||
- `pkg/cloudbroker/secgroup` - для `Security group`
|
||||
- `pkg/cloudbroker/sep` - для `SEP`
|
||||
@@ -563,6 +565,7 @@ func main() {
|
||||
- `.PCIDevice()` - для работы с `PCIDevice`
|
||||
- `.Prometheus()` - для работы с `Prometheus`
|
||||
- `.Resmon()` - для работы с `Resmon`
|
||||
- `.ResourceOptimizer()` - для работы с `ResourceOptimizer`
|
||||
- `.RG()` - для работы с `RG`
|
||||
- `.SecurityGroup()` - для работы с `Security Group`
|
||||
- `.SEP()` - для работы с `SEP`
|
||||
|
||||
@@ -16,8 +16,10 @@ type SnapshotCreateRequest struct {
|
||||
|
||||
// Text label for snapshot.
|
||||
// Must be unique among this compute snapshots
|
||||
// Allowed characters: a-z, 0-9, spaces, punctuation except '<' and '>'
|
||||
// Maximum length: 36 characters
|
||||
// Required: true
|
||||
Label string `url:"label" json:"label" validate:"required"`
|
||||
Label string `url:"label" json:"label" validate:"required,max=36,excludesall=<>"`
|
||||
}
|
||||
|
||||
// SnapshotCreate create compute snapshot
|
||||
|
||||
@@ -34,6 +34,9 @@ type ItemLocation struct {
|
||||
|
||||
// Support of SDN
|
||||
SDNSupport bool `json:"sdn_support"`
|
||||
|
||||
// Is Zero Access enabled
|
||||
ZeroAccessEnabled bool `json:"zeroaccess_enabled"`
|
||||
}
|
||||
|
||||
// List of locations
|
||||
|
||||
@@ -2,7 +2,7 @@ package zone
|
||||
|
||||
// FilterByID returns ListZones with specified ID.
|
||||
func (list ListZones) FilterByID(id uint64) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.ID == id
|
||||
}
|
||||
|
||||
@@ -11,7 +11,7 @@ func (list ListZones) FilterByID(id uint64) ListZones {
|
||||
|
||||
// FilterByName returns ListZones with specified Name.
|
||||
func (list ListZones) FilterByName(name string) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.Name == name
|
||||
}
|
||||
|
||||
@@ -20,7 +20,7 @@ func (list ListZones) FilterByName(name string) ListZones {
|
||||
|
||||
// FilterByStatus returns ListZones with specified Status.
|
||||
func (list ListZones) FilterByStatus(status string) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.Status == status
|
||||
}
|
||||
|
||||
@@ -28,7 +28,7 @@ func (list ListZones) FilterByStatus(status string) ListZones {
|
||||
}
|
||||
|
||||
// FilterFunc allows filtering ListZones based on a user-specified predicate.
|
||||
func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
|
||||
func (list ListZones) FilterFunc(predicate func(ItemZone) bool) ListZones {
|
||||
var result ListZones
|
||||
|
||||
for _, item := range list.Data {
|
||||
@@ -42,11 +42,11 @@ func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
|
||||
return result
|
||||
}
|
||||
|
||||
// FindOne returns first found RecordZone
|
||||
// FindOne returns first found ItemZone
|
||||
// If none was found, returns an empty struct.
|
||||
func (list ListZones) FindOne() RecordZone {
|
||||
func (list ListZones) FindOne() ItemZone {
|
||||
if list.EntryCount == 0 {
|
||||
return RecordZone{}
|
||||
return ItemZone{}
|
||||
}
|
||||
|
||||
return list.Data[0]
|
||||
|
||||
@@ -3,7 +3,7 @@ package zone
|
||||
import "testing"
|
||||
|
||||
var zones = ListZones{
|
||||
Data: []RecordZone{
|
||||
Data: []ItemZone{
|
||||
|
||||
{
|
||||
ID: 2,
|
||||
@@ -76,7 +76,7 @@ func TestFilterByStatus(t *testing.T) {
|
||||
}
|
||||
|
||||
func TestFilterFunc(t *testing.T) {
|
||||
actual := zones.FilterFunc(func(ien RecordZone) bool {
|
||||
actual := zones.FilterFunc(func(ien ItemZone) bool {
|
||||
return ien.Deletable == true
|
||||
})
|
||||
|
||||
|
||||
@@ -5,7 +5,7 @@ type ListZones struct {
|
||||
EntryCount uint64 `json:"entryCount"`
|
||||
|
||||
// Data
|
||||
Data []RecordZone `json:"data"`
|
||||
Data []ItemZone `json:"data"`
|
||||
}
|
||||
|
||||
// Detailed information about the zone record
|
||||
@@ -63,4 +63,76 @@ type RecordZone struct {
|
||||
|
||||
// List of associated VINS IDs
|
||||
VinsIDs []uint64 `json:"vinsIds"`
|
||||
|
||||
// DRS
|
||||
DRS bool `json:"drs"`
|
||||
|
||||
// DRS UID
|
||||
DRSUID string `json:"drs_uid"`
|
||||
|
||||
// App ID
|
||||
AppID string `json:"app_id"`
|
||||
|
||||
// Decort URL
|
||||
DecortURL string `json:"decort_url"`
|
||||
|
||||
// DRS Name
|
||||
DRSName string `json:"drs_name"`
|
||||
|
||||
// SSO URL
|
||||
SSOURL string `json:"sso_url"`
|
||||
}
|
||||
|
||||
// A zone item from a list
|
||||
type ItemZone struct {
|
||||
// App ID
|
||||
AppID string `json:"app_id"`
|
||||
|
||||
// If true, all nodes belonging to the given zone will be marked for autostart
|
||||
AutoStart bool `json:"autostart"`
|
||||
|
||||
// Created timestamp
|
||||
CreatedTime uint64 `json:"createdTime"`
|
||||
|
||||
// Decort URL
|
||||
DecortURL string `json:"decort_url"`
|
||||
|
||||
// Deletable flag
|
||||
Deletable bool `json:"deletable"`
|
||||
|
||||
// Description
|
||||
Description string `json:"description"`
|
||||
|
||||
// DRS
|
||||
DRS bool `json:"drs"`
|
||||
|
||||
// DRS Name
|
||||
DRSName string `json:"drs_name"`
|
||||
|
||||
// DRS UID
|
||||
DRSUID string `json:"drs_uid"`
|
||||
|
||||
// GID
|
||||
GID uint64 `json:"gid"`
|
||||
|
||||
// GUID
|
||||
GUID uint64 `json:"guid"`
|
||||
|
||||
// ID
|
||||
ID uint64 `json:"id"`
|
||||
|
||||
// Name
|
||||
Name string `json:"name"`
|
||||
|
||||
// List of associated Node IDs
|
||||
NodeIDs []uint64 `json:"nodeIds"`
|
||||
|
||||
// SSO URL
|
||||
SSOURL string `json:"sso_url"`
|
||||
|
||||
// Status
|
||||
Status string `json:"status"`
|
||||
|
||||
// Updated timestamp
|
||||
UpdatedTime uint64 `json:"updatedTime"`
|
||||
}
|
||||
|
||||
@@ -16,8 +16,10 @@ type SnapshotCreateRequest struct {
|
||||
|
||||
// Text label for snapshot.
|
||||
// Must be unique among this compute snapshots
|
||||
// Allowed characters: a-z, 0-9, spaces, punctuation except '<' and '>'
|
||||
// Maximum length: 36 characters
|
||||
// Required: true
|
||||
Label string `url:"label" json:"label" validate:"required"`
|
||||
Label string `url:"label" json:"label" validate:"required,max=36,excludesall=<>"`
|
||||
}
|
||||
|
||||
// SnapshotCreate creates compute snapshot
|
||||
|
||||
@@ -39,11 +39,11 @@ type EditRequest struct {
|
||||
|
||||
// Does this machine supports hot resize
|
||||
// Required: false
|
||||
HotResize bool `url:"hotresize,omitempty" json:"hotresize,omitempty"`
|
||||
HotResize interface{} `url:"hotresize,omitempty" json:"hotresize,omitempty" validate:"omitempty,isBool"`
|
||||
|
||||
// Does this image boot OS
|
||||
// Required: false
|
||||
Bootable bool `url:"bootable,omitempty" json:"bootable,omitempty"`
|
||||
Bootable interface{} `url:"bootable,omitempty" json:"bootable,omitempty" validate:"omitempty,isBool"`
|
||||
}
|
||||
|
||||
// Edit edits an existing image
|
||||
|
||||
@@ -17,6 +17,10 @@ type MultiImageExportRequest struct {
|
||||
// Name of the target pool
|
||||
// Required: true
|
||||
PoolName string `url:"pool_name" json:"pool_name" validate:"required"`
|
||||
|
||||
// Target SEP ID
|
||||
// Required: true
|
||||
SEPID uint64 `url:"sep_id" json:"sep_id" validate:"required"`
|
||||
}
|
||||
|
||||
// MultiImageExport copies a physical image from multi image to the specified pool
|
||||
|
||||
@@ -120,7 +120,7 @@ type FreeResourcesInfo struct {
|
||||
RAM float64 `json:"RAM"`
|
||||
|
||||
// VCPU
|
||||
VCPU uint64 `json:"vCPUs"`
|
||||
VCPU float64 `json:"vCPUs"`
|
||||
}
|
||||
|
||||
// Resources Info
|
||||
|
||||
10
pkg/cloudbroker/resource_optimizer.go
Normal file
10
pkg/cloudbroker/resource_optimizer.go
Normal file
@@ -0,0 +1,10 @@
|
||||
package cloudbroker
|
||||
|
||||
import (
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/resource_optimizer"
|
||||
)
|
||||
|
||||
// Accessing the ResourceOptimizer method group
|
||||
func (cb *CloudBroker) ResourceOptimizer() *resource_optimizer.ResourceOptimizer {
|
||||
return resource_optimizer.New(cb.client)
|
||||
}
|
||||
42
pkg/cloudbroker/resource_optimizer/drs_add_nodes.go
Normal file
42
pkg/cloudbroker/resource_optimizer/drs_add_nodes.go
Normal file
@@ -0,0 +1,42 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSAddNodesRequest struct to add nodes to DRS
|
||||
type DRSAddNodesRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
|
||||
// IDs of the nodes to add
|
||||
// Required: true
|
||||
NodeIDs []uint64 `url:"node_ids" json:"node_ids" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSAddNodes adds nodes to DRS in the specified zone
|
||||
func (ro ResourceOptimizer) DRSAddNodes(ctx context.Context, req DRSAddNodesRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_add_nodes"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
58
pkg/cloudbroker/resource_optimizer/drs_create.go
Normal file
58
pkg/cloudbroker/resource_optimizer/drs_create.go
Normal file
@@ -0,0 +1,58 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSCreateRequest struct to create DRS
|
||||
type DRSCreateRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
|
||||
// Application ID
|
||||
// Required: true
|
||||
AppID string `url:"app_id" json:"app_id" validate:"required"`
|
||||
|
||||
// Application secret
|
||||
// Required: true
|
||||
AppSecret string `url:"app_secret" json:"app_secret" validate:"required"`
|
||||
|
||||
// Decort URL
|
||||
// Required: true
|
||||
DecortURL string `url:"decort_url" json:"decort_url" validate:"required"`
|
||||
|
||||
// SSO URL
|
||||
// Required: true
|
||||
SSOURL string `url:"sso_url" json:"sso_url" validate:"required"`
|
||||
|
||||
// DRS name
|
||||
// Required: true
|
||||
DRSName string `url:"drs_name" json:"drs_name" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSCreate creates a new DRS in the specified zone
|
||||
func (ro ResourceOptimizer) DRSCreate(ctx context.Context, req DRSCreateRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_create"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
42
pkg/cloudbroker/resource_optimizer/drs_del_nodes.go
Normal file
42
pkg/cloudbroker/resource_optimizer/drs_del_nodes.go
Normal file
@@ -0,0 +1,42 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSDelNodesRequest struct to delete nodes from DRS
|
||||
type DRSDelNodesRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
|
||||
// IDs of the nodes to delete
|
||||
// Required: true
|
||||
NodeIDs []uint64 `url:"node_ids" json:"node_ids" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSDelNodes removes nodes from DRS in the specified zone
|
||||
func (ro ResourceOptimizer) DRSDelNodes(ctx context.Context, req DRSDelNodesRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_del_nodes"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
38
pkg/cloudbroker/resource_optimizer/drs_remove.go
Normal file
38
pkg/cloudbroker/resource_optimizer/drs_remove.go
Normal file
@@ -0,0 +1,38 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSRemoveRequest struct to remove DRS
|
||||
type DRSRemoveRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSRemove removes DRS from the specified zone
|
||||
func (ro ResourceOptimizer) DRSRemove(ctx context.Context, req DRSRemoveRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_remove"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
38
pkg/cloudbroker/resource_optimizer/drs_start.go
Normal file
38
pkg/cloudbroker/resource_optimizer/drs_start.go
Normal file
@@ -0,0 +1,38 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSStartRequest struct to start DRS
|
||||
type DRSStartRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSStart starts DRS in the specified zone
|
||||
func (ro ResourceOptimizer) DRSStart(ctx context.Context, req DRSStartRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_start"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
38
pkg/cloudbroker/resource_optimizer/drs_stop.go
Normal file
38
pkg/cloudbroker/resource_optimizer/drs_stop.go
Normal file
@@ -0,0 +1,38 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSStopRequest struct to stop DRS
|
||||
type DRSStopRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
}
|
||||
|
||||
// DRSStop stops DRS in the specified zone
|
||||
func (ro ResourceOptimizer) DRSStop(ctx context.Context, req DRSStopRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_stop"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
58
pkg/cloudbroker/resource_optimizer/drs_update.go
Normal file
58
pkg/cloudbroker/resource_optimizer/drs_update.go
Normal file
@@ -0,0 +1,58 @@
|
||||
package resource_optimizer
|
||||
|
||||
import (
|
||||
"context"
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
|
||||
)
|
||||
|
||||
// DRSUpdateRequest struct to update DRS
|
||||
type DRSUpdateRequest struct {
|
||||
// ID of the zone
|
||||
// Required: true
|
||||
ZoneID uint64 `url:"zone_id" json:"zone_id" validate:"required"`
|
||||
|
||||
// Application ID
|
||||
// Required: false
|
||||
AppID string `url:"app_id,omitempty" json:"app_id,omitempty"`
|
||||
|
||||
// Application secret
|
||||
// Required: false
|
||||
AppSecret string `url:"app_secret,omitempty" json:"app_secret,omitempty"`
|
||||
|
||||
// Decort URL
|
||||
// Required: false
|
||||
DecortURL string `url:"decort_url,omitempty" json:"decort_url,omitempty"`
|
||||
|
||||
// SSO URL
|
||||
// Required: false
|
||||
SSOURL string `url:"sso_url,omitempty" json:"sso_url,omitempty"`
|
||||
|
||||
// DRS name
|
||||
// Required: false
|
||||
DRSName string `url:"drs_name,omitempty" json:"drs_name,omitempty"`
|
||||
}
|
||||
|
||||
// DRSUpdate updates DRS configuration in the specified zone
|
||||
func (ro ResourceOptimizer) DRSUpdate(ctx context.Context, req DRSUpdateRequest) (bool, error) {
|
||||
err := validators.ValidateRequest(req)
|
||||
if err != nil {
|
||||
return false, validators.ValidationErrors(validators.GetErrors(err))
|
||||
}
|
||||
|
||||
url := "/cloudbroker/resource_optimizer/drs_update"
|
||||
|
||||
res, err := ro.client.DecortApiCall(ctx, http.MethodPost, url, req)
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
result, err := strconv.ParseBool(string(res))
|
||||
if err != nil {
|
||||
return false, err
|
||||
}
|
||||
|
||||
return result, nil
|
||||
}
|
||||
16
pkg/cloudbroker/resource_optimizer/resource_optimizer.go
Normal file
16
pkg/cloudbroker/resource_optimizer/resource_optimizer.go
Normal file
@@ -0,0 +1,16 @@
|
||||
// API Actor API for managing resource optimizer
|
||||
package resource_optimizer
|
||||
|
||||
import "repository.basistech.ru/BASIS/decort-golang-sdk/interfaces"
|
||||
|
||||
// Structure for creating request to resource_optimizer
|
||||
type ResourceOptimizer struct {
|
||||
client interfaces.Caller
|
||||
}
|
||||
|
||||
// Builder for resource_optimizer endpoints
|
||||
func New(client interfaces.Caller) *ResourceOptimizer {
|
||||
return &ResourceOptimizer{
|
||||
client: client,
|
||||
}
|
||||
}
|
||||
@@ -21,6 +21,10 @@ type CreateRequest struct {
|
||||
// If true, all nodes belonging to the given zone will be marked for autostart
|
||||
// Required: false
|
||||
AutoStart interface{} `url:"autostart,omitempty" json:"autostart,omitempty" validate:"omitempty,isBool"`
|
||||
|
||||
// Enables Distributed Resource Scheduler (DRS) functionality for the zone
|
||||
// Required: false
|
||||
DRS interface{} `url:"drs,omitempty" json:"drs,omitempty" validate:"omitempty,isBool"`
|
||||
}
|
||||
|
||||
// Create creates zone object
|
||||
|
||||
@@ -2,7 +2,7 @@ package zone
|
||||
|
||||
// FilterByID returns ListZones with specified ID.
|
||||
func (list ListZones) FilterByID(id uint64) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.ID == id
|
||||
}
|
||||
|
||||
@@ -11,7 +11,7 @@ func (list ListZones) FilterByID(id uint64) ListZones {
|
||||
|
||||
// FilterByName returns ListZones with specified Name.
|
||||
func (list ListZones) FilterByName(name string) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.Name == name
|
||||
}
|
||||
|
||||
@@ -20,7 +20,7 @@ func (list ListZones) FilterByName(name string) ListZones {
|
||||
|
||||
// FilterByStatus returns ListZones with specified Status.
|
||||
func (list ListZones) FilterByStatus(status string) ListZones {
|
||||
predicate := func(izone RecordZone) bool {
|
||||
predicate := func(izone ItemZone) bool {
|
||||
return izone.Status == status
|
||||
}
|
||||
|
||||
@@ -28,7 +28,7 @@ func (list ListZones) FilterByStatus(status string) ListZones {
|
||||
}
|
||||
|
||||
// FilterFunc allows filtering ListZones based on a user-specified predicate.
|
||||
func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
|
||||
func (list ListZones) FilterFunc(predicate func(ItemZone) bool) ListZones {
|
||||
var result ListZones
|
||||
|
||||
for _, item := range list.Data {
|
||||
@@ -42,11 +42,11 @@ func (list ListZones) FilterFunc(predicate func(RecordZone) bool) ListZones {
|
||||
return result
|
||||
}
|
||||
|
||||
// FindOne returns first found RecordZone
|
||||
// FindOne returns first found ItemZone
|
||||
// If none was found, returns an empty struct.
|
||||
func (list ListZones) FindOne() RecordZone {
|
||||
func (list ListZones) FindOne() ItemZone {
|
||||
if list.EntryCount == 0 {
|
||||
return RecordZone{}
|
||||
return ItemZone{}
|
||||
}
|
||||
|
||||
return list.Data[0]
|
||||
|
||||
@@ -3,7 +3,7 @@ package zone
|
||||
import "testing"
|
||||
|
||||
var zones = ListZones{
|
||||
Data: []RecordZone{
|
||||
Data: []ItemZone{
|
||||
|
||||
{
|
||||
ID: 2,
|
||||
@@ -76,7 +76,7 @@ func TestFilterByStatus(t *testing.T) {
|
||||
}
|
||||
|
||||
func TestFilterFunc(t *testing.T) {
|
||||
actual := zones.FilterFunc(func(ien RecordZone) bool {
|
||||
actual := zones.FilterFunc(func(ien ItemZone) bool {
|
||||
return ien.Deletable == true
|
||||
})
|
||||
|
||||
|
||||
@@ -5,7 +5,7 @@ type ListZones struct {
|
||||
EntryCount uint64 `json:"entryCount"`
|
||||
|
||||
// Data
|
||||
Data []RecordZone `json:"data"`
|
||||
Data []ItemZone `json:"data"`
|
||||
}
|
||||
|
||||
// Detailed information about the zone record
|
||||
@@ -63,4 +63,76 @@ type RecordZone struct {
|
||||
|
||||
// List of associated VINS IDs
|
||||
VinsIDs []uint64 `json:"vinsIds"`
|
||||
|
||||
// DRS
|
||||
DRS bool `json:"drs"`
|
||||
|
||||
// DRS UID
|
||||
DRSUID string `json:"drs_uid"`
|
||||
|
||||
// App ID
|
||||
AppID string `json:"app_id"`
|
||||
|
||||
// Decort URL
|
||||
DecortURL string `json:"decort_url"`
|
||||
|
||||
// DRS Name
|
||||
DRSName string `json:"drs_name"`
|
||||
|
||||
// SSO URL
|
||||
SSOURL string `json:"sso_url"`
|
||||
}
|
||||
|
||||
// A zone item from a list
|
||||
type ItemZone struct {
|
||||
// App ID
|
||||
AppID string `json:"app_id"`
|
||||
|
||||
// If true, all nodes belonging to the given zone will be marked for autostart
|
||||
AutoStart bool `json:"autostart"`
|
||||
|
||||
// Created timestamp
|
||||
CreatedTime uint64 `json:"createdTime"`
|
||||
|
||||
// Decort URL
|
||||
DecortURL string `json:"decort_url"`
|
||||
|
||||
// Deletable flag
|
||||
Deletable bool `json:"deletable"`
|
||||
|
||||
// Description
|
||||
Description string `json:"description"`
|
||||
|
||||
// DRS
|
||||
DRS bool `json:"drs"`
|
||||
|
||||
// DRS Name
|
||||
DRSName string `json:"drs_name"`
|
||||
|
||||
// DRS UID
|
||||
DRSUID string `json:"drs_uid"`
|
||||
|
||||
// GID
|
||||
GID uint64 `json:"gid"`
|
||||
|
||||
// GUID
|
||||
GUID uint64 `json:"guid"`
|
||||
|
||||
// ID
|
||||
ID uint64 `json:"id"`
|
||||
|
||||
// Name
|
||||
Name string `json:"name"`
|
||||
|
||||
// List of associated Node IDs
|
||||
NodeIDs []uint64 `json:"nodeIds"`
|
||||
|
||||
// SSO URL
|
||||
SSOURL string `json:"sso_url"`
|
||||
|
||||
// Status
|
||||
Status string `json:"status"`
|
||||
|
||||
// Updated timestamp
|
||||
UpdatedTime uint64 `json:"updatedTime"`
|
||||
}
|
||||
|
||||
@@ -57,6 +57,7 @@ import (
|
||||
node_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/node"
|
||||
pcidevice_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/pcidevice"
|
||||
prometheus_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/prometheus"
|
||||
resource_optimizer_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/resource_optimizer"
|
||||
rg_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/rg"
|
||||
secgroup_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/secgroup"
|
||||
sep_cb "repository.basistech.ru/BASIS/decort-golang-sdk/pkg/cloudbroker/sep"
|
||||
@@ -923,6 +924,15 @@ func getRequestsMapCloudbroker() map[string]interface{} {
|
||||
"/restmachine/cloudbroker/prometheus/computeMemoryUsage": prometheus_cb.ComputeMemoryUsageRequest{},
|
||||
"/restmachine/cloudbroker/prometheus/computeMemoryUnused": prometheus_cb.ComputeMemoryUnusedRequest{},
|
||||
|
||||
// resource_optimizer
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_add_nodes": resource_optimizer_cb.DRSAddNodesRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_create": resource_optimizer_cb.DRSCreateRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_del_nodes": resource_optimizer_cb.DRSDelNodesRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_remove": resource_optimizer_cb.DRSRemoveRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_start": resource_optimizer_cb.DRSStartRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_stop": resource_optimizer_cb.DRSStopRequest{},
|
||||
"/restmachine/cloudbroker/resource_optimizer/drs_update": resource_optimizer_cb.DRSUpdateRequest{},
|
||||
|
||||
// rg
|
||||
"/restmachine/cloudbroker/rg/accessGrant": rg_cb.AccessGrantRequest{},
|
||||
"/restmachine/cloudbroker/rg/accessRevoke": rg_cb.AccessRevokeRequest{},
|
||||
|
||||
Reference in New Issue
Block a user