Added WriteTimeout (100ms)

This commit is contained in:
2025-10-12 19:20:48 +02:00
parent e16021ee49
commit b829092503

View File

@@ -3,6 +3,7 @@ package fluentd
import ( import (
"fmt" "fmt"
"log" "log"
"time"
"github.com/fluent/fluent-logger-golang/fluent" "github.com/fluent/fluent-logger-golang/fluent"
) )
@@ -14,9 +15,9 @@ type Logger struct {
func NewLogger(appName, fHost string, fPort int) (*Logger, error) { func NewLogger(appName, fHost string, fPort int) (*Logger, error) {
config := fluent.Config{ config := fluent.Config{
FluentHost: fHost, FluentHost: fHost,
FluentPort: fPort, FluentPort: fPort,
// WriteTimeout: -1, WriteTimeout: 100 * time.Millisecond,
} }
fluent, err := fluent.New(config) fluent, err := fluent.New(config)
if err != nil { if err != nil {