Flush Buffer before Exit

kobsio · Nov 4, 2024 · d6b5727 · d6b5727
1 parent 3b46198
commit d6b5727
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/cmd/plugin/main.go b/cmd/plugin/main.go
@@ -369,7 +369,12 @@ func FLBPluginExit() int {
 
 //export FLBPluginExitCtx
 func FLBPluginExitCtx(ctx unsafe.Pointer) int {
-	metricsServer.Stop()
+	defer metricsServer.Stop()
+	err := client.BufferWrite()
+	if err != nil {
+		log.Error(nil, "Error while writing buffer", zap.Error(err))
+		return output.FLB_ERROR
+	}
 	return output.FLB_OK
 }