Merge pull request #1218 from eden/master
support componentconfigs with native type aliasespull/1226/head
commit
4e032050a4
|
@ -47,44 +47,47 @@ func findNestedElement(s string, c interface{}) (reflect.Value, error) {
|
|||
|
||||
// setElement sets the supplied element to the value in the supplied string. The string will be coerced to the correct type.
|
||||
func setElement(e reflect.Value, v string) error {
|
||||
switch t := e.Interface().(type) {
|
||||
case int, int32, int64:
|
||||
switch e.Kind() {
|
||||
case reflect.Int, reflect.Int32, reflect.Int64:
|
||||
i, err := strconv.Atoi(v)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error converting input %s to an integer: %s", v, err)
|
||||
}
|
||||
e.SetInt(int64(i))
|
||||
case string:
|
||||
case reflect.String:
|
||||
e.SetString(v)
|
||||
case float32, float64:
|
||||
case reflect.Float32, reflect.Float64:
|
||||
f, err := strconv.ParseFloat(v, 64)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error converting input %s to a float: %s", v, err)
|
||||
}
|
||||
e.SetFloat(f)
|
||||
case bool:
|
||||
case reflect.Bool:
|
||||
b, err := strconv.ParseBool(v)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error converting input %s to a bool: %s", v, err)
|
||||
}
|
||||
e.SetBool(b)
|
||||
case net.IP:
|
||||
ip := net.ParseIP(v)
|
||||
if ip == nil {
|
||||
return fmt.Errorf("Error converting input %s to an IP.", v)
|
||||
}
|
||||
e.Set(reflect.ValueOf(ip))
|
||||
case utilnet.PortRange:
|
||||
pr, err := utilnet.ParsePortRange(v)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error converting input %s to PortRange: %s", v, err)
|
||||
}
|
||||
e.Set(reflect.ValueOf(*pr))
|
||||
case []string:
|
||||
vals := strings.Split(v, ",")
|
||||
e.Set(reflect.ValueOf(vals))
|
||||
default:
|
||||
return fmt.Errorf("Unable to set type %T.", t)
|
||||
switch t := e.Interface().(type) {
|
||||
case net.IP:
|
||||
ip := net.ParseIP(v)
|
||||
if ip == nil {
|
||||
return fmt.Errorf("Error converting input %s to an IP.", v)
|
||||
}
|
||||
e.Set(reflect.ValueOf(ip))
|
||||
case utilnet.PortRange:
|
||||
pr, err := utilnet.ParsePortRange(v)
|
||||
if err != nil {
|
||||
return fmt.Errorf("Error converting input %s to PortRange: %s", v, err)
|
||||
}
|
||||
e.Set(reflect.ValueOf(*pr))
|
||||
case []string:
|
||||
vals := strings.Split(v, ",")
|
||||
e.Set(reflect.ValueOf(vals))
|
||||
default:
|
||||
return fmt.Errorf("Unable to set type %T.", t)
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
|
|
@ -25,6 +25,8 @@ import (
|
|||
utilnet "k8s.io/kubernetes/pkg/util/net"
|
||||
)
|
||||
|
||||
type aliasedString string
|
||||
|
||||
type testConfig struct {
|
||||
A string
|
||||
B int
|
||||
|
@ -54,6 +56,7 @@ type subConfig3 struct {
|
|||
Q net.IP
|
||||
R utilnet.PortRange
|
||||
S []string
|
||||
T aliasedString
|
||||
}
|
||||
|
||||
func buildConfig() testConfig {
|
||||
|
@ -172,6 +175,7 @@ func TestSetElement(t *testing.T) {
|
|||
{"D.I.Q", "11.22.33.44", func(t testConfig) bool { return t.D.I.Q.Equal(net.ParseIP("11.22.33.44")) }},
|
||||
{"D.I.R", "7-11", func(t testConfig) bool { return t.D.I.R.Base == 7 && t.D.I.R.Size == 5 }},
|
||||
{"D.I.S", "a,b", func(t testConfig) bool { return reflect.DeepEqual(t.D.I.S, []string{"a", "b"}) }},
|
||||
{"D.I.T", "foo", func(t testConfig) bool { return t.D.I.T == "foo" }},
|
||||
} {
|
||||
a := buildConfig()
|
||||
if err := FindAndSet(tc.path, &a, tc.newval); err != nil {
|
||||
|
|
Loading…
Reference in New Issue