fix unit tests

openshift · Aug 19, 2020 · 1ec2338 · 1ec2338
1 parent 2bcb086
commit 1ec2338
Show file tree

Hide file tree

Showing 2 changed files with 50 additions and 0 deletions.
diff --git a/pkg/generators/forwarding/fluentd/fluent_conf_test.go b/pkg/generators/forwarding/fluentd/fluent_conf_test.go
@@ -352,6 +352,15 @@ var _ = Describe("Generating fluentd config", func() {
 					</record>
 					remove_keys req,res,msg,name,level,v,pid,err
 				</filter>
+
+				<filter k8s-audit.log**>
+				  @type record_transformer
+				  <record>
+				    k8s_audit_level ${record['level']}
+				  </record>
+				  remove_keys level
+				</filter>
+
 				<filter **>
 					@type viaq_data_model
 					elasticsearch_index_prefix_field 'viaq_index_name'
@@ -765,6 +774,15 @@ var _ = Describe("Generating fluentd config", func() {
 					</record>
 					remove_keys req,res,msg,name,level,v,pid,err
 				</filter>
+
+				<filter k8s-audit.log**>
+				  @type record_transformer
+				  <record>
+				    k8s_audit_level ${record['level']}
+				  </record>
+				  remove_keys level
+				</filter>
+
 				<filter **>
 					@type viaq_data_model
 					elasticsearch_index_prefix_field 'viaq_index_name'
@@ -1564,6 +1582,14 @@ var _ = Describe("Generating fluentd config", func() {
         remove_keys req,res,msg,name,level,v,pid,err
       </filter>
     
+      <filter k8s-audit.log**>
+        @type record_transformer
+        <record>
+          k8s_audit_level ${record['level']}
+        </record>
+        remove_keys level
+      </filter>
+
       <filter **>
         @type viaq_data_model
         elasticsearch_index_prefix_field 'viaq_index_name'

diff --git a/pkg/generators/forwarding/fluentd/output_conf_legacy_test.go b/pkg/generators/forwarding/fluentd/output_conf_legacy_test.go
@@ -299,6 +299,14 @@ var _ = Describe("Generating fluentd legacy output store config blocks", func()
             remove_keys req,res,msg,name,level,v,pid,err
           </filter>
 
+          <filter k8s-audit.log**>
+            @type record_transformer
+            <record>
+              k8s_audit_level ${record['level']}
+            </record>
+            remove_keys level
+          </filter>
+
           <filter **>
             @type viaq_data_model
             elasticsearch_index_prefix_field 'viaq_index_name'
@@ -739,6 +747,14 @@ var _ = Describe("Generating fluentd legacy output store config blocks", func()
             remove_keys req,res,msg,name,level,v,pid,err
           </filter>
 
+          <filter k8s-audit.log**>
+            @type record_transformer
+            <record>
+              k8s_audit_level ${record['level']}
+            </record>
+            remove_keys level
+          </filter>
+
           <filter **>
             @type viaq_data_model
             elasticsearch_index_prefix_field 'viaq_index_name'
@@ -1180,6 +1196,14 @@ var _ = Describe("Generating fluentd legacy output store config blocks", func()
             remove_keys req,res,msg,name,level,v,pid,err
           </filter>
 
+          <filter k8s-audit.log**>
+            @type record_transformer
+            <record>
+              k8s_audit_level ${record['level']}
+            </record>
+            remove_keys level
+          </filter>
+
           <filter **>
             @type viaq_data_model
             elasticsearch_index_prefix_field 'viaq_index_name'