unit and priority config

operator/builtin/input/journald/journald.go

@@ -44,6 +44,7 @@ func NewJournaldInputConfig(operatorID string) *JournaldInputConfig {
 	return &JournaldInputConfig{
 		InputConfig: helper.NewInputConfig(operatorID, "journald_input"),
 		StartAt:     "end",
+		Priority:  	 "info",
 	}
 }
 
@@ -54,6 +55,8 @@ 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"`
+	Priority  string   `mapstructure:"priority,omitempty"  json:"priority,omitempty"  yaml:"priority,omitempty"`
 }
 
 // Build will build a journald input operator from the supplied configuration
@@ -82,6 +85,12 @@ func (c JournaldInputConfig) Build(buildContext operator.BuildContext) ([]operat
 		return nil, fmt.Errorf("invalid value '%s' for parameter 'start_at'", c.StartAt)
 	}
 
+	for _, unit := range c.Units {
+		args = append(args, "--unit=", unit)
+	}
+
+	args = append(args, "--priority", c.Priority)
+
 	switch {
 	case c.Directory != nil:
 		args = append(args, "--directory", *c.Directory)