A Fluentd Handler for slog Go library.
See also:
slog.Handler
chaining, fanout, routing, failover, load balancing...slog
attribute formattingslog
sampling policyslog
loggerslog
loggerslog
loggerslog
handler for Datadog
slog
handler for Rollbar
slog
handler for Sentry
slog
handler for Syslog
slog
handler for Logstash
slog
handler for Fluentd
slog
handler for Graylog
slog
handler for Loki
slog
handler for Slack
slog
handler for Telegram
slog
handler for Mattermost
slog
handler for Microsoft Teams
slog
handler for Webhook
slog
handler for Kafka
go get github.com/samber/slog-fluentd
Compatibility: go >= 1.21
No breaking changes will be made to exported APIs before v2.0.0.
💡 UsageGoDoc: https://pkg.go.dev/github.com/samber/slog-fluentd
Fluentd settings<source>
@type forward
bind 0.0.0.0
port 24224
</source>
Handler options
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"
"log/slog"
)
func main() {
// docker-compose up -d
client, err := fluent.New(fluent.Config{
FluentHost: "localhost",
FluentPort: 24224,
FluentNetwork: "tcp",
MarshalAsJSON: true,
})
if err != nil {
log.Fatal(err.Error())
}
logger := slog.New(
slogfluentd.Option{
Level: slog.LevelDebug,
Client: client,
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"
}
}
}
🤝 Contributing
Don't hesitate ;)
# Install some dev dependencies
make tools
# Run tests
make test
# or
make watch-test
👤 Contributors
💫 Show your support
Give a ⭐️ if this project helped you!
📝 LicenseCopyright © 2023 Samuel Berthe.
This project is MIT licensed.
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4