chore(fluentbit): add rfc3399 format

Author: duanhongyi

charts/fluentbit/Chart.lock

@@ -76,10 +76,10 @@ config:
         Match               kubernetes.*
         Base_URL            http://drycc-quickwit-indexer.{{ $.Release.Namespace }}.svc.{{ .Values.global.clusterDomain }}:7280
         Compress            true
-        Index_Name          {{ .Values.quickwit.logIndexPrefix }}${ .kubernetes.namespace_name | default "{{ .Release.Namespace }}" }
+        Index_Name          {{printf "%s{{ %s | default \"%s\" }}" .Values.quickwit.logIndexPrefix ".kubernetes.namespace_name" .Release.Namespace }}
         Buffer_Size         65536
         Json_Date_Key       timestamp
-        Json_Date_Format    %Y-%m-%dT%H:%M:%S%z
+        Json_Date_Format    rfc3399
   ## https://docs.fluentbit.io/manual/pipeline/parsers
   parsers: |
     [PARSER]
@@ -101,3 +101,6 @@ config:
   plugins: |
     [PLUGINS]
         Path                /opt/drycc/fluent-bit/lib/out_quickwit.so
+
+global:
+  clusterDomain: "cluster.local"

charts/fluentbit/charts/common-1.1.4.tgz

@@ -66,7 +66,7 @@ func FLBPluginInit(ctx unsafe.Pointer) int {
 			return buffer
 		},
 	}
-	IndexNameTemplate, err = template.New("url").Funcs(sprig.FuncMap()).Delims("${", "}").Parse(IndexName)
+	IndexNameTemplate, err = template.New("index").Funcs(sprig.FuncMap()).Parse(IndexName)
 	if err != nil {
 		panic(err)
 	}
@@ -123,21 +123,28 @@ func formatTime(ts any, format string) string {
 	default:
 		timestamp = time.Now()
 	}
-	return timestamp.Format(strings.NewReplacer(
-		"%Y", "2006",
-		"%y", "06",
-		"%m", "01",
-		"%d", "02",
-		"%H", "15",
-		"%I", "03",
-		"%M", "04",
-		"%S", "05",
-		"%p", "PM",
-		"%L", "000",
-		"%f", "000000",
-		"%z", "-0700",
-		"%Z", "MST",
-	).Replace(format))
+	switch format {
+	case "rfc3399":
+		return timestamp.Format(time.RFC3339)
+	case "unix_timestamp":
+		return fmt.Sprint(timestamp.Unix())
+	default:
+		return timestamp.Format(strings.NewReplacer(
+			"%Y", "2006",
+			"%y", "06",
+			"%m", "01",
+			"%d", "02",
+			"%H", "15",
+			"%I", "03",
+			"%M", "04",
+			"%S", "05",
+			"%p", "PM",
+			"%L", "000",
+			"%f", "000000",
+			"%z", "-0700",
+			"%Z", "MST",
+		).Replace(format))
+	}
 }
 
 func convertMap(values map[any]any) map[string]any {