diff --git a/pkg/leakybucket/manager.go b/pkg/leakybucket/manager.go index 0fe6fd495..78d43b283 100644 --- a/pkg/leakybucket/manager.go +++ b/pkg/leakybucket/manager.go @@ -111,7 +111,10 @@ func LoadBuckets(files []string, dataFolder string) ([]BucketFactory, chan types ) var seed namegenerator.Generator = namegenerator.NewNameGenerator(time.Now().UTC().UnixNano()) - exprhelpers.Init() + err := exprhelpers.Init() + if err != nil { + return nil, nil, err + } response = make(chan types.Event, 1) for _, f := range files { @@ -280,6 +283,9 @@ func LoadBucket(g *BucketFactory, dataFolder string) error { if len(g.Data) > 0 { for _, data := range g.Data { err = exprhelpers.FileInit(dataFolder, data.DestPath) + if err != nil { + log.Errorf(err.Error()) + } } } diff --git a/pkg/parser/stage.go b/pkg/parser/stage.go index 66efecb97..ff05c90d2 100644 --- a/pkg/parser/stage.go +++ b/pkg/parser/stage.go @@ -43,7 +43,10 @@ func LoadStages(stageFiles []Stagefile, pctx *UnixParserCtx) ([]Node, error) { tmpstages := make(map[string]bool) pctx.Stages = []string{} - exprhelpers.Init() + err := exprhelpers.Init() + if err != nil { + return nil, err + } for _, stageFile := range stageFiles { if !strings.HasSuffix(stageFile.Filename, ".yaml") { log.Warningf("skip non yaml : %s", stageFile.Filename) @@ -115,6 +118,9 @@ func LoadStages(stageFiles []Stagefile, pctx *UnixParserCtx) ([]Node, error) { if len(node.Data) > 0 { for _, data := range node.Data { err = exprhelpers.FileInit(pctx.DataFolder, data.DestPath) + if err != nil { + log.Errorf(err.Error()) + } } } nodes = append(nodes, node) diff --git a/pkg/types/dataset.go b/pkg/types/dataset.go index dd3797466..fa5c55816 100644 --- a/pkg/types/dataset.go +++ b/pkg/types/dataset.go @@ -16,7 +16,7 @@ type DataSource struct { } type DataSet struct { - Data []*DataSource `yaml:"data",omitempty` + Data []*DataSource `yaml:"data,omitempty"` } func downloadFile(url string, destPath string) error {