Merge pull request #49 from monopole/removeAnotherUtil

Remove util and privatize selectByGvk
This commit is contained in:
Jeff Regan
2018-06-01 14:20:29 -07:00
committed by GitHub
8 changed files with 11 additions and 15 deletions

View File

@@ -21,7 +21,6 @@ import (
"fmt"
"github.com/kubernetes-sigs/kustomize/pkg/resmap"
"github.com/kubernetes-sigs/kustomize/pkg/types"
)
// mapTransformer contains a map string->string and path configs
@@ -61,7 +60,7 @@ func (o *mapTransformer) Transform(m resmap.ResMap) error {
obj := m[id].Unstruct()
objMap := obj.UnstructuredContent()
for _, path := range o.pathConfigs {
if !types.SelectByGVK(id.Gvk(), path.GroupVersionKind) {
if !selectByGVK(id.Gvk(), path.GroupVersionKind) {
continue
}
err := mutateField(objMap, path.Path, path.CreateIfNotPresent, o.addMap)

View File

@@ -22,7 +22,6 @@ import (
"github.com/kubernetes-sigs/kustomize/pkg/hash"
"github.com/kubernetes-sigs/kustomize/pkg/resmap"
"github.com/kubernetes-sigs/kustomize/pkg/types"
"k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime/schema"
@@ -43,10 +42,10 @@ func NewNameHashTransformer() Transformer {
func (o *nameHashTransformer) Transform(m resmap.ResMap) error {
for id, obj := range m {
switch {
case types.SelectByGVK(id.Gvk(), &schema.GroupVersionKind{Version: "v1", Kind: "ConfigMap"}):
case selectByGVK(id.Gvk(), &schema.GroupVersionKind{Version: "v1", Kind: "ConfigMap"}):
appendHashForConfigMap(obj.Unstruct())
case types.SelectByGVK(id.Gvk(), &schema.GroupVersionKind{Version: "v1", Kind: "Secret"}):
case selectByGVK(id.Gvk(), &schema.GroupVersionKind{Version: "v1", Kind: "Secret"}):
appendHashForSecret(obj.Unstruct())
}
}

View File

@@ -21,7 +21,6 @@ import (
"fmt"
"github.com/kubernetes-sigs/kustomize/pkg/resmap"
"github.com/kubernetes-sigs/kustomize/pkg/types"
"k8s.io/apimachinery/pkg/runtime/schema"
)
@@ -57,7 +56,7 @@ func (o *nameReferenceTransformer) Transform(
objMap := obj.UnstructuredContent()
for _, referencePathConfig := range o.pathConfigs {
for _, path := range referencePathConfig.pathConfigs {
if !types.SelectByGVK(id.Gvk(), path.GroupVersionKind) {
if !selectByGVK(id.Gvk(), path.GroupVersionKind) {
continue
}
err := mutateField(objMap, path.Path, path.CreateIfNotPresent,
@@ -82,7 +81,7 @@ func (o *nameReferenceTransformer) updateNameReference(
}
for id, obj := range m {
if !types.SelectByGVK(id.Gvk(), &GVK) {
if !selectByGVK(id.Gvk(), &GVK) {
continue
}
if id.Name() == s {

View File

@@ -21,7 +21,6 @@ import (
"fmt"
"github.com/kubernetes-sigs/kustomize/pkg/resmap"
"github.com/kubernetes-sigs/kustomize/pkg/types"
)
// namePrefixTransformer contains the prefix and the path config for each field that
@@ -62,7 +61,7 @@ func (o *namePrefixTransformer) Transform(m resmap.ResMap) error {
obj := m[id].Unstruct()
objMap := obj.UnstructuredContent()
for _, path := range o.pathConfigs {
if !types.SelectByGVK(id.Gvk(), path.GroupVersionKind) {
if !selectByGVK(id.Gvk(), path.GroupVersionKind) {
continue
}
err := mutateField(objMap, path.Path, path.CreateIfNotPresent, o.addPrefix)

View File

@@ -14,20 +14,20 @@ See the License for the specific language governing permissions and
limitations under the License.
*/
package types
package transformers
import (
"k8s.io/apimachinery/pkg/runtime/schema"
)
// SelectByGVK returns true if `selector` selects `in`; otherwise, false.
// selectByGVK returns true if `selector` selects `in`; otherwise, false.
// If `selector` and `in` are the same, return true.
// If `selector` is nil, it is considered as a wildcard and always return true.
// e.g. selector <Group: "", Version: "", Kind: "Deployment"> CAN select
// <Group: "extensions", Version: "v1beta1", Kind: "Deployment">.
// selector <Group: "apps", Version: "", Kind: "Deployment"> CANNOT select
// <Group: "extensions", Version: "v1beta1", Kind: "Deployment">.
func SelectByGVK(in schema.GroupVersionKind, selector *schema.GroupVersionKind) bool {
func selectByGVK(in schema.GroupVersionKind, selector *schema.GroupVersionKind) bool {
if selector == nil {
return true
}

View File

@@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
limitations under the License.
*/
package types
package transformers
import (
"testing"
@@ -123,7 +123,7 @@ func TestSelectByGVK(t *testing.T) {
}
for _, tc := range testCases {
filtered := SelectByGVK(tc.in, tc.filter)
filtered := selectByGVK(tc.in, tc.filter)
if filtered != tc.expected {
t.Fatalf("unexpected filter result for test case: %v", tc.description)
}