mirror of
https://github.com/rancher/types.git
synced 2025-09-16 23:08:25 +00:00
Updates for norman refactoring
This commit is contained in:
@@ -3,41 +3,41 @@ package mapper
|
||||
import (
|
||||
"github.com/rancher/norman/types"
|
||||
"github.com/rancher/norman/types/convert"
|
||||
m "github.com/rancher/norman/types/mapper"
|
||||
"github.com/rancher/norman/types/values"
|
||||
)
|
||||
|
||||
type DeploymentStrategyMapper struct {
|
||||
}
|
||||
|
||||
func (d DeploymentStrategyMapper) FromInternal(data map[string]interface{}) {
|
||||
if m.GetValueN(data, "strategy", "type") != "Recreate" {
|
||||
m.PutValue(data, "Parallel", "deploymentStrategy", "kind")
|
||||
maxUnavailable := m.GetValueN(data, "strategy", "rollingUpdate", "maxUnavailable")
|
||||
maxSurge := m.GetValueN(data, "strategy", "rollingUpdate", "maxSurge")
|
||||
if values.GetValueN(data, "strategy", "type") != "Recreate" {
|
||||
values.PutValue(data, "Parallel", "deploymentStrategy", "kind")
|
||||
maxUnavailable := values.GetValueN(data, "strategy", "rollingUpdate", "maxUnavailable")
|
||||
maxSurge := values.GetValueN(data, "strategy", "rollingUpdate", "maxSurge")
|
||||
if !convert.IsEmpty(maxSurge) {
|
||||
m.PutValue(data, true, "deploymentStrategy", "parallelConfig", "startFirst")
|
||||
m.PutValue(data, convert.ToString(maxSurge), "batchSize")
|
||||
values.PutValue(data, true, "deploymentStrategy", "parallelConfig", "startFirst")
|
||||
values.PutValue(data, convert.ToString(maxSurge), "batchSize")
|
||||
} else if !convert.IsEmpty(maxUnavailable) {
|
||||
m.PutValue(data, convert.ToString(maxUnavailable), "batchSize")
|
||||
values.PutValue(data, convert.ToString(maxUnavailable), "batchSize")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func (d DeploymentStrategyMapper) ToInternal(data map[string]interface{}) {
|
||||
batchSize := m.GetValueN(data, "batchSize")
|
||||
batchSize := values.GetValueN(data, "batchSize")
|
||||
if convert.IsEmpty(batchSize) {
|
||||
batchSize = 1
|
||||
}
|
||||
|
||||
batchSize, _ = convert.ToNumber(batchSize)
|
||||
|
||||
kind, _ := m.GetValueN(data, "deploymentStrategy", "kind").(string)
|
||||
kind, _ := values.GetValueN(data, "deploymentStrategy", "kind").(string)
|
||||
if kind == "" || kind == "Parallel" {
|
||||
startFirst, _ := m.GetValueN(data, "deploymentStrategy", "startFirst").(bool)
|
||||
startFirst, _ := values.GetValueN(data, "deploymentStrategy", "startFirst").(bool)
|
||||
if startFirst {
|
||||
m.PutValue(data, batchSize, "strategy", "rollingUpdate", "maxSurge")
|
||||
values.PutValue(data, batchSize, "strategy", "rollingUpdate", "maxSurge")
|
||||
} else {
|
||||
m.PutValue(data, batchSize, "strategy", "rollingUpdate", "maxUnavailable")
|
||||
values.PutValue(data, batchSize, "strategy", "rollingUpdate", "maxUnavailable")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user