Remove deprecated decoder things

* loader interface,
* needless FileInfo.
This commit is contained in:
Tomaž Jerman
2020-11-27 11:19:15 +01:00
parent 8b6b322c1b
commit 7ca422bdd3
4 changed files with 14 additions and 26 deletions
+3 -3
View File
@@ -13,7 +13,7 @@ import (
type (
decoder interface {
CanDecodeFile(os.FileInfo) bool
Decode(context.Context, io.Reader, os.FileInfo) ([]resource.Interface, error)
Decode(context.Context, io.Reader) ([]resource.Interface, error)
}
)
@@ -61,8 +61,8 @@ func Decode(ctx context.Context, path string, decoders ...decoder) ([]resource.I
}
defer f.Close()
if dnn, err = d.Decode(ctx, f, info); err != nil {
return err
if dnn, err = d.Decode(ctx, f); err != nil {
return fmt.Errorf("failed to decode %s: %w", info.Name(), err)
}
nn = append(nn, dnn...)
+7 -14
View File
@@ -2,7 +2,6 @@ package yaml
import (
"context"
"fmt"
"io"
"os"
"path/filepath"
@@ -14,25 +13,19 @@ import (
type (
// decoder is a wrapper struct for yaml related methods
decoder struct {
loader loader
}
loader interface {
LoadComposeNamespace()
}
decoder struct{}
EnvoyMarshler interface {
MarshalEnvoy() ([]resource.Interface, error)
}
nodeDecoder interface {
DecodeNodes(ctx context.Context, l loader) ([]resource.Interface, error)
DecodeNodes(ctx context.Context) ([]resource.Interface, error)
}
)
func Decoder(l loader) *decoder {
return &decoder{l}
func Decoder() *decoder {
return &decoder{}
}
// CanDecodeFile
@@ -45,14 +38,14 @@ func (y *decoder) CanDecodeFile(i os.FileInfo) bool {
return false
}
func (y *decoder) Decode(ctx context.Context, r io.Reader, i os.FileInfo) ([]resource.Interface, error) {
func (y *decoder) Decode(ctx context.Context, r io.Reader) ([]resource.Interface, error) {
var (
doc = &Document{}
)
if err := yaml.NewDecoder(r).Decode(doc); err != nil {
return nil, fmt.Errorf("failed to decode %s: %w", i.Name(), err)
return nil, err
}
return doc.Decode(ctx, y.loader)
return doc.Decode(ctx)
}
+1 -1
View File
@@ -50,7 +50,7 @@ func (doc *Document) UnmarshalYAML(n *yaml.Node) (err error) {
}
//
func (doc *Document) Decode(ctx context.Context, l loader) ([]resource.Interface, error) {
func (doc *Document) Decode(ctx context.Context) ([]resource.Interface, error) {
nn := make([]resource.Interface, 0, 100)
mm := make([]envoy.Marshaller, 0, 20)
+3 -8
View File
@@ -56,18 +56,13 @@ func yd(ctx context.Context, suite, fname string) ([]resource.Interface, error)
}
defer f.Close()
info, err := os.Stat(fp)
if err != nil {
return nil, err
}
d := yaml.Decoder(nil)
return d.Decode(ctx, f, info)
d := yaml.Decoder()
return d.Decode(ctx, f)
}
func dd(ctx context.Context, suite string) ([]resource.Interface, error) {
fp := path.Join("testdata", suite)
d := yaml.Decoder(nil)
d := yaml.Decoder()
return directory.Decode(ctx, fp, d)
}