add null plugin

Signed-off-by: Chengwei Guo <[email protected]>

Author: cw-Guo

apis/fluentd/v1alpha1/plugins/output/null.go

@@ -0,0 +1,7 @@
+package output
+
+// Null defines the parameters for out_null output plugin
+type Null struct {
+	// NeverFlush for testing to simulate the output plugin that never succeeds to flush.
+	NeverFlush *bool `json:"neverFlush,omitempty"`
+}

apis/fluentd/v1alpha1/plugins/output/types.go

@@ -54,6 +54,8 @@ type Output struct {
 	Datadog *Datadog `json:"datadog,omitempty"`
 	// copy plugin
 	Copy *Copy `json:"copy,omitempty"`
+	// null plugin
+	Null *Null `json:"nullPlugin,omitempty"`
 }
 
 // DeepCopyInto implements the DeepCopyInto interface.
@@ -177,6 +179,11 @@ func (o *Output) Params(loader plugins.SecretLoader) (*params.PluginStore, error
 		return o.copyPlugin(ps, loader), nil
 	}
 
+	if o.Null != nil {
+		ps.InsertType(string(params.NullOutputType))
+		return o.nullPlugin(ps, loader), nil
+	}
+
 	return o.customOutput(ps, loader), nil
 
 }
@@ -1074,4 +1081,11 @@ func (o *Output) copyPlugin(parent *params.PluginStore, sl plugins.SecretLoader)
 	return parent
 }
 
+func (o *Output) nullPlugin(parent *params.PluginStore, sl plugins.SecretLoader) *params.PluginStore {
+	if o.Null.NeverFlush != nil {
+		parent.InsertPairs("never_flush", fmt.Sprint(*o.Null.NeverFlush))
+	}
+	return parent
+}
+
 var _ plugins.Plugin = &Output{}

apis/fluentd/v1alpha1/plugins/params/const.go

@@ -73,6 +73,7 @@ const (
 	CloudWatchOutputType              OutputType = "cloudwatch_logs"
 	DatadogOutputType                 OutputType = "datadog"
 	CopyOutputType                    OutputType = "copy"
+	NullOutputType                    OutputType = "null"
 )
 
 var (

charts/fluent-operator/charts/fluentd-crds/crds/fluentd.fluent.io_clusteroutputs.yaml

@@ -2226,6 +2226,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties:

charts/fluent-operator/charts/fluentd-crds/crds/fluentd.fluent.io_outputs.yaml

@@ -2226,6 +2226,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties:

config/crd/bases/fluentd.fluent.io_clusteroutputs.yaml

@@ -2226,6 +2226,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties:

config/crd/bases/fluentd.fluent.io_outputs.yaml

@@ -2226,6 +2226,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties:

docs/plugins/fluentd/output/null.md

@@ -0,0 +1,8 @@
+# Null
+
+Null defines the parameters for out_null output plugin
+
+
+| Field | Description | Scheme |
+| ----- | ----------- | ------ |
+| neverFlush | NeverFlush for testing to simulate the output plugin that never succeeds to flush. | *bool |

docs/plugins/fluentd/output/types.md

@@ -27,3 +27,4 @@ Output defines all available output plugins and their parameters
 | cloudWatch | out_cloudwatch plugin | *[CloudWatch](#cloudwatch) |
 | datadog | datadog plugin | *[Datadog](#datadog) |
 | copy | copy plugin | *[Copy](#copy) |
+| nullPlugin | null plugin | *[Null](#null) |

manifests/setup/fluent-operator-crd.yaml

@@ -10723,6 +10723,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties:
@@ -39580,6 +39588,14 @@ spec:
                       required:
                       - url
                       type: object
+                    nullPlugin:
+                      description: null plugin
+                      properties:
+                        neverFlush:
+                          description: NeverFlush for testing to simulate the output
+                            plugin that never succeeds to flush.
+                          type: boolean
+                      type: object
                     opensearch:
                       description: out_opensearch plugin
                       properties: