Remove filesystem from ConfigMapGenerator and SecretGenerator

This commit is contained in:
Jingfang Liu
2019-01-16 13:33:06 -08:00
parent 2fa4a34589
commit f7c34ccb52
11 changed files with 23 additions and 32 deletions

View File

@@ -26,21 +26,18 @@ import (
"k8s.io/api/core/v1" "k8s.io/api/core/v1"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/util/validation" "k8s.io/apimachinery/pkg/util/validation"
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/ifc" "sigs.k8s.io/kustomize/pkg/ifc"
"sigs.k8s.io/kustomize/pkg/types" "sigs.k8s.io/kustomize/pkg/types"
) )
// ConfigMapFactory makes ConfigMaps. // ConfigMapFactory makes ConfigMaps.
type ConfigMapFactory struct { type ConfigMapFactory struct {
fSys fs.FileSystem ldr ifc.Loader
ldr ifc.Loader
} }
// NewConfigMapFactory returns a new ConfigMapFactory. // NewConfigMapFactory returns a new ConfigMapFactory.
func NewConfigMapFactory( func NewConfigMapFactory(l ifc.Loader) *ConfigMapFactory {
fSys fs.FileSystem, l ifc.Loader) *ConfigMapFactory { return &ConfigMapFactory{ldr: l}
return &ConfigMapFactory{fSys: fSys, ldr: l}
} }
func (f *ConfigMapFactory) makeFreshConfigMap( func (f *ConfigMapFactory) makeFreshConfigMap(

View File

@@ -131,7 +131,7 @@ func TestConstructConfigMap(t *testing.T) {
fSys := fs.MakeFakeFS() fSys := fs.MakeFakeFS()
fSys.WriteFile("/configmap/app.env", []byte("DB_USERNAME=admin\nDB_PASSWORD=somepw\n")) fSys.WriteFile("/configmap/app.env", []byte("DB_USERNAME=admin\nDB_PASSWORD=somepw\n"))
fSys.WriteFile("/configmap/app-init.ini", []byte("FOO=bar\nBAR=baz\n")) fSys.WriteFile("/configmap/app-init.ini", []byte("FOO=bar\nBAR=baz\n"))
f := NewConfigMapFactory(fSys, loader.NewFileLoaderAtRoot(fSys)) f := NewConfigMapFactory(loader.NewFileLoaderAtRoot(fSys))
for _, tc := range testCases { for _, tc := range testCases {
cm, err := f.MakeConfigMap(&tc.input, tc.options) cm, err := f.MakeConfigMap(&tc.input, tc.options)
if err != nil { if err != nil {

View File

@@ -23,20 +23,18 @@ import (
"github.com/pkg/errors" "github.com/pkg/errors"
corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
"k8s.io/apimachinery/pkg/util/validation" "k8s.io/apimachinery/pkg/util/validation"
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/ifc" "sigs.k8s.io/kustomize/pkg/ifc"
"sigs.k8s.io/kustomize/pkg/types" "sigs.k8s.io/kustomize/pkg/types"
) )
// SecretFactory makes Secrets. // SecretFactory makes Secrets.
type SecretFactory struct { type SecretFactory struct {
fSys fs.FileSystem ldr ifc.Loader
ldr ifc.Loader
} }
// NewSecretFactory returns a new SecretFactory. // NewSecretFactory returns a new SecretFactory.
func NewSecretFactory(fSys fs.FileSystem, ldr ifc.Loader) *SecretFactory { func NewSecretFactory(ldr ifc.Loader) *SecretFactory {
return &SecretFactory{fSys: fSys, ldr: ldr} return &SecretFactory{ldr: ldr}
} }
func (f *SecretFactory) makeFreshSecret(args *types.SecretArgs) *corev1.Secret { func (f *SecretFactory) makeFreshSecret(args *types.SecretArgs) *corev1.Secret {

View File

@@ -132,7 +132,7 @@ func TestConstructSecret(t *testing.T) {
fSys := fs.MakeFakeFS() fSys := fs.MakeFakeFS()
fSys.WriteFile("/secret/app.env", []byte("DB_USERNAME=admin\nDB_PASSWORD=somepw\n")) fSys.WriteFile("/secret/app.env", []byte("DB_USERNAME=admin\nDB_PASSWORD=somepw\n"))
fSys.WriteFile("/secret/app-init.ini", []byte("FOO=bar\nBAR=baz\n")) fSys.WriteFile("/secret/app-init.ini", []byte("FOO=bar\nBAR=baz\n"))
f := NewSecretFactory(fSys, loader.NewFileLoaderAtRoot(fSys)) f := NewSecretFactory(loader.NewFileLoaderAtRoot(fSys))
for _, tc := range testCases { for _, tc := range testCases {
cm, err := f.MakeSecret(&tc.input, tc.options) cm, err := f.MakeSecret(&tc.input, tc.options)
if err != nil { if err != nil {

View File

@@ -25,7 +25,6 @@ import (
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/util/yaml" "k8s.io/apimachinery/pkg/util/yaml"
"sigs.k8s.io/kustomize/k8sdeps/configmapandsecret" "sigs.k8s.io/kustomize/k8sdeps/configmapandsecret"
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/ifc" "sigs.k8s.io/kustomize/pkg/ifc"
"sigs.k8s.io/kustomize/pkg/types" "sigs.k8s.io/kustomize/pkg/types"
) )
@@ -94,10 +93,10 @@ func (kf *KunstructuredFactoryImpl) MakeSecret(args *types.SecretArgs, options *
return NewKunstructuredFromObject(sec) return NewKunstructuredFromObject(sec)
} }
// Set sets loader, filesystem and workdirectory // Set sets loader
func (kf *KunstructuredFactoryImpl) Set(fs fs.FileSystem, ldr ifc.Loader) { func (kf *KunstructuredFactoryImpl) Set(ldr ifc.Loader) {
kf.cmFactory = configmapandsecret.NewConfigMapFactory(fs, ldr) kf.cmFactory = configmapandsecret.NewConfigMapFactory(ldr)
kf.secretFactory = configmapandsecret.NewSecretFactory(fs, ldr) kf.secretFactory = configmapandsecret.NewSecretFactory(ldr)
} }
// validate validates that u has kind and name // validate validates that u has kind and name

View File

@@ -67,7 +67,7 @@ func newCmdAddConfigMap(fSys fs.FileSystem, kf ifc.KunstructuredFactory) *cobra.
} }
// Add the flagsAndArgs map to the kustomization file. // Add the flagsAndArgs map to the kustomization file.
kf.Set(fSys, loader.NewFileLoaderAtCwd(fSys)) kf.Set(loader.NewFileLoaderAtCwd(fSys))
err = addConfigMap(kustomization, flagsAndArgs, kf) err = addConfigMap(kustomization, flagsAndArgs, kf)
if err != nil { if err != nil {
return err return err

View File

@@ -18,7 +18,6 @@ limitations under the License.
package ifc package ifc
import ( import (
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/gvk" "sigs.k8s.io/kustomize/pkg/gvk"
"sigs.k8s.io/kustomize/pkg/types" "sigs.k8s.io/kustomize/pkg/types"
) )
@@ -67,7 +66,7 @@ type KunstructuredFactory interface {
FromMap(m map[string]interface{}) Kunstructured FromMap(m map[string]interface{}) Kunstructured
MakeConfigMap(args *types.ConfigMapArgs, options *types.GeneratorOptions) (Kunstructured, error) MakeConfigMap(args *types.ConfigMapArgs, options *types.GeneratorOptions) (Kunstructured, error)
MakeSecret(args *types.SecretArgs, options *types.GeneratorOptions) (Kunstructured, error) MakeSecret(args *types.SecretArgs, options *types.GeneratorOptions) (Kunstructured, error)
Set(fs fs.FileSystem, ldr Loader) Set(ldr Loader)
} }
// See core.v1.SecretTypeOpaque // See core.v1.SecretTypeOpaque

View File

@@ -20,7 +20,6 @@ import (
"fmt" "fmt"
"github.com/pkg/errors" "github.com/pkg/errors"
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/ifc" "sigs.k8s.io/kustomize/pkg/ifc"
internal "sigs.k8s.io/kustomize/pkg/internal/error" internal "sigs.k8s.io/kustomize/pkg/internal/error"
"sigs.k8s.io/kustomize/pkg/resource" "sigs.k8s.io/kustomize/pkg/resource"
@@ -106,9 +105,9 @@ func (rmF *Factory) NewResMapFromSecretArgs(argsList []types.SecretArgs, options
return newResMapFromResourceSlice(resources) return newResMapFromResourceSlice(resources)
} }
// Set sets the filesystem and loader for the underlying factory // Set sets the loader for the underlying factory
func (rmF *Factory) Set(fs fs.FileSystem, ldr ifc.Loader) { func (rmF *Factory) Set(ldr ifc.Loader) {
rmF.resF.Set(fs, ldr) rmF.resF.Set(ldr)
} }
func newResMapFromResourceSlice(resources []*resource.Resource) (ResMap, error) { func newResMapFromResourceSlice(resources []*resource.Resource) (ResMap, error) {

View File

@@ -231,7 +231,7 @@ BAR=baz
// TODO: add testcase for data coming from multiple sources like // TODO: add testcase for data coming from multiple sources like
// files/literal/env etc. // files/literal/env etc.
} }
rmF.Set(fs.MakeFakeFS(), l) rmF.Set(l)
for _, tc := range testCases { for _, tc := range testCases {
if ferr := l.AddFile(tc.filepath, []byte(tc.content)); ferr != nil { if ferr := l.AddFile(tc.filepath, []byte(tc.content)); ferr != nil {
t.Fatalf("Error adding fake file: %v\n", ferr) t.Fatalf("Error adding fake file: %v\n", ferr)
@@ -263,7 +263,7 @@ func TestNewResMapFromSecretArgs(t *testing.T) {
} }
fakeFs := fs.MakeFakeFS() fakeFs := fs.MakeFakeFS()
fakeFs.Mkdir(".") fakeFs.Mkdir(".")
rmF.Set(fakeFs, loader.NewFileLoaderAtRoot(fakeFs)) rmF.Set(loader.NewFileLoaderAtRoot(fakeFs))
actual, err := rmF.NewResMapFromSecretArgs(secrets, nil) actual, err := rmF.NewResMapFromSecretArgs(secrets, nil)
if err != nil { if err != nil {

View File

@@ -21,7 +21,6 @@ import (
"fmt" "fmt"
"log" "log"
"sigs.k8s.io/kustomize/pkg/fs"
"sigs.k8s.io/kustomize/pkg/ifc" "sigs.k8s.io/kustomize/pkg/ifc"
internal "sigs.k8s.io/kustomize/pkg/internal/error" internal "sigs.k8s.io/kustomize/pkg/internal/error"
"sigs.k8s.io/kustomize/pkg/patch" "sigs.k8s.io/kustomize/pkg/patch"
@@ -108,9 +107,9 @@ func (rf *Factory) SliceFromBytes(in []byte) ([]*Resource, error) {
return result, nil return result, nil
} }
// Set sets the filesystem and loader for the underlying factory // Set sets the loader for the underlying factory
func (rf *Factory) Set(fs fs.FileSystem, ldr ifc.Loader) { func (rf *Factory) Set(ldr ifc.Loader) {
rf.kf.Set(fs, ldr) rf.kf.Set(ldr)
} }
// MakeConfigMap makes an instance of Resource for ConfigMap // MakeConfigMap makes an instance of Resource for ConfigMap

View File

@@ -211,7 +211,7 @@ func (kt *KustTarget) accumulateTarget() (
func (kt *KustTarget) generateConfigMapsAndSecrets( func (kt *KustTarget) generateConfigMapsAndSecrets(
errs *interror.KustomizationErrors) (resmap.ResMap, error) { errs *interror.KustomizationErrors) (resmap.ResMap, error) {
kt.rFactory.Set(kt.fSys, kt.ldr) kt.rFactory.Set(kt.ldr)
cms, err := kt.rFactory.NewResMapFromConfigMapArgs( cms, err := kt.rFactory.NewResMapFromConfigMapArgs(
kt.kustomization.ConfigMapGenerator, kt.kustomization.GeneratorOptions) kt.kustomization.ConfigMapGenerator, kt.kustomization.GeneratorOptions)
if err != nil { if err != nil {