Simplify some code and add TODOs.

This commit is contained in:
Jeffrey Regan
2018-10-30 17:31:28 -07:00
parent af1e1e6942
commit d04877a9e7
5 changed files with 25 additions and 42 deletions

View File

@@ -20,7 +20,6 @@ import (
"fmt" "fmt"
"sigs.k8s.io/kustomize/pkg/resmap" "sigs.k8s.io/kustomize/pkg/resmap"
"sigs.k8s.io/kustomize/pkg/resource"
"sigs.k8s.io/kustomize/pkg/transformers" "sigs.k8s.io/kustomize/pkg/transformers"
) )
@@ -33,25 +32,16 @@ func NewNameHashTransformer() transformers.Transformer {
return &nameHashTransformer{} return &nameHashTransformer{}
} }
// Transform appends hash to configmaps and secrets. // Transform appends hash to generated resources.
func (o *nameHashTransformer) Transform(m resmap.ResMap) error { func (o *nameHashTransformer) Transform(m resmap.ResMap) error {
for _, res := range m { for _, res := range m {
if res.IsGenerated() { if res.IsGenerated() {
err := o.appendHash(res) h, err := NewKustHash().Hash(res.Map())
if err != nil { if err != nil {
return err return err
} }
res.SetName(fmt.Sprintf("%s-%s", res.GetName(), h))
} }
} }
return nil return nil
} }
func (o *nameHashTransformer) appendHash(res *resource.Resource) error {
h, err := NewKustHash().Hash(res.Map())
if err != nil {
return err
}
nameWithHash := fmt.Sprintf("%s-%s", res.GetName(), h)
res.SetName(nameWithHash)
return nil
}

View File

@@ -1,4 +1,4 @@
description: multibases with name reference description: multibases with name reference
args: [] args: []
filename: testdata/testcase-multibases-conflict/combined filename: testdata/testcase-multibases-conflict/combined
expectedError: detected conflicts when resolving name references serviceaccount expectedError: Multiple matches for name noGroup_v1_ServiceAccount

View File

@@ -82,7 +82,6 @@ func unmarshal(y []byte, o interface{}) error {
if err != nil { if err != nil {
return err return err
} }
dec := json.NewDecoder(bytes.NewReader(j)) dec := json.NewDecoder(bytes.NewReader(j))
dec.DisallowUnknownFields() dec.DisallowUnknownFields()
return dec.Decode(o) return dec.Decode(o)
@@ -111,7 +110,6 @@ func (kt *KustTarget) resolveRefsToGeneratedResources(m resmap.ResMap) (resmap.R
return nil, err return nil, err
} }
} }
var r []transformers.Transformer var r []transformers.Transformer
t, err := transformers.NewNameReferenceTransformer(kt.tConfig.NameReference) t, err := transformers.NewNameReferenceTransformer(kt.tConfig.NameReference)
if err != nil { if err != nil {
@@ -159,7 +157,6 @@ func (kt *KustTarget) loadCustomizedResMap() (resmap.ResMap, error) {
if err != nil { if err != nil {
errs.Append(errors.Wrap(err, "SliceFromPatches")) errs.Append(errors.Wrap(err, "SliceFromPatches"))
} }
if len(errs.Get()) > 0 { if len(errs.Get()) > 0 {
return nil, errs return nil, errs
} }

View File

@@ -21,7 +21,6 @@ import (
"fmt" "fmt"
"sigs.k8s.io/kustomize/pkg/gvk" "sigs.k8s.io/kustomize/pkg/gvk"
"sigs.k8s.io/kustomize/pkg/resid"
"sigs.k8s.io/kustomize/pkg/resmap" "sigs.k8s.io/kustomize/pkg/resmap"
"sigs.k8s.io/kustomize/pkg/transformers/config" "sigs.k8s.io/kustomize/pkg/transformers/config"
) )
@@ -47,17 +46,21 @@ func NewNameReferenceTransformer(
// associated with the key. e.g. if <k, v> is one of the key-value pair in the map, // associated with the key. e.g. if <k, v> is one of the key-value pair in the map,
// then the old name is k.Name and the new name is v.GetName() // then the old name is k.Name and the new name is v.GetName()
func (o *nameReferenceTransformer) Transform(m resmap.ResMap) error { func (o *nameReferenceTransformer) Transform(m resmap.ResMap) error {
// TODO: Too much looping.
// Even more hidden loops in FilterBy,
// updateNameReference and FindByGVKN.
for id := range m { for id := range m {
objMap := m[id].Map()
for _, backRef := range o.backRefs { for _, backRef := range o.backRefs {
for _, fSpec := range backRef.FieldSpecs { for _, fSpec := range backRef.FieldSpecs {
if !id.Gvk().IsSelected(&fSpec.Gvk) { if id.Gvk().IsSelected(&fSpec.Gvk) {
continue err := mutateField(
} m[id].Map(), fSpec.PathSlice(),
err := mutateField(objMap, fSpec.PathSlice(), fSpec.CreateIfNotPresent, fSpec.CreateIfNotPresent,
o.updateNameReference(backRef.Gvk, m.FilterBy(id))) o.updateNameReference(
if err != nil { backRef.Gvk, m.FilterBy(id)))
return err if err != nil {
return err
}
} }
} }
} }
@@ -72,27 +75,20 @@ func (o *nameReferenceTransformer) updateNameReference(
if !ok { if !ok {
return nil, fmt.Errorf("%#v is expectd to be %T", in, s) return nil, fmt.Errorf("%#v is expectd to be %T", in, s)
} }
for id, res := range m { for id, res := range m {
if !id.Gvk().IsSelected(&backRef) { if id.Gvk().IsSelected(&backRef) && id.Name() == s {
continue matchedIds := m.FindByGVKN(id)
} // If there's more than one match, there's no way
if id.Name() == s { // to know which one to pick, so emit error.
err := o.detectConflict(id, m, s) if len(matchedIds) > 1 {
if err != nil { return nil, fmt.Errorf(
return nil, err "Multiple matches for name %s:\n %v", id, matchedIds)
} }
// Return transformed name of the object,
// complete with prefixes, hashes, etc.
return res.GetName(), nil return res.GetName(), nil
} }
} }
return in, nil return in, nil
} }
} }
func (o *nameReferenceTransformer) detectConflict(id resid.ResId, m resmap.ResMap, name string) error {
matchedIds := m.FindByGVKN(id)
if len(matchedIds) > 1 {
return fmt.Errorf("detected conflicts when resolving name references %s:\n%v", name, matchedIds)
}
return nil
}