Rename AsyncStop to ForceStopAsyncSend

Signed-off-by: JamesJJ <jj@fcg.fyi>

Author: JamesJJ

README.md

@@ -69,9 +69,9 @@ Since the default is zero value, Write will not time out.
 Enable asynchronous I/O (connect and write) for sending events to Fluentd.
 The default is false.
 
-### AsyncStop
+### ForceStopAsyncSend
 
-Enables discarding bufferred events when Close() is called in Async mode. If Fluentd is continuously unavailable, Close() will block forever otherwise.
+When Async is enabled, immediately discard the event queue on close() and return (instead of trying MaxRetry times for each event in the queue before returning)
 The default is false.
 
 ### RequestAck

fluent/fluent.go

@@ -37,19 +37,19 @@ const (
 )
 
 type Config struct {
-	FluentPort       int           `json:"fluent_port"`
-	FluentHost       string        `json:"fluent_host"`
-	FluentNetwork    string        `json:"fluent_network"`
-	FluentSocketPath string        `json:"fluent_socket_path"`
-	Timeout          time.Duration `json:"timeout"`
-	WriteTimeout     time.Duration `json:"write_timeout"`
-	BufferLimit      int           `json:"buffer_limit"`
-	RetryWait        int           `json:"retry_wait"`
-	MaxRetry         int           `json:"max_retry"`
-	MaxRetryWait     int           `json:"max_retry_wait"`
-	TagPrefix        string        `json:"tag_prefix"`
-	Async            bool          `json:"async"`
-	AsyncStop        bool          `json:"async_stop"`
+	FluentPort         int           `json:"fluent_port"`
+	FluentHost         string        `json:"fluent_host"`
+	FluentNetwork      string        `json:"fluent_network"`
+	FluentSocketPath   string        `json:"fluent_socket_path"`
+	Timeout            time.Duration `json:"timeout"`
+	WriteTimeout       time.Duration `json:"write_timeout"`
+	BufferLimit        int           `json:"buffer_limit"`
+	RetryWait          int           `json:"retry_wait"`
+	MaxRetry           int           `json:"max_retry"`
+	MaxRetryWait       int           `json:"max_retry_wait"`
+	TagPrefix          string        `json:"tag_prefix"`
+	Async              bool          `json:"async"`
+	ForceStopAsyncSend bool          `json:"force_stop_async_send"`
 	// Deprecated: Use Async instead
 	AsyncConnect  bool `json:"async_connect"`
 	MarshalAsJSON bool `json:"marshal_as_json"`
@@ -307,7 +307,7 @@ func (f *Fluent) EncodeData(tag string, tm time.Time, message interface{}) (msg
 // Close closes the connection, waiting for pending logs to be sent
 func (f *Fluent) Close() (err error) {
 	if f.Config.Async {
-		if f.Config.AsyncStop {
+		if f.Config.ForceStopAsyncSend {
 			f.stopRunning <- true
 			close(f.stopRunning)
 		}
@@ -360,7 +360,7 @@ func (f *Fluent) run() {
 			if stopRunning || !ok {
 				drainEvents = true
 			}
-default:
+		default:
 		}
 		select {
 		case entry, ok := <-f.pending:

fluent/fluent_test.go

@@ -249,19 +249,19 @@ func TestJsonConfig(t *testing.T) {
 	}
 	var got Config
 	expect := Config{
-		FluentPort:       8888,
-		FluentHost:       "localhost",
-		FluentNetwork:    "tcp",
-		FluentSocketPath: "/var/tmp/fluent.sock",
-		Timeout:          3000,
-		WriteTimeout:     6000,
-		BufferLimit:      10,
-		RetryWait:        5,
-		MaxRetry:         3,
-		TagPrefix:        "fluent",
-		Async:            false,
-		AsyncStop:        false,
-		MarshalAsJSON:    true,
+		FluentPort:         8888,
+		FluentHost:         "localhost",
+		FluentNetwork:      "tcp",
+		FluentSocketPath:   "/var/tmp/fluent.sock",
+		Timeout:            3000,
+		WriteTimeout:       6000,
+		BufferLimit:        10,
+		RetryWait:          5,
+		MaxRetry:           3,
+		TagPrefix:          "fluent",
+		Async:              false,
+		ForceStopAsyncSend: false,
+		MarshalAsJSON:      true,
 	}
 
 	err = json.Unmarshal(b, &got)

fluent/testdata/config.json

@@ -10,6 +10,6 @@
   "max_retry":3,
   "tag_prefix":"fluent",
   "async": false,
-  "async_stop": false,
+  "force_stop_async_send": false,
   "marshal_as_json": true
 }