Fix the input plugin.

Signed-off-by: Josh Baird <[email protected]>
fluent · Oct 30, 2023 · d0b1c32 · d0b1c32
1 parent 84062c0
commit d0b1c32
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/apis/fluentd/v1alpha1/plugins/input/types.go b/apis/fluentd/v1alpha1/plugins/input/types.go
@@ -32,7 +32,7 @@ type Input struct {
 	// in_sample plugin
 	Sample *Sample `json:"sample,omitempty"`
 	// monitor_agent plugin
-	MonitorAgent *MonitorAgent `json:"monitorAgent,omitempty"`
+	MonitorAgent *MonitorAgent `json:"monitor_agent,omitempty"`
 }
 
 // DeepCopyInto implements the DeepCopyInto interface.
@@ -89,6 +89,7 @@ func (i *Input) Params(loader plugins.SecretLoader) (*params.PluginStore, error)
 
 	if i.MonitorAgent != nil {
 		ps.InsertType(string(params.MonitorAgentType))
+		return i.monitorAgentPlugin(ps, loader), nil
 	}
 
 	return nil, errors.New("you must define an input plugin")

diff --git a/apis/fluentd/v1alpha1/tests/__debug_bin3692928812 b/apis/fluentd/v1alpha1/tests/__debug_bin3692928812