Adding deprecation message and completed fluent#write error message

alexlry · alexlry · commit 7d967bac2a18 · 2018-04-19T14:29:12.000+02:00
Signed-off-by: alexlry &lt;alexandre@keymantics.com&gt;
diff --git a/fluent/fluent.go b/fluent/fluent.go
@@ -97,6 +97,7 @@ func New(config Config) (f *Fluent, err error) {
 		config.MaxRetryWait = defaultMaxRetryWait
 	}
 	if config.AsyncConnect {
+		fmt.Fprintf(os.Stderr, "fluent#New: AsyncConnect is now deprecated, please use Async instead")
 		config.Async = config.Async || config.AsyncConnect
 	}
 	if config.Async {
@@ -337,5 +338,5 @@ func (f *Fluent) write(data []byte) error {
 		}
 	}
 
-	return errors.New("fluent#write: failed to reconnect")
+	return fmt.Errorf("fluent#write: failed to reconnect, max retry: %v", f.Config.MaxRetry)
 }

Original file line number	Diff line number	Diff line change
`@@ -97,6 +97,7 @@ func New(config Config) (f *Fluent, err error) {`
`97`	`97`	`config.MaxRetryWait = defaultMaxRetryWait`
`98`	`98`	`}`
`99`	`99`	`if config.AsyncConnect {`
	`100`	`+ fmt.Fprintf(os.Stderr, "fluent#New: AsyncConnect is now deprecated, please use Async instead")`
`100`	`101`	`config.Async = config.Async \|\| config.AsyncConnect`
`101`	`102`	`}`
`102`	`103`	`if config.Async {`
`@@ -337,5 +338,5 @@ func (f *Fluent) write(data []byte) error {`
`337`	`338`	`}`
`338`	`339`	`}`
`339`	`340`
`340`		`- return errors.New("fluent#write: failed to reconnect")`
	`341`	`+ return fmt.Errorf("fluent#write: failed to reconnect, max retry: %v", f.Config.MaxRetry)`
`341`	`342`	`}`