example to stop after success

src/go_plugin/out_gstdout.go

@@ -32,20 +32,13 @@ func FLBPluginFlush(data unsafe.Pointer, length C.int, tag *C.char) int {
 	var ret int
 	var ts interface{}
 	var record map[interface{}]interface{}
-        xxdata := url.Values{
-          "name": {"x"},
-          "occupation": {"y"},
-        }
-        _, err := http.PostForm("https://softinst140097.host.vifib.net/erp5/fluentbit_upload_test/", xxdata)
-        if err == nil {
-          os.Exit(0)
-        }
-
 	// Create Fluent Bit decoder
 	dec := output.NewDecoder(data, int(length))
 
 	// Iterate Records
 	count = 0
+        var result string
+        result = ""
 	for {
 		// Extract Record
 		ret, ts, record = output.GetRecord(dec)
@@ -65,12 +58,11 @@ func FLBPluginFlush(data unsafe.Pointer, length C.int, tag *C.char) int {
 		}
 
 		// Print record keys and values
-		fmt.Printf("[%d] %s: [%s, {", count, C.GoString(tag),
-			timestamp.String())
+                result = result + C.GoString(tag) + ":[" +timestamp.String()
 		for k, v := range record {
-			fmt.Printf("\"%s\": %v, ", k, v)
+                   result = result + fmt.Sprintf("%s: %v", k,v)
 		}
-		fmt.Printf("}\n")
+                result += "}\n"
 		count++
 	}
 
@@ -79,7 +71,17 @@ func FLBPluginFlush(data unsafe.Pointer, length C.int, tag *C.char) int {
 	// output.FLB_OK    = data have been processed.
 	// output.FLB_ERROR = unrecoverable error, do not try this again.
 	// output.FLB_RETRY = retry to flush later.
-	return output.FLB_OK
+        fmt.Printf(result)
+        xxdata := url.Values{
+          "name": {result},
+          "occupation": {"y"},
+        }
+        res, err := http.PostForm("https://softinst140097.host.vifib.net/erp5/fluentbit_upload_test/", xxdata)
+        fmt.Printf("%v", res)
+        if err == nil {
+         os.Exit(0)
+        }
+	return output.FLB_RETRY
 }
 
 //export FLBPluginExit