check if journald directory exists (#379)

observIQ · Aug 16, 2021 · 69d0199 · 69d0199
1 parent 7f94b79
commit 69d0199
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/operator/builtin/input/journald/journald.go b/operator/builtin/input/journald/journald.go
@@ -8,6 +8,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"os"
 	"os/exec"
 	"strconv"
 	"sync"
@@ -68,6 +69,9 @@ func (c JournaldInputConfig) Build(buildContext operator.BuildContext) ([]operat
 
 	switch {
 	case c.Directory != nil:
+		if _, err := os.Stat(*c.Directory); os.IsNotExist(err) {
+			return nil, fmt.Errorf("invalid value '%s' for parameter 'directory', directory does not exist: %s", *c.Directory, err)
+		}
 		args = append(args, "--directory", *c.Directory)
 	case len(c.Files) > 0:
 		for _, file := range c.Files {