diff --git a/Dockerfile b/Dockerfile
index b788435..045e8b5 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -10,28 +10,22 @@ RUN export GO111MODULE=on \
   && init-stack go mod vendor \
   && init-stack go build \
     -ldflags "-X main.Revision=${BUILD_TAG} -X main.BuildDate=${BUILD_DATE}" \
-    -buildmode=c-shared -o /var/lib/fluent-bit/out_drycc.so plugin/out_drycc.go
+    -buildmode=c-shared -o /var/lib/fluent-bit/out_quickwit.so plugin/out_quickwit.go
 
 
 FROM registry.drycc.cc/drycc/base:${CODENAME}
 
-ENV DRYCC_UID=1001 \
+ARG DRYCC_UID=1001 \
   DRYCC_GID=1001 \
-  FLUENT_BIT_VERSION=4.0.0 \
-  DRYCC_HOME_DIR=/opt/drycc \
-  FLUENT_BIT_PLUGINS_PATH=${DRYCC_HOME_DIR}/fluent-bit/plugins
-  
+  FLUENT_BIT_VERSION=4.0.9 \
+  DRYCC_HOME_DIR=/opt/drycc
+
 RUN groupadd drycc --gid ${DRYCC_GID} \
   && useradd drycc -u ${DRYCC_UID} -g ${DRYCC_GID} -s /bin/bash -m -d ${DRYCC_HOME_DIR}
 
 RUN install-stack fluent-bit ${FLUENT_BIT_VERSION} \
-  && mkdir -p ${FLUENT_BIT_PLUGINS_PATH} \
   && chown -R ${DRYCC_UID}:${DRYCC_GID} ${DRYCC_HOME_DIR}/fluent-bit
 
-COPY --chown=${DRYCC_UID}:${DRYCC_GID} --from=build /var/lib/fluent-bit/out_drycc.so ${FLUENT_BIT_PLUGINS_PATH}
-
-ADD rootfs /
+COPY --chown=${DRYCC_UID}:${DRYCC_GID} --from=build /var/lib/fluent-bit/out_quickwit.so /opt/drycc/fluent-bit/lib
 
 USER ${DRYCC_UID}
-
-CMD ["/usr/local/bin/boot"]
diff --git a/Makefile b/Makefile
index 36af89d..3ccbdc4 100644
--- a/Makefile
+++ b/Makefile
@@ -1,7 +1,6 @@
 SHORT_NAME ?= fluentbit
 BUILD_TAG ?= git-$(shell git rev-parse --short HEAD)
 BUILD_DATE := $(shell date --rfc-3339=ns | tr " " T)
-SHELL_SCRIPTS = $(wildcard rootfs/usr/local/bin/*)
 DRYCC_REGISTRY ?= ${DEV_REGISTRY}
 IMAGE_PREFIX ?= drycc
 PLATFORM ?= linux/amd64,linux/arm64
@@ -42,7 +41,6 @@ style-check:
 	gofmt -l -w -s plugin
 	go vet plugin
 	lint
-	shellcheck $(SHELL_SCRIPTS)
 
 clean:
 	rm -rf _dist
diff --git a/README.md b/README.md
index 649a1ed..c7f0aff 100644
--- a/README.md
+++ b/README.md
@@ -8,7 +8,7 @@ a lightweight, [Heroku-inspired](http://heroku.com) workflow.
 ## About
 This is an debian based image for running [fluentbit](http://fluentbit.io). It is built for the purpose of running on a kubernetes cluster.
 
-This image is in with [workflow](https://github.com/drycc/workflow) v2 to send all log data to the [logger](https://github.com/drycc/logger) component.
+This image is in with [workflow](https://github.com/drycc/workflow) v2 to send all log data to the [quickwit](https://github.com/drycc/quickwit) component.
 
 
 ## Helm Chart
@@ -23,12 +23,3 @@ Once you have installed the Helm client, you can deploy a Fluentbit Chart into a
 ```sh
 helm show values oci://registry.drycc.cc/charts-testing/fluentbit
 ```
-
-## Plugins
-
-Fluent Bit currently supports integration of Golang plugins built as shared objects for output plugins only. The interface for the Golang plugins is currently under development but is functional.
-
-### Drycc Output
-Drycc output is a custom fluentbit plugin that was written to forward data directly to drycc components while filtering out data that we did not care about. We have 2 pieces of information we care about currently.
-
-Logs from applications that are written to stdout within the container and the controller logs that represent actions against those applications. These logs are sent to an internal messaging system ([VALKEY](https://valkey.io)) on a configurable topic. The logger component then reads those messages and stores the data in an ring buffer.
diff --git a/charts/fluentbit/Chart.yaml b/charts/fluentbit/Chart.yaml
index 3f634f5..148e464 100644
--- a/charts/fluentbit/Chart.yaml
+++ b/charts/fluentbit/Chart.yaml
@@ -3,6 +3,10 @@ home: https://github.com/drycc/fluentbit
 apiVersion: v2
 appVersion: 1.0.0
 version: v1.0.0
+dependencies:
+  - name: common
+    repository: oci://registry.drycc.cc/charts
+    version: ~1.1.2
 description: Log shipping mechanism for Drycc Workflow.
 maintainers:
   - name: Drycc Team
diff --git a/charts/fluentbit/templates/_helpers.tpl b/charts/fluentbit/templates/_helpers.tpl
index 9d2d805..250674d 100644
--- a/charts/fluentbit/templates/_helpers.tpl
+++ b/charts/fluentbit/templates/_helpers.tpl
@@ -1,19 +1,8 @@
 {{/* Generate fluentbit envs */}}
 {{- define "fluentbit.envs" }}
 env:
-{{- if (.Values.valkeyUrl) }}
-- name: DRYCC_VALKEY_URL
+- name: NAMESPACE
   valueFrom:
-    secretKeyRef:
-      name: logger-fluentbit-creds
-      key: valkey-url
-{{- else if .Values.valkey.enabled }}
-- name: VALKEY_PASSWORD
-  valueFrom:
-    secretKeyRef:
-      name: valkey-creds
-      key: password
-- name: DRYCC_VALKEY_URL
-  value: "redis://:$(VALKEY_PASSWORD)@drycc-valkey.{{.Release.Namespace}}.svc.{{.Values.global.clusterDomain}}:16379/2"
-{{- end }}
+    fieldRef:
+      fieldPath: metadata.namespace
 {{- end }}
\ No newline at end of file
diff --git a/charts/fluentbit/templates/logger-fluentbit-configmap.yaml b/charts/fluentbit/templates/fluentbit-configmap.yaml
similarity index 94%
rename from charts/fluentbit/templates/logger-fluentbit-configmap.yaml
rename to charts/fluentbit/templates/fluentbit-configmap.yaml
index 3de9e14..5915f70 100644
--- a/charts/fluentbit/templates/logger-fluentbit-configmap.yaml
+++ b/charts/fluentbit/templates/fluentbit-configmap.yaml
@@ -1,7 +1,7 @@
 apiVersion: v1
 kind: ConfigMap
 metadata:
-  name: logger-fluentbit-config
+  name: fluentbit-config
   namespace: {{ .Release.Namespace }}
   labels:
     heritage: drycc
diff --git a/charts/fluentbit/templates/logger-fluentbit-daemon.yaml b/charts/fluentbit/templates/fluentbit-daemon.yaml
similarity index 74%
rename from charts/fluentbit/templates/logger-fluentbit-daemon.yaml
rename to charts/fluentbit/templates/fluentbit-daemon.yaml
index b8bb0f0..ddb77ce 100644
--- a/charts/fluentbit/templates/logger-fluentbit-daemon.yaml
+++ b/charts/fluentbit/templates/fluentbit-daemon.yaml
@@ -1,7 +1,7 @@
 apiVersion: apps/v1
 kind: DaemonSet
 metadata:
-  name: drycc-logger-fluentbit
+  name: drycc-fluentbit
   labels:
     heritage: drycc
   annotations:
@@ -11,33 +11,37 @@ spec:
     type: RollingUpdate
   selector:
     matchLabels:
-      app: drycc-logger-fluentbit
+      app: drycc-fluentbit
       heritage: drycc
   template:
     metadata:
-      name: drycc-logger-fluentbit
+      name: drycc-fluentbit
       labels: {{- include "common.labels.standard" . | nindent 8 }}
         heritage: drycc
-        app: drycc-logger-fluentbit
+        app: drycc-fluentbit
     spec:
-      serviceAccount: drycc-logger-fluentbit
+      serviceAccount: drycc-fluentbit
       initContainers:
-      - name: drycc-logger-fluentbit-init
+      - name: drycc-fluentbit-init
         image: {{.Values.imageRegistry}}/{{.Values.imageOrg}}/python-dev:latest
         imagePullPolicy: {{.Values.imagePullPolicy}}
         args:
         - netcat
         - -v
         - -u
-        - $(DRYCC_VALKEY_URL)
+        - http://drycc-quickwit-indexer:7280
         {{- include "fluentbit.envs" . | indent 8 }}
       containers:
-      - name: drycc-logger-fluentbit
+      - name: drycc-fluentbit
         image: {{.Values.imageRegistry}}/{{.Values.imageOrg}}/fluentbit:{{.Values.imageTag}}
         imagePullPolicy: {{.Values.imagePullPolicy}}
         {{- if .Values.diagnosticMode.enabled }}
         command: {{- include "common.tplvalues.render" (dict "value" .Values.diagnosticMode.command "context" $) | nindent 10 }}
         args: {{- include "common.tplvalues.render" (dict "value" .Values.diagnosticMode.args "context" $) | nindent 10 }}
+        {{- else }}
+        args:
+        - fluent-bit
+        - --config=/opt/drycc/fluent-bit/etc/fluent-bit/fluent-bit.conf
         {{- end }}
         {{- with index .Values "resources" }}
         resources:
@@ -47,15 +51,15 @@ spec:
         volumeMounts:
         - name: varlog
           mountPath: /var/log
-        - name: logger-fluentbit-config
-          mountPath: /opt/drycc/fluent-bit/templates
+        - name: fluentbit-config
+          mountPath: /opt/drycc/fluent-bit/etc/fluent-bit
       volumes:
       - name: varlog
         hostPath:
           path: /var/log
-      - name: logger-fluentbit-config
+      - name: fluentbit-config
         configMap:
-          name: logger-fluentbit-config
+          name: fluentbit-config
       securityContext:
         fsGroup: 0
         runAsGroup: 0
diff --git a/charts/fluentbit/templates/logger-fluentbit-service-account.yaml b/charts/fluentbit/templates/fluentbit-service-account.yaml
similarity index 71%
rename from charts/fluentbit/templates/logger-fluentbit-service-account.yaml
rename to charts/fluentbit/templates/fluentbit-service-account.yaml
index 2f87155..5d03f02 100644
--- a/charts/fluentbit/templates/logger-fluentbit-service-account.yaml
+++ b/charts/fluentbit/templates/fluentbit-service-account.yaml
@@ -1,6 +1,6 @@
 apiVersion: v1
 kind: ServiceAccount
 metadata:
-  name: drycc-logger-fluentbit
+  name: drycc-fluentbit
   labels:
     heritage: drycc
diff --git a/charts/fluentbit/templates/logger-fluentbit-clusterrole.yaml b/charts/fluentbit/templates/logger-fluentbit-clusterrole.yaml
deleted file mode 100644
index d6b0388..0000000
--- a/charts/fluentbit/templates/logger-fluentbit-clusterrole.yaml
+++ /dev/null
@@ -1,11 +0,0 @@
-kind: ClusterRole
-apiVersion: rbac.authorization.k8s.io/v1
-metadata:
-  name: {{ printf "%s:drycc-logger-fluentbit" .Release.Namespace | quote }}
-  labels:
-    app: drycc-logger-fluentbit
-    heritage: drycc
-rules:
-- apiGroups: [""]
-  resources: ["pods", "namespaces"]
-  verbs: ["list", "get", "watch"]
\ No newline at end of file
diff --git a/charts/fluentbit/templates/logger-fluentbit-clusterrolebinding.yaml b/charts/fluentbit/templates/logger-fluentbit-clusterrolebinding.yaml
deleted file mode 100644
index e05225b..0000000
--- a/charts/fluentbit/templates/logger-fluentbit-clusterrolebinding.yaml
+++ /dev/null
@@ -1,15 +0,0 @@
-kind: ClusterRoleBinding
-apiVersion: rbac.authorization.k8s.io/v1
-metadata:
-  name: {{ printf "%s:drycc-logger-fluentbit" .Release.Namespace | quote }}
-  labels:
-    app: drycc-logger-fluentbit
-    heritage: drycc
-roleRef:
-  apiGroup: rbac.authorization.k8s.io
-  kind: ClusterRole
-  name: {{ printf "%s:drycc-logger-fluentbit" .Release.Namespace | quote }}
-subjects:
-- kind: ServiceAccount
-  name: drycc-logger-fluentbit
-  namespace: {{ .Release.Namespace }}
diff --git a/charts/fluentbit/templates/logger-fluentbit-secret-creds.yaml b/charts/fluentbit/templates/logger-fluentbit-secret-creds.yaml
deleted file mode 100644
index 7a26ea2..0000000
--- a/charts/fluentbit/templates/logger-fluentbit-secret-creds.yaml
+++ /dev/null
@@ -1,10 +0,0 @@
-apiVersion: v1
-kind: Secret
-metadata:
-  name: logger-fluentbit-creds
-  labels:
-    heritage: drycc
-data:
-  {{- if (.Values.valkeyUrl) }}
-  valkey-url: {{ .Values.valkeyUrl | b64enc }}
-  {{- end }}
\ No newline at end of file
diff --git a/charts/fluentbit/values.yaml b/charts/fluentbit/values.yaml
index 7e52dd8..b815578 100644
--- a/charts/fluentbit/values.yaml
+++ b/charts/fluentbit/values.yaml
@@ -27,10 +27,11 @@ resources: {}
   #   memory: 30Mi
 
 # Interval to flush output (seconds)
-flush: 1
+flush: 10
 
-# external valkey configuration
-valkeyUrl: ""
+# The log index prefix in Quickwit, which is prepended to the index name.
+quickwit:
+  logIndexPrefix: "logs-"
 
 ## https://docs.fluentbit.io/manual/administration/configuring-fluent-bit/classic-mode/configuration-file
 config:
@@ -39,14 +40,14 @@ config:
         Flush               {{ .Values.flush }}
         Daemon              Off
         Log_Level           info
-        Plugins_File        /opt/drycc/fluent-bit/etc/fluent-bit/plugins.conf
         Parsers_File        /opt/drycc/fluent-bit/etc/fluent-bit/parsers.conf
+        Plugins_File        /opt/drycc/fluent-bit/etc/fluent-bit/plugins.conf
 
   ## https://docs.fluentbit.io/manual/pipeline/inputs
   inputs: |
     [INPUT]
         Name                tail
-        Path                /var/log/containers/*_{{ .Release.Namespace }}_*.log
+        Path                /var/log/containers/*.log
         DB                  /var/log/containers.pos.db
         DB.locking          true
         Offset_Key          offset
@@ -59,24 +60,23 @@ config:
     [FILTER]
         Name                kubernetes
         Match               kubernetes.*
-        Kube_URL            https://${KUBERNETES_SERVICE_HOST}:${KUBERNETES_SERVICE_PORT}
-        Kube_CA_File        /var/run/secrets/kubernetes.io/serviceaccount/ca.crt
-        Kube_Token_File     /var/run/secrets/kubernetes.io/serviceaccount/token
-        Kube_Tag_Prefix     kubernetes.var.log.containers.
-        tls.verify          false
+        Keep_Log            Off
+        Merge_Log           On
         Buffer_Size         0
+        Regex_Parser        kubernetes
+        Use_Tag_For_Meta    true
 
   ## https://docs.fluentbit.io/manual/pipeline/outputs
   outputs: |
     [OUTPUT]
-        Name                drycc
+        Name                quickwit
         Match               kubernetes.*
-        Stream              logs
-        Max_Len             3000
-        Valkey_URL          ${DRYCC_VALKEY_URL}
-        Controller_Name     drycc-controller
-        Controller_Regex    ^(INFO|WARN|DEBUG|ERROR)\s+(\[(\S+)\])+:(.*)
-        Exclude_Namespaces  drycc,drycc-manager,drycc-helmbroker,kube-system,metallb
+        Base_URL            http://drycc-quickwit-indexer:7280
+        Compress            true
+        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    rfc3399
   ## https://docs.fluentbit.io/manual/pipeline/parsers
   parsers: |
     [PARSER]
@@ -86,7 +86,7 @@ config:
         Time_Format         %Y-%m-%dT%H:%M:%S.%L
         Time_Keep           On
 
-    [PARSER]
+    [PARSER] 
         # http://rubular.com/r/tjUt3Awgg4
         Name                cri
         Format              regex
@@ -94,10 +94,13 @@ config:
         Time_Key            time
         Time_Format         %Y-%m-%dT%H:%M:%S.%L%z
         Time_Keep           On
+
+    [PARSER]
+        Name    kubernetes
+        Format  regex
+        Regex   (?<tag>[^.]+)?\.?(?<pod_name>[a-z0-9](?:[-a-z0-9]*[a-z0-9])?(?:\.[a-z0-9]([-a-z0-9]*[a-z0-9])?)*)_(?<namespace_name>[^_]+)_(?<container_name>.+)-(?<docker_id>[a-z0-9]{64})\.log$
+
   ## https://docs.fluentbit.io/manual/development/golang-output-plugins
   plugins: |
     [PLUGINS]
-        Path                ${FLUENT_BIT_PLUGINS_PATH}/out_drycc.so
-
-valkey:
-  enabled: true
+        Path                /opt/drycc/fluent-bit/lib/out_quickwit.so
diff --git a/go.mod b/go.mod
index 089fc7e..731700a 100644
--- a/go.mod
+++ b/go.mod
@@ -1,14 +1,23 @@
 module github.com/drycc/fluentbit
 
-go 1.24
+go 1.25
 
 require (
+	github.com/Masterminds/sprig/v3 v3.3.0
 	github.com/fluent/fluent-bit-go v0.0.0-20230731091245-a7a013e2473c
-	github.com/valkey-io/valkey-go v1.0.56
-	github.com/valkey-io/valkey-go/valkeycompat v1.0.56
 )
 
 require (
+	dario.cat/mergo v1.0.1 // indirect
+	github.com/Masterminds/goutils v1.1.1 // indirect
+	github.com/Masterminds/semver/v3 v3.3.0 // indirect
+	github.com/google/go-cmp v0.7.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/huandu/xstrings v1.5.0 // indirect
+	github.com/mitchellh/copystructure v1.2.0 // indirect
+	github.com/mitchellh/reflectwalk v1.0.2 // indirect
+	github.com/shopspring/decimal v1.4.0 // indirect
+	github.com/spf13/cast v1.7.0 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
-	golang.org/x/sys v0.31.0 // indirect
+	golang.org/x/crypto v0.26.0 // indirect
 )
diff --git a/go.sum b/go.sum
index 33b3aa0..3639cf0 100644
--- a/go.sum
+++ b/go.sum
@@ -1,36 +1,49 @@
+dario.cat/mergo v1.0.1 h1:Ra4+bf83h2ztPIQYNP99R6m+Y7KfnARDfID+a+vLl4s=
+dario.cat/mergo v1.0.1/go.mod h1:uNxQE+84aUszobStD9th8a29P2fMDhsBdgRYvZOxGmk=
+github.com/Masterminds/goutils v1.1.1 h1:5nUrii3FMTL5diU80unEVvNevw1nH4+ZV4DSLVJLSYI=
+github.com/Masterminds/goutils v1.1.1/go.mod h1:8cTjp+g8YejhMuvIA5y2vz3BpJxksy863GQaJW2MFNU=
+github.com/Masterminds/semver/v3 v3.3.0 h1:B8LGeaivUe71a5qox1ICM/JLl0NqZSW5CHyL+hmvYS0=
+github.com/Masterminds/semver/v3 v3.3.0/go.mod h1:4V+yj/TJE1HU9XfppCwVMZq3I84lprf4nC11bSS5beM=
+github.com/Masterminds/sprig/v3 v3.3.0 h1:mQh0Yrg1XPo6vjYXgtf5OtijNAKJRNcTdOOGZe3tPhs=
+github.com/Masterminds/sprig/v3 v3.3.0/go.mod h1:Zy1iXRYNqNLUolqCpL4uhk6SHUMAOSCzdgBfDb35Lz0=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/fluent/fluent-bit-go v0.0.0-20230731091245-a7a013e2473c h1:yKN46XJHYC/gvgH2UsisJ31+n4K3S7QYZSfU2uAWjuI=
 github.com/fluent/fluent-bit-go v0.0.0-20230731091245-a7a013e2473c/go.mod h1:L92h+dgwElEyUuShEwjbiHjseW410WIcNz+Bjutc8YQ=
-github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
-github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
-github.com/go-task/slim-sprig/v3 v3.0.0 h1:sUs3vkvUymDpBKi3qH1YSqBQk9+9D/8M2mN1vB6EwHI=
-github.com/go-task/slim-sprig/v3 v3.0.0/go.mod h1:W848ghGpv3Qj3dhTPRyJypKRiqCdHZiAzKg9hl15HA8=
+github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=
+github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=
 github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
 github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
-github.com/google/pprof v0.0.0-20250208200701-d0013a598941 h1:43XjGa6toxLpeksjcxs1jIoIyr+vUfOqY2c6HB4bpoc=
-github.com/google/pprof v0.0.0-20250208200701-d0013a598941/go.mod h1:vavhavw2zAxS5dIdcRluK6cSGGPlZynqzFM8NdvU144=
-github.com/onsi/ginkgo/v2 v2.22.2 h1:/3X8Panh8/WwhU/3Ssa6rCKqPLuAkVY2I0RoyDLySlU=
-github.com/onsi/ginkgo/v2 v2.22.2/go.mod h1:oeMosUL+8LtarXBHu/c0bx2D/K9zyQ6uX3cTyztHwsk=
-github.com/onsi/gomega v1.36.2 h1:koNYke6TVk6ZmnyHrCXba/T/MoLBXFjeC1PtvYgw0A8=
-github.com/onsi/gomega v1.36.2/go.mod h1:DdwyADRjrc825LhMEkD76cHR5+pUnjhUN8GlHlRPHzY=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/huandu/xstrings v1.5.0 h1:2ag3IFq9ZDANvthTwTiqSSZLjDc+BedvHPAp5tJy2TI=
+github.com/huandu/xstrings v1.5.0/go.mod h1:y5/lhBue+AyNmUVz9RLU9xbLR0o4KIIExikq4ovT0aE=
+github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
+github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/mitchellh/copystructure v1.2.0 h1:vpKXTN4ewci03Vljg/q9QvCGUDttBOGBIa15WveJJGw=
+github.com/mitchellh/copystructure v1.2.0/go.mod h1:qLl+cE2AmVv+CoeAwDPye/v+N2HKCj9FbZEVFJRxO9s=
+github.com/mitchellh/reflectwalk v1.0.2 h1:G2LzWKi524PWgd3mLHV8Y5k7s6XUvT0Gef6zxSIeXaQ=
+github.com/mitchellh/reflectwalk v1.0.2/go.mod h1:mSTlrgnPZtwu0c4WaC2kGObEpuNDbx0jmZXqmk4esnw=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/rogpeppe/go-internal v1.9.0 h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=
+github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs=
+github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
+github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
+github.com/spf13/cast v1.7.0 h1:ntdiHjuueXFgm5nzDRdOS4yfT43P5Fnud6DH50rz/7w=
+github.com/spf13/cast v1.7.0/go.mod h1:ancEpBxwJDODSW/UG4rDrAqiKolqNNh2DX3mk86cAdo=
+github.com/stretchr/testify v1.5.1 h1:nOGnQDM7FYENwehXlg/kFVnos3rEvtKTjRvOWSzb6H4=
+github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/ugorji/go v1.1.7/go.mod h1:kZn38zHttfInRq0xu/PH0az30d+z6vm202qpg1oXVMw=
 github.com/ugorji/go/codec v1.1.7/go.mod h1:Ax+UKWsSmolVDwsd+7N3ZtXu+yMGCf907BLYF3GoBXY=
 github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE=
 github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
-github.com/valkey-io/valkey-go v1.0.56 h1:7qp/9dqqPbYEEKeFZCnpX6nzM5XzO2MPp0iKh9+c9Wg=
-github.com/valkey-io/valkey-go v1.0.56/go.mod h1:sxpCChk8i3oTG+A/lUi9Lj8C/7WI+yhnQCvDJlPVKNM=
-github.com/valkey-io/valkey-go/mock v1.0.56 h1:ZJ1W5nBLPcYxqTHqlbLFZ+QTkP8csJAmTGiairz8cVo=
-github.com/valkey-io/valkey-go/mock v1.0.56/go.mod h1:PotVMrBbjcPwBgec2CFEHfe+4/URbxN7cnBmU3sTy9o=
-github.com/valkey-io/valkey-go/valkeycompat v1.0.56 h1:bqltI2FCAElpY/LHKJe5scRtdRvHdIbhKPkCWki3Ppg=
-github.com/valkey-io/valkey-go/valkeycompat v1.0.56/go.mod h1:knF+QzcgwPDEoes594Rircbt+ZhXtnnEGc2UzvNqEFU=
-go.uber.org/mock v0.5.0 h1:KAMbZvZPyBPWgD14IrIQ38QCyjwpvVVV6K/bHl1IwQU=
-go.uber.org/mock v0.5.0/go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM=
-golang.org/x/net v0.37.0 h1:1zLorHbz+LYj7MQlSf1+2tPIIgibq2eL5xkrGk6f+2c=
-golang.org/x/net v0.37.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
-golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik=
-golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
-golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY=
-golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4=
-golang.org/x/tools v0.31.0 h1:0EedkvKDbh+qistFTd0Bcwe/YLh4vHwWEkiI0toFIBU=
-golang.org/x/tools v0.31.0/go.mod h1:naFTU+Cev749tSJRXJlna0T3WxKvb1kWEx15xA4SdmQ=
+golang.org/x/crypto v0.26.0 h1:RrRspgV4mU+YwB4FYnuBoKsUapNIL5cohGAmSH3azsw=
+golang.org/x/crypto v0.26.0/go.mod h1:GY7jblb9wI+FOo5y8/S2oY4zWP07AkOJ4+jxCqdqn54=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU=
+gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
diff --git a/plugin/out_drycc.go b/plugin/out_drycc.go
deleted file mode 100644
index b0bb894..0000000
--- a/plugin/out_drycc.go
+++ /dev/null
@@ -1,156 +0,0 @@
-package main
-
-import (
-	"C"
-	"unsafe"
-
-	"context"
-	"strings"
-
-	"github.com/fluent/fluent-bit-go/output"
-	"github.com/valkey-io/valkey-go"
-	"github.com/valkey-io/valkey-go/valkeycompat"
-)
-import (
-	"encoding/json"
-	"fmt"
-	"regexp"
-	"strconv"
-	"time"
-)
-
-var (
-	Stream            string
-	MaxLen            int64
-	Revision          string
-	BuildDate         string
-	ControllerName    string
-	ControllerRegex   *regexp.Regexp
-	ExcludeNamespaces []string
-	ValkeyClient      valkey.Client
-)
-
-//export FLBPluginRegister
-func FLBPluginRegister(ctx unsafe.Pointer) int {
-	fmt.Printf("Drycc output version %s %s", Revision, BuildDate)
-	return output.FLBPluginRegister(ctx, "drycc", "Ship fluent-bit logs to valkey xstream")
-}
-
-// (fluentbit will call this)
-// ctx (context) pointer to fluentbit context (state/ c code)
-//
-//export FLBPluginInit
-func FLBPluginInit(ctx unsafe.Pointer) int {
-	var err error
-	Stream = output.FLBPluginConfigKey(ctx, "Stream")
-	MaxLen, err = strconv.ParseInt(output.FLBPluginConfigKey(ctx, "Max_Len"), 10, 64)
-	if err != nil {
-		MaxLen = 1000
-	}
-	ValkeyURL := output.FLBPluginConfigKey(ctx, "Valkey_URL")
-	ControllerName = output.FLBPluginConfigKey(ctx, "Controller_Name")
-	ControllerRegex = regexp.MustCompile(output.FLBPluginConfigKey(ctx, "Controller_Regex"))
-	ExcludeNamespaces = strings.Split(output.FLBPluginConfigKey(ctx, "Exclude_Namespaces"), ",")
-
-	ValkeyClient, err = valkey.NewClient(valkey.MustParseURL(ValkeyURL))
-	if err != nil {
-		return output.FLB_ERROR
-	}
-	return output.FLB_OK
-}
-
-//export FLBPluginFlushCtx
-//revive:disable:unused-parameter
-func FLBPluginFlushCtx(ctx, data unsafe.Pointer, length C.int, _ *C.char) int {
-	status := output.FLB_OK
-	context, cancel := context.WithTimeout(context.Background(), time.Second*30)
-	defer cancel()
-	decoder := output.NewDecoder(data, int(length))
-	pipeline := valkeycompat.NewAdapter(ValkeyClient).Pipeline()
-	for {
-		ret, ts, rec := output.GetRecord(decoder)
-		if ret != 0 {
-			break
-		}
-		// Get timestamp
-		rec["time"] = toTimestamp(ts)
-		if !checkRecord(rec) {
-			continue
-		}
-		if values, err := toValues(rec); err == nil {
-			pipeline.XAdd(context, valkeycompat.XAddArgs{
-				Stream:     Stream,
-				NoMkStream: false,
-				MaxLen:     MaxLen,
-				Approx:     true,
-				ID:         "*",
-				Values:     values,
-			})
-		} else {
-			status = output.FLB_ERROR
-		}
-	}
-	if _, err := pipeline.Exec(context); err != nil {
-		status = output.FLB_ERROR
-	}
-	return status
-}
-
-//export FLBPluginExit
-func FLBPluginExit() int {
-	ValkeyClient.Close()
-	return output.FLB_OK
-}
-
-func toMap(values map[interface{}]interface{}) map[string]interface{} {
-	m := make(map[string]interface{})
-	for k, v := range values {
-		switch t := v.(type) {
-		case []byte:
-			// prevent encoding to base64
-			m[k.(string)] = string(t)
-		case map[interface{}]interface{}:
-			m[k.(string)] = toMap(t)
-		default:
-			m[k.(string)] = v
-		}
-	}
-	return m
-}
-
-func toValues(values map[interface{}]interface{}) (map[string]interface{}, error) {
-	data, err := json.Marshal(toMap(values))
-	if err != nil {
-		return nil, err
-	}
-	return map[string]interface{}{"data": data, "timestamp": time.Now().Unix()}, err
-}
-
-func toTimestamp(ts interface{}) string {
-	var timestamp time.Time
-	switch t := ts.(type) {
-	case output.FLBTime:
-		timestamp = ts.(output.FLBTime).Time
-	case uint64:
-		timestamp = time.Unix(int64(t), 0)
-	default:
-		timestamp = time.Now()
-	}
-	return timestamp.Format(time.RFC3339Nano)
-}
-
-func checkRecord(record map[interface{}]interface{}) bool {
-	if kubernetes, ok := record["kubernetes"].(map[interface{}]interface{}); ok {
-		// drycc controller
-		container := fmt.Sprintf("%s", kubernetes["container_name"])
-		if ok && strings.HasPrefix(container, ControllerName) {
-			log := fmt.Sprintf("%s", record["log"])
-			if ok && len(ControllerRegex.FindStringSubmatch(log)) > 0 {
-				return true
-			}
-		}
-	}
-	return false
-}
-
-func main() {}
diff --git a/plugin/out_quickwit.go b/plugin/out_quickwit.go
new file mode 100644
index 0000000..c4c6c79
--- /dev/null
+++ b/plugin/out_quickwit.go
@@ -0,0 +1,192 @@
+// drycc quickwit plugin
+package main
+
+import (
+	"C"
+)
+
+import (
+	"bytes"
+	"crypto/tls"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"strconv"
+	"strings"
+	"sync"
+	"text/template"
+	"time"
+	"unsafe"
+
+	"github.com/Masterminds/sprig/v3"
+	"github.com/fluent/fluent-bit-go/output"
+)
+
+var (
+	MaxLen    int64
+	Revision  string
+	BuildDate string
+
+	// plugin config
+	BaseURL        string
+	IndexName      string
+	Compress       bool
+	BufferSize     int
+	JSONDateKey    string
+	JSONDateFormat string
+	// internal variables
+	BufferPool        sync.Pool
+	IndexNameTemplate *template.Template
+)
+
+//export FLBPluginRegister
+func FLBPluginRegister(ctx unsafe.Pointer) int {
+	fmt.Printf("Quickwit output version %s %s", Revision, BuildDate)
+	return output.FLBPluginRegister(ctx, "quickwit", "Ship fluent-bit logs to quickwit")
+}
+
+// (fluentbit will call this)
+// ctx (context) pointer to fluentbit context (state/ c code)
+//
+//export FLBPluginInit
+func FLBPluginInit(ctx unsafe.Pointer) int {
+	BaseURL = output.FLBPluginConfigKey(ctx, "Base_URL")
+	IndexName = output.FLBPluginConfigKey(ctx, "Index_Name")
+	Compress, _ = strconv.ParseBool(output.FLBPluginConfigKey(ctx, "Compress"))
+
+	var err error
+	BufferSize, err = strconv.Atoi(output.FLBPluginConfigKey(ctx, "Buffer_Size"))
+	if err != nil {
+		panic(err)
+	}
+	BufferPool = sync.Pool{
+		New: func() any {
+			buffer := &bytes.Buffer{}
+			buffer.Grow(BufferSize)
+			return buffer
+		},
+	}
+	IndexNameTemplate, err = template.New("index").Funcs(sprig.FuncMap()).Parse(IndexName)
+	if err != nil {
+		panic(err)
+	}
+	JSONDateKey = output.FLBPluginConfigKey(ctx, "Json_Date_Key")
+	JSONDateFormat = output.FLBPluginConfigKey(ctx, "Json_Date_Format")
+	return output.FLB_OK
+}
+
+//export FLBPluginFlushCtx
+//revive:disable:unused-parameter
+func FLBPluginFlushCtx(ctx, data unsafe.Pointer, length C.int, _ *C.char) int {
+	decoder := output.NewDecoder(data, int(length))
+	results := make(map[string]*bytes.Buffer)
+	for {
+		ret, ts, rec := output.GetRecord(decoder)
+		if ret != 0 {
+			break
+		}
+		data := convertMap(rec)
+		data[JSONDateKey] = formatTime(ts, JSONDateFormat)
+		if jsonBytes, err := json.Marshal(data); err == nil {
+			var buffer bytes.Buffer
+			IndexNameTemplate.Execute(&buffer, data)
+			index := buffer.String()
+			if buffer, ok := results[index]; !ok {
+				buffer := BufferPool.Get().(*bytes.Buffer)
+				results[index] = buffer
+				buffer.Write(jsonBytes)
+				buffer.WriteByte('\n')
+			} else {
+				buffer.Write(jsonBytes)
+				buffer.WriteByte('\n')
+			}
+		}
+	}
+	if err := sendResults(results); err != nil {
+		return output.FLB_ERROR
+	}
+	return output.FLB_OK
+}
+
+//export FLBPluginExit
+func FLBPluginExit() int {
+	return output.FLB_OK
+}
+
+func formatTime(ts any, format string) string {
+	var timestamp time.Time
+	switch t := ts.(type) {
+	case output.FLBTime:
+		timestamp = ts.(output.FLBTime).Time
+	case uint64:
+		timestamp = time.Unix(int64(t), 0)
+	default:
+		timestamp = time.Now()
+	}
+	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 {
+	m := make(map[string]any)
+	for k, v := range values {
+		key := fmt.Sprintf("%v", k)
+		switch t := v.(type) {
+		case []byte:
+			m[key] = string(t)
+		case map[any]any:
+			m[key] = convertMap(t)
+		default:
+			m[key] = v
+		}
+	}
+	return m
+}
+
+func sendResults(results map[string]*bytes.Buffer) error {
+	client := &http.Client{
+		Transport: &http.Transport{
+			TLSClientConfig:    &tls.Config{InsecureSkipVerify: false},
+			ForceAttemptHTTP2:  true,
+			MaxIdleConns:       100,
+			IdleConnTimeout:    90 * time.Second,
+			DisableCompression: !Compress,
+		},
+		Timeout: 30 * time.Second,
+	}
+	defer client.CloseIdleConnections()
+	for index, body := range results {
+		url := fmt.Sprintf("%s/api/v1/%s/ingest", BaseURL, index)
+		if req, err := http.NewRequest("POST", url, body); err == nil {
+			if resp, err := client.Do(req); err == nil {
+				io.Copy(io.Discard, resp.Body)
+				resp.Body.Close()
+				body.Reset()
+			}
+		}
+	}
+	return nil
+}
+
+func main() {}
diff --git a/rootfs/opt/drycc/fluent-bit/templates/fluent-bit.conf b/rootfs/opt/drycc/fluent-bit/templates/fluent-bit.conf
deleted file mode 100644
index 6d9fa26..0000000
--- a/rootfs/opt/drycc/fluent-bit/templates/fluent-bit.conf
+++ /dev/null
@@ -1,35 +0,0 @@
-[SERVICE]
-    Flush               1
-    Daemon              Off
-    Log_Level           info
-    Plugins_File        /opt/drycc/fluent-bit/etc/fluent-bit/plugins.conf
-    Parsers_File        /opt/drycc/fluent-bit/etc/fluent-bit/parsers.conf
-
-[INPUT]
-    Name                tail
-    Path                /var/log/containers/*.log
-    DB                  /var/log/containers.pos.db
-    DB.locking          true
-    Offset_Key          offset
-    Tag                 kubernetes.*
-    Read_from_Head      false
-    multiline.parser    docker,cri
-
-[FILTER]
-    Name                kubernetes
-    Match               kubernetes.*
-    Kube_URL            https://${KUBERNETES_SERVICE_HOST}:${KUBERNETES_SERVICE_PORT}
-    Kube_CA_File        /var/run/secrets/kubernetes.io/serviceaccount/ca.crt
-    Kube_Token_File     /var/run/secrets/kubernetes.io/serviceaccount/token
-    Kube_Tag_Prefix     kubernetes.var.log.containers.
-    tls.verify          false
-
-[OUTPUT]
-    Name                drycc
-    Match               kubernetes.*
-    Stream              logs
-    Max_Len             3000
-    Valkey_URL          ${DRYCC_VALKEY_URL}
-    Controller_Name     drycc-controller
-    Controller_Regex    ^(INFO|WARN|DEBUG|ERROR)\s+(\[(\S+)\])+:(.*)
-    Exclude_Namespaces  drycc,drycc-manager,drycc-helmbroker,kube-system,metallb
\ No newline at end of file
diff --git a/rootfs/opt/drycc/fluent-bit/templates/parsers.conf b/rootfs/opt/drycc/fluent-bit/templates/parsers.conf
deleted file mode 100644
index ec918ee..0000000
--- a/rootfs/opt/drycc/fluent-bit/templates/parsers.conf
+++ /dev/null
@@ -1,15 +0,0 @@
-[PARSER]
-    Name                docker
-    Format              json
-    Time_Key            time
-    Time_Format         %Y-%m-%dT%H:%M:%S.%L
-    Time_Keep           On
-
-[PARSER]
-    # http://rubular.com/r/tjUt3Awgg4
-    Name                cri
-    Format              regex
-    Regex               ^(?<time>[^ ]+) (?<stream>stdout|stderr) (?<logtag>[^ ]*) (?<message>.*)$
-    Time_Key            time
-    Time_Format         %Y-%m-%dT%H:%M:%S.%L%z
-    Time_Keep           On
\ No newline at end of file
diff --git a/rootfs/opt/drycc/fluent-bit/templates/plugins.conf b/rootfs/opt/drycc/fluent-bit/templates/plugins.conf
deleted file mode 100644
index 0f56db0..0000000
--- a/rootfs/opt/drycc/fluent-bit/templates/plugins.conf
+++ /dev/null
@@ -1,2 +0,0 @@
-[PLUGINS]
-    Path                ${FLUENT_BIT_PLUGINS_PATH}/out_drycc.so
\ No newline at end of file
diff --git a/rootfs/usr/local/bin/boot b/rootfs/usr/local/bin/boot
deleted file mode 100755
index 39d4c4b..0000000
--- a/rootfs/usr/local/bin/boot
+++ /dev/null
@@ -1,20 +0,0 @@
-#!/usr/bin/env bash
-set -eo pipefail
-shopt -s expand_aliases
-
-eval "cat <<EOF
-$(</opt/drycc/fluent-bit/templates/plugins.conf)
-EOF
-" 2> /dev/null > /opt/drycc/fluent-bit/etc/fluent-bit/plugins.conf
-
-eval "cat <<EOF
-$(</opt/drycc/fluent-bit/templates/parsers.conf)
-EOF
-" 2> /dev/null > /opt/drycc/fluent-bit/etc/fluent-bit/parsers.conf
-
-eval "cat <<EOF
-$(</opt/drycc/fluent-bit/templates/fluent-bit.conf)
-EOF
-" 2> /dev/null > /opt/drycc/fluent-bit/etc/fluent-bit/fluent-bit.conf
-
-fluent-bit -c /opt/drycc/fluent-bit/etc/fluent-bit/fluent-bit.conf
