You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							104 lines
						
					
					
						
							2.7 KiB
						
					
					
				
			
		
		
	
	
							104 lines
						
					
					
						
							2.7 KiB
						
					
					
				package compute
 | 
						|
 | 
						|
import (
 | 
						|
	"context"
 | 
						|
	"errors"
 | 
						|
	"net/http"
 | 
						|
	"strconv"
 | 
						|
 | 
						|
	"repository.basistech.ru/BASIS/decort-golang-sdk/internal/validators"
 | 
						|
)
 | 
						|
 | 
						|
// Request struct for add affinity rule
 | 
						|
type AffinityRuleAddRequest struct {
 | 
						|
	// IDs of the compute instances
 | 
						|
	// Required: true
 | 
						|
	ComputeIDs []uint64 `url:"computeIds" json:"computeIds"`
 | 
						|
 | 
						|
	// Should be one of:
 | 
						|
	//	- node
 | 
						|
	//	- compute
 | 
						|
	// Required: true
 | 
						|
	Topology string `url:"topology" json:"topology"`
 | 
						|
 | 
						|
	// The degree of 'strictness' of this rule
 | 
						|
	// Should be one of:
 | 
						|
	//	- RECOMMENDED
 | 
						|
	//	- REQUIRED
 | 
						|
	// Required: true
 | 
						|
	Policy string `url:"policy" json:"policy"`
 | 
						|
 | 
						|
	// The comparison mode is 'value', recorded by the specified 'key'
 | 
						|
	// Should be one of:
 | 
						|
	//	- EQ
 | 
						|
	//	- EN
 | 
						|
	//	- ANY
 | 
						|
	// Required: true
 | 
						|
	Mode string `url:"mode" json:"mode"`
 | 
						|
 | 
						|
	// Key that are taken into account when analyzing this rule will be identified
 | 
						|
	// Required: true
 | 
						|
	Key string `url:"key" json:"key"`
 | 
						|
 | 
						|
	// Value that must match the key to be taken into account when analyzing this rule
 | 
						|
	// Required: true
 | 
						|
	Value string `url:"value" json:"value"`
 | 
						|
}
 | 
						|
 | 
						|
func (crq AffinityRuleAddRequest) validate() error {
 | 
						|
	if len(crq.ComputeIDs) == 0 {
 | 
						|
		return errors.New("validation-error: field ComputeIDs must be set")
 | 
						|
	}
 | 
						|
	if crq.Topology == "" {
 | 
						|
		return errors.New("validation-error: field Topology must be set")
 | 
						|
	}
 | 
						|
	validator := validators.StringInSlice(crq.Topology, []string{"compute", "node"})
 | 
						|
	if !validator {
 | 
						|
		return errors.New("validation-error: field Topology can be only compute or node")
 | 
						|
	}
 | 
						|
	if crq.Policy == "" {
 | 
						|
		return errors.New("validation-error: field Policy must be set")
 | 
						|
	}
 | 
						|
	validator = validators.StringInSlice(crq.Policy, []string{"RECOMMENDED", "REQUIRED"})
 | 
						|
	if !validator {
 | 
						|
		return errors.New("validation-error: field Policy can be only RECOMMENDED or REQUIRED")
 | 
						|
	}
 | 
						|
	if crq.Mode == "" {
 | 
						|
		return errors.New("validation-error: field Mode must be set")
 | 
						|
	}
 | 
						|
	validator = validators.StringInSlice(crq.Mode, []string{"EQ", "NE", "ANY"})
 | 
						|
	if !validator {
 | 
						|
		return errors.New("validation-error: field Mode can be only EQ, NE or ANY")
 | 
						|
	}
 | 
						|
	if crq.Key == "" {
 | 
						|
		return errors.New("validation-error: field Key must be set")
 | 
						|
	}
 | 
						|
	if crq.Value == "" {
 | 
						|
		return errors.New("validation-error: field Value must be set")
 | 
						|
	}
 | 
						|
 | 
						|
	return nil
 | 
						|
}
 | 
						|
 | 
						|
// AffinityRuleAdd add affinity rule
 | 
						|
func (c Compute) AffinityRuleAdd(ctx context.Context, req AffinityRuleAddRequest) (bool, error) {
 | 
						|
	err := req.validate()
 | 
						|
	if err != nil {
 | 
						|
		return false, err
 | 
						|
	}
 | 
						|
 | 
						|
	url := "/cloudbroker/compute/affinityRuleAdd"
 | 
						|
 | 
						|
	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
 | 
						|
}
 |