fix nil pointer reference

Signed-off-by: juicer <[email protected]>
fluent · Jul 4, 2024 · 072be47 · 072be47
1 parent cb16289
commit 072be47
Showing 1 changed file with 12 additions and 10 deletions.
diff --git a/controllers/fluentbitconfig_controller.go b/controllers/fluentbitconfig_controller.go
@@ -403,16 +403,18 @@ func (r *FluentBitConfigReconciler) generateRewriteTagConfig(
 			md5.Sum([]byte(cfg.Namespace)),
 		),
 	)
-	if cfg.Spec.Service.EmitterName != "" {
-		buf.WriteString(fmt.Sprintf("    Emitter_Name    %s\n", cfg.Spec.Service.EmitterName))
-	} else {
-		buf.WriteString(fmt.Sprintf("    Emitter_Name    re_emitted_%x\n", md5.Sum([]byte(cfg.Namespace))))
-	}
-	if cfg.Spec.Service.EmitterStorageType != "" {
-		buf.WriteString(fmt.Sprintf("    Emitter_Storage.type    %s\n", cfg.Spec.Service.EmitterStorageType))
-	}
-	if cfg.Spec.Service.EmitterMemBufLimit != "" {
-		buf.WriteString(fmt.Sprintf("    Emitter_Mem_Buf_Limit    %s\n", cfg.Spec.Service.EmitterMemBufLimit))
+	if cfg.Spec.Service != nil {
+		if cfg.Spec.Service.EmitterName != "" {
+			buf.WriteString(fmt.Sprintf("    Emitter_Name    %s\n", cfg.Spec.Service.EmitterName))
+		} else {
+			buf.WriteString(fmt.Sprintf("    Emitter_Name    re_emitted_%x\n", md5.Sum([]byte(cfg.Namespace))))
+		}
+		if cfg.Spec.Service.EmitterStorageType != "" {
+			buf.WriteString(fmt.Sprintf("    Emitter_Storage.type    %s\n", cfg.Spec.Service.EmitterStorageType))
+		}
+		if cfg.Spec.Service.EmitterMemBufLimit != "" {
+			buf.WriteString(fmt.Sprintf("    Emitter_Mem_Buf_Limit    %s\n", cfg.Spec.Service.EmitterMemBufLimit))
+		}
 	}
 	return buf.String()
 }