clean up

open-telemetry · Aug 27, 2021 · f296a3f · f296a3f
1 parent c12d0c2
commit f296a3f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/operator/builtin/input/journald/journald.go b/operator/builtin/input/journald/journald.go
@@ -44,7 +44,7 @@ func NewJournaldInputConfig(operatorID string) *JournaldInputConfig {
 	return &JournaldInputConfig{
 		InputConfig: helper.NewInputConfig(operatorID, "journald_input"),
 		StartAt:     "end",
-		Priority:  	 "info",
+		Priority:    "info",
 	}
 }
 
@@ -55,7 +55,7 @@ type JournaldInputConfig struct {
 	Directory *string  `mapstructure:"directory,omitempty" json:"directory,omitempty" yaml:"directory,omitempty"`
 	Files     []string `mapstructure:"files,omitempty"     json:"files,omitempty"     yaml:"files,omitempty"`
 	StartAt   string   `mapstructure:"start_at,omitempty"  json:"start_at,omitempty"  yaml:"start_at,omitempty"`
-	Units	  []string `mapstructure:"units,omitempty"     json:"units,omitempty"     yaml:"units,omitempty"`
+	Units     []string `mapstructure:"units,omitempty"     json:"units,omitempty"     yaml:"units,omitempty"`
 	Priority  string   `mapstructure:"priority,omitempty"  json:"priority,omitempty"  yaml:"priority,omitempty"`
 }
 
@@ -86,7 +86,7 @@ func (c JournaldInputConfig) Build(buildContext operator.BuildContext) ([]operat
 	}
 
 	for _, unit := range c.Units {
-		args = append(args, "--unit=", unit)
+		args = append(args, "--unit", unit)
 	}
 
 	args = append(args, "--priority", c.Priority)

diff --git a/operator/builtin/input/journald/journald_test.go b/operator/builtin/input/journald/journald_test.go
@@ -124,6 +124,7 @@ func TestJournaldInputConfig(t *testing.T) {
 	input := map[string]interface{}{
 		"id":         "my_journald_input",
 		"type":       "journald_input",
+		"priority":   "info",
 		"start_at":   "end",
 		"write_to":   "$body.to",
 		"attributes": map[string]interface{}{},