A Fluentd Handler for slog Go library.
See also:
- slog-multi:
slog.Handlerchaining, fanout, routing, failover, load balancing... - slog-formatter:
slogattribute formatting - slog-sampling:
slogsampling policy - slog-gin: Gin middleware for
sloglogger - slog-echo: Echo middleware for
sloglogger - slog-fiber: Fiber middleware for
sloglogger - slog-datadog: A
sloghandler forDatadog - slog-rollbar: A
sloghandler forRollbar - slog-sentry: A
sloghandler forSentry - slog-syslog: A
sloghandler forSyslog - slog-logstash: A
sloghandler forLogstash - slog-fluentd: A
sloghandler forFluentd - slog-graylog: A
sloghandler forGraylog - slog-loki: A
sloghandler forLoki - slog-slack: A
sloghandler forSlack - slog-telegram: A
sloghandler forTelegram - slog-mattermost: A
sloghandler forMattermost - slog-microsoft-teams: A
sloghandler forMicrosoft Teams - slog-webhook: A
sloghandler forWebhook - slog-kafka: A
sloghandler forKafka
go get github.com/samber/slog-fluentdCompatibility: go >= 1.20.3
This library is v0 and follows SemVer strictly. On slog final release (go 1.21), this library will go v1.
No breaking changes will be made to exported APIs before v1.0.0.
GoDoc: https://pkg.go.dev/github.com/samber/slog-fluentd
type Option struct {
// log level (default: debug)
Level slog.Leveler
// connection to Fluentd
Client *fluentd.Fluentd
Tag string
// optional: customize json payload builder
Converter Converter
}Attributes will be injected in log payload.
Fluentd tag can be inserted in logger options or in a record attribute of type string.
import (
"github.com/fluent/fluent-logger-golang/fluent"
slogfluentd "github.com/samber/slog-fluentd"
"golang.org/x/exp/slog"
)
func main() {
// docker-compose up -d
client, err := fluent.New(fluent.Config{
FluentHost: "localhost",
FluentPort: 24224,
FluentNetwork: "tcp",
})
if err != nil {
log.Fatal(err.Error())
}
logger := slog.New(slogfluentd.Option{Level: slog.LevelDebug, Conn: conn, Tag: "api"}.NewFluentdHandler())
logger = logger.
With("environment", "dev").
With("release", "v1.0.0")
// log error
logger.
With("tag", "api.sql").
With("query.statement", "SELECT COUNT(*) FROM users;").
With("query.duration", 1*time.Second).
With("error", fmt.Errorf("could not count users")).
Error("caramba!")
// log user signup
logger.
With(
slog.Group("user",
slog.String("id", "user-123"),
slog.Time("created_at", time.Now()),
),
).
Info("user registration")
}Output:
// tag: api.sql
{
"timestamp":"2023-04-10T14:00:0.000000+00:00",
"level":"ERROR",
"message":"caramba!",
"tag":"api.sql",
"error":{
"error":"could not count users",
"kind":"*errors.errorString",
"stack":null
},
"extra":{
"environment":"dev",
"release":"v1.0.0",
"query.statement":"SELECT COUNT(*) FROM users;",
"query.duration": "1s"
}
}
// tag: api
{
"timestamp":"2023-04-10T14:00:0.000000+00:00",
"level":"INFO",
"message":"user registration",
"tag":"api",
"error":null,
"extra":{
"environment":"dev",
"release":"v1.0.0",
"user":{
"id":"user-123",
"created_at":"2023-04-10T14:00:0.000000+00:00"
}
}
}- Ping me on twitter @samuelberthe (DMs, mentions, whatever :))
- Fork the project
- Fix open issues or request new features
Don't hesitate ;)
# Install some dev dependencies
make tools
# Run tests
make test
# or
make watch-testGive a ⭐️ if this project helped you!
Copyright © 2023 Samuel Berthe.
This project is MIT licensed.