Skip to content

Commit

Permalink
Merge branch 'master' into bugfix/OM-86907
Browse files Browse the repository at this point in the history
  • Loading branch information
ading1977 committed Jun 30, 2022
2 parents d67a87f + 5e8ddac commit 2d6a43a
Show file tree
Hide file tree
Showing 17 changed files with 1,103 additions and 990 deletions.
2 changes: 1 addition & 1 deletion pkg/builder/group/group_builder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ func TestGroupBuilderDynamic(t *testing.T) {

groupBuilder := DynamicRegularGroup(id).
OfType(eType).
MatchingEntities(SelectedBy(selectionSpec).and(selectionSpec2))
MatchingEntities(SelectedBy(selectionSpec).And(selectionSpec2))

groupDTO, err := groupBuilder.Build()
assert.Nil(t, err)
Expand Down
4 changes: 2 additions & 2 deletions pkg/builder/group/policy_builder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -294,7 +294,7 @@ func TestPlaceTogetherPolicy(t *testing.T) {
SetProperty("3333-")

placeTogetherPolicyBuilder := PlaceTogether(id).
WithBuyers(DynamicBuyers(SelectedBy(selectionSpec1).and(selectionSpec2)).OfType(eType)).
WithBuyers(DynamicBuyers(SelectedBy(selectionSpec1).And(selectionSpec2)).OfType(eType)).
OnSellerType(proto.EntityDTO_CONTAINER_POD)

groupDTOList, _ := assertPlaceTogetherPolicyConditions(t, placeTogetherPolicyBuilder)
Expand All @@ -304,7 +304,7 @@ func TestPlaceTogetherPolicy(t *testing.T) {

// Invalid buyer group
placeTogetherPolicyBuilder = PlaceTogether(id).
WithBuyers(DynamicBuyers(SelectedBy(selectionSpec1).and(selectionSpec2)))
WithBuyers(DynamicBuyers(SelectedBy(selectionSpec1).And(selectionSpec2)))

isValidBuyerData := assertValidBuyerData(t, placeTogetherPolicyBuilder.buyerData)
assert.Equal(t, false, isValidBuyerData)
Expand Down
2 changes: 1 addition & 1 deletion pkg/builder/group/selection_builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ func SelectedBy(entitySpec SelectionSpecBuilder) *Matching {
}
return matching
}
func (matching *Matching) and(entitySpec SelectionSpecBuilder) *Matching {
func (matching *Matching) And(entitySpec SelectionSpecBuilder) *Matching {
matching.selectionSpecBuilderList = append(matching.selectionSpecBuilderList, entitySpec)
return matching
}
Expand Down
77 changes: 77 additions & 0 deletions pkg/builder/group/settings_policy_builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,3 +82,80 @@ func NewResizeAutomationPolicySetting(actionCapability string) *proto.GroupDTO_S
},
}
}

func NewHorizontalScaleUpAutomationPolicySetting(actionMode string) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_HORIZONTAL_SCALE_UP_AUTOMATION_MODE.Enum(),
SettingValueType: &proto.GroupDTO_Setting_StringSettingValueType_{
StringSettingValueType: &proto.GroupDTO_Setting_StringSettingValueType{
Value: &actionMode,
},
},
}
}

func NewHorizontalScaleDownAutomationPolicySetting(actionMode string) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_HORIZONTAL_SCALE_DOWN_AUTOMATION_MODE.Enum(),
SettingValueType: &proto.GroupDTO_Setting_StringSettingValueType_{
StringSettingValueType: &proto.GroupDTO_Setting_StringSettingValueType{
Value: &actionMode,
},
},
}
}

func NewMoveAutomationPolicySetting(actionMode string) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_MOVE_AUTOMATION_MODE.Enum(),
SettingValueType: &proto.GroupDTO_Setting_StringSettingValueType_{
StringSettingValueType: &proto.GroupDTO_Setting_StringSettingValueType{
Value: &actionMode,
},
},
}
}

func NewMinReplicasPolicySetting(minReplicas float32) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_MIN_REPLICAS.Enum(),
SettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType_{
NumericSettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType{
Value: &minReplicas,
},
},
}
}

func NewMaxReplicasPolicySetting(maxReplicas float32) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_MAX_REPLICAS.Enum(),
SettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType_{
NumericSettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType{
Value: &maxReplicas,
},
},
}
}

func NewResponseTimeSLOPolicySetting(responseTimeSLO float32) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_RESPONSE_TIME_SLO.Enum(),
SettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType_{
NumericSettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType{
Value: &responseTimeSLO,
},
},
}
}

func NewTransactionSLOPolicySetting(transactionSLO float32) *proto.GroupDTO_Setting {
return &proto.GroupDTO_Setting{
Type: proto.GroupDTO_Setting_TRANSACTION_SLO.Enum(),
SettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType_{
NumericSettingValueType: &proto.GroupDTO_Setting_NumericSettingValueType{
Value: &transactionSLO,
},
},
}
}
2 changes: 1 addition & 1 deletion pkg/proto/ActionExecution.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion pkg/proto/CloudCostDTO.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion pkg/proto/CommonCost.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 2d6a43a

Please sign in to comment.