mirror of
https://github.com/kubernetes-sigs/kustomize.git
synced 2026-06-12 01:14:22 +00:00
Cut more ties to k8sdeps
This commit is contained in:
@@ -22,22 +22,9 @@ import (
|
|||||||
"unicode/utf8"
|
"unicode/utf8"
|
||||||
|
|
||||||
"k8s.io/api/core/v1"
|
"k8s.io/api/core/v1"
|
||||||
"sigs.k8s.io/kustomize/k8sdeps/kv/plugin"
|
|
||||||
"sigs.k8s.io/kustomize/pkg/ifc"
|
|
||||||
"sigs.k8s.io/kustomize/pkg/types"
|
"sigs.k8s.io/kustomize/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Factory makes ConfigMaps and Secrets.
|
|
||||||
type Factory struct {
|
|
||||||
baseFactory
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewFactory returns a new Factory.
|
|
||||||
func NewFactory(
|
|
||||||
l ifc.Loader, o *types.GeneratorOptions, reg plugin.Registry) *Factory {
|
|
||||||
return &Factory{baseFactory{ldr: l, options: o, reg: reg}}
|
|
||||||
}
|
|
||||||
|
|
||||||
func makeFreshConfigMap(
|
func makeFreshConfigMap(
|
||||||
args *types.ConfigMapArgs) *v1.ConfigMap {
|
args *types.ConfigMapArgs) *v1.ConfigMap {
|
||||||
cm := &v1.ConfigMap{}
|
cm := &v1.ConfigMap{}
|
||||||
|
|||||||
@@ -29,23 +29,29 @@ import (
|
|||||||
"sigs.k8s.io/kustomize/pkg/types"
|
"sigs.k8s.io/kustomize/pkg/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
// baseFactory holds code shared by Factory and SecretFactory.
|
// Factory makes ConfigMaps and Secrets.
|
||||||
type baseFactory struct {
|
type Factory struct {
|
||||||
ldr ifc.Loader
|
ldr ifc.Loader
|
||||||
options *types.GeneratorOptions
|
options *types.GeneratorOptions
|
||||||
reg plugin.Registry
|
reg plugin.Registry
|
||||||
}
|
}
|
||||||
|
|
||||||
func (bf baseFactory) loadKvPairs(
|
// NewFactory returns a new Factory.
|
||||||
|
func NewFactory(
|
||||||
|
l ifc.Loader, o *types.GeneratorOptions, reg plugin.Registry) *Factory {
|
||||||
|
return &Factory{ldr: l, options: o, reg: reg}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (f *Factory) loadKvPairs(
|
||||||
args types.GeneratorArgs) (all []kv.Pair, err error) {
|
args types.GeneratorArgs) (all []kv.Pair, err error) {
|
||||||
pairs, err := bf.keyValuesFromPlugins(args.KVSources)
|
pairs, err := f.keyValuesFromPlugins(args.KVSources)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, fmt.Sprintf(
|
return nil, errors.Wrap(err, fmt.Sprintf(
|
||||||
"plugins: %s",
|
"plugins: %s",
|
||||||
args.KVSources))
|
args.KVSources))
|
||||||
}
|
}
|
||||||
all = append(all, pairs...)
|
all = append(all, pairs...)
|
||||||
pairs, err = bf.keyValuesFromEnvFiles(args.EnvSources)
|
pairs, err = f.keyValuesFromEnvFiles(args.EnvSources)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, fmt.Sprintf(
|
return nil, errors.Wrap(err, fmt.Sprintf(
|
||||||
"env source files: %v",
|
"env source files: %v",
|
||||||
@@ -60,7 +66,7 @@ func (bf baseFactory) loadKvPairs(
|
|||||||
}
|
}
|
||||||
all = append(all, pairs...)
|
all = append(all, pairs...)
|
||||||
|
|
||||||
pairs, err = bf.keyValuesFromFileSources(args.FileSources)
|
pairs, err = f.keyValuesFromFileSources(args.FileSources)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, errors.Wrap(err, fmt.Sprintf(
|
return nil, errors.Wrap(err, fmt.Sprintf(
|
||||||
"file sources: %v", args.FileSources))
|
"file sources: %v", args.FileSources))
|
||||||
@@ -90,14 +96,14 @@ func keyValuesFromLiteralSources(sources []string) ([]kv.Pair, error) {
|
|||||||
return kvs, nil
|
return kvs, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (bf baseFactory) keyValuesFromPlugins(sources []types.KVSource) ([]kv.Pair, error) {
|
func (f *Factory) keyValuesFromPlugins(sources []types.KVSource) ([]kv.Pair, error) {
|
||||||
var result []kv.Pair
|
var result []kv.Pair
|
||||||
for _, s := range sources {
|
for _, s := range sources {
|
||||||
plug, err := bf.reg.Load(s.PluginType, s.Name)
|
plug, err := f.reg.Load(s.PluginType, s.Name)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
kvs, err := plug.Get(bf.reg.Root(), s.Args)
|
kvs, err := plug.Get(f.reg.Root(), s.Args)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@@ -119,14 +125,14 @@ func sortedKeys(m map[string]string) []string {
|
|||||||
return keys
|
return keys
|
||||||
}
|
}
|
||||||
|
|
||||||
func (bf baseFactory) keyValuesFromFileSources(sources []string) ([]kv.Pair, error) {
|
func (f *Factory) keyValuesFromFileSources(sources []string) ([]kv.Pair, error) {
|
||||||
var kvs []kv.Pair
|
var kvs []kv.Pair
|
||||||
for _, s := range sources {
|
for _, s := range sources {
|
||||||
k, fPath, err := kv.ParseFileSource(s)
|
k, fPath, err := kv.ParseFileSource(s)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
content, err := bf.ldr.Load(fPath)
|
content, err := f.ldr.Load(fPath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@@ -135,10 +141,10 @@ func (bf baseFactory) keyValuesFromFileSources(sources []string) ([]kv.Pair, err
|
|||||||
return kvs, nil
|
return kvs, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (bf baseFactory) keyValuesFromEnvFiles(paths []string) ([]kv.Pair, error) {
|
func (f *Factory) keyValuesFromEnvFiles(paths []string) ([]kv.Pair, error) {
|
||||||
var kvs []kv.Pair
|
var kvs []kv.Pair
|
||||||
for _, path := range paths {
|
for _, path := range paths {
|
||||||
content, err := bf.ldr.Load(path)
|
content, err := f.ldr.Load(path)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@@ -49,7 +49,7 @@ func TestKeyValuesFromFileSources(t *testing.T) {
|
|||||||
fSys.WriteFile("/files/app-init.ini", []byte("FOO=bar"))
|
fSys.WriteFile("/files/app-init.ini", []byte("FOO=bar"))
|
||||||
ldr := loader.NewFileLoaderAtRoot(fSys)
|
ldr := loader.NewFileLoaderAtRoot(fSys)
|
||||||
reg := plugin.NewRegistry(ldr)
|
reg := plugin.NewRegistry(ldr)
|
||||||
bf := baseFactory{loader.NewFileLoaderAtRoot(fSys), nil, reg}
|
bf := NewFactory(loader.NewFileLoaderAtRoot(fSys), nil, reg)
|
||||||
for _, tc := range tests {
|
for _, tc := range tests {
|
||||||
kvs, err := bf.keyValuesFromFileSources(tc.sources)
|
kvs, err := bf.keyValuesFromFileSources(tc.sources)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -125,7 +125,7 @@ func TestKeyValuesFromPlugins(t *testing.T) {
|
|||||||
fSys.WriteFile("/files/app-init.ini", []byte("FOO=bar"))
|
fSys.WriteFile("/files/app-init.ini", []byte("FOO=bar"))
|
||||||
ldr := loader.NewFileLoaderAtRoot(fSys)
|
ldr := loader.NewFileLoaderAtRoot(fSys)
|
||||||
reg := plugin.NewRegistry(ldr)
|
reg := plugin.NewRegistry(ldr)
|
||||||
bf := baseFactory{ldr, nil, reg}
|
bf := NewFactory(ldr, nil, reg)
|
||||||
|
|
||||||
for _, tc := range tests {
|
for _, tc := range tests {
|
||||||
kvs, err := bf.keyValuesFromPlugins(tc.sources)
|
kvs, err := bf.keyValuesFromPlugins(tc.sources)
|
||||||
Reference in New Issue
Block a user