docs: updated datafx's README.

Author: eser

connfx/README.md

@@ -44,10 +44,7 @@ import (
 
 func main() {
     // Create logger using logfx
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{
-        Level:      "INFO",
-        PrettyMode: true,
-    })
+    logger := logfx.NewLoggerWithDefaults()
 
     // Create connection registry
     registry := connfx.NewRegistryWithDefaults(logger)

datafx/README.md

@@ -23,35 +23,27 @@ datafx depends on connfx for connection management. You configure connections th
 ### Connection Configuration (via connfx)
 
 ```go
-// Redis configuration example
+// Redis/Valkey configuration example
 redisConfig := &connfx.ConfigTarget{
     Protocol: "redis",
-    Host:     "localhost",
-    Port:     6379,
     DSN:      "redis://localhost:6379",
 }
 
 // PostgreSQL configuration example
 postgresConfig := &connfx.ConfigTarget{
     Protocol: "postgres",
-    Host:     "localhost",
-    Port:     5432,
     DSN:      "postgres://user:pass@localhost:5432/dbname",
 }
 
 // MongoDB configuration example
 mongoConfig := &connfx.ConfigTarget{
     Protocol: "mongodb",
-    Host:     "localhost",
-    Port:     27017,
     DSN:      "mongodb://localhost:27017/mydb",
 }
 
 // AMQP/RabbitMQ configuration example
 amqpConfig := &connfx.ConfigTarget{
     Protocol: "amqp",
-    Host:     "localhost",
-    Port:     5672,
     DSN:      "amqp://guest:guest@localhost:5672/",
 }
 ```
@@ -78,10 +70,10 @@ type Product struct {
 
 // Example message types for queues
 type OrderEvent struct {
-    OrderID   string    `json:"order_id"`
-    CustomerID string   `json:"customer_id"`
-    Amount    float64   `json:"amount"`
-    Timestamp time.Time `json:"timestamp"`
+    OrderID    string    `json:"order_id"`
+    CustomerID string    `json:"customer_id"`
+    Amount     float64   `json:"amount"`
+    Timestamp  time.Time `json:"timestamp"`
 }
 
 type NotificationMessage struct {
@@ -121,14 +113,12 @@ func main() {
     ctx := context.Background()
 
     // Setup connection registry
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: logfx.LevelInfo})
+    logger := logfx.NewLoggerWithDefaults()
     registry := connfx.NewRegistryWithDefaults(logger)
 
     // Configure connection
     config := &connfx.ConfigTarget{
         Protocol: "redis",
-        Host:     "localhost",
-        Port:     6379,
         DSN:      "redis://localhost:6379",
     }
 
@@ -323,7 +313,7 @@ func main() {
     ctx := context.Background()
 
     // Setup connection registry
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: logfx.LevelInfo})
+    logger := logfx.NewLoggerWithDefaults()
     registry := connfx.NewRegistryWithDefaults(logger)
 
     // Configure AMQP connection

httpfx/http_service_test.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"net"
 	"net/http"
-	"os"
 	"testing"
 	"time"
 
@@ -86,7 +85,7 @@ func TestNewHTTPService(t *testing.T) { //nolint:funlen
 		t.Run(tt.name, func(t *testing.T) {
 			t.Parallel()
 
-			logger := logfx.NewLogger(os.Stdout, &logfx.Config{}) //nolint:exhaustruct
+			logger := logfx.NewLoggerWithDefaults()
 
 			router := httpfx.NewRouter("/")
 			metricsProvider := setupTestMetricsProvider(t)
@@ -121,7 +120,7 @@ func TestNewHTTPService(t *testing.T) { //nolint:funlen
 func TestHTTPService_Start(t *testing.T) { //nolint:funlen
 	t.Parallel()
 
-	logger := logfx.NewLogger(os.Stdout, &logfx.Config{}) //nolint:exhaustruct
+	logger := logfx.NewLoggerWithDefaults()
 
 	router := httpfx.NewRouter("/")
 	metricsProvider := setupTestMetricsProvider(t)

logfx/level.go

@@ -24,6 +24,8 @@ const (
 	LevelPanic slog.Level = slog.Level(16)
 )
 
+const DefaultLogLevel = "INFO"
+
 func LevelEncoder(l slog.Level) string {
 	str := func(base string, val slog.Level) string {
 		if val == 0 {

logfx/logger.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"io"
 	"log/slog"
+	"os"
 )
 
 type Logger struct {
@@ -26,17 +27,20 @@ func NewLogger(w io.Writer, config *Config) *Logger {
 	return logger
 }
 
-func NewLoggerAsDefault(w io.Writer, config *Config) *Logger {
-	logger := NewLogger(w, config)
-	slog.SetDefault(logger.Logger)
-
-	return logger
+func NewLoggerWithDefaults() *Logger {
+	return NewLogger(os.Stdout, &Config{ //nolint:exhaustruct
+		Level: DefaultLogLevel,
+	})
 }
 
 func NewLoggerFromSlog(slog *slog.Logger) *Logger {
 	return &Logger{Logger: slog}
 }
 
+func (l *Logger) SetAsDefault() {
+	slog.SetDefault(l.Logger)
+}
+
 // Trace logs at [LevelTrace].
 func (l *Logger) Trace(msg string, args ...any) {
 	l.Log(context.Background(), LevelTrace, msg, args...)

processfx/README.md

@@ -30,7 +30,7 @@ import (
 
 func main() {
     ctx := context.Background()
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: "info"})
+    logger := logfx.NewLoggerWithDefaults()
 
     // Create process manager
     process := processfx.New(ctx, logger)
@@ -73,7 +73,7 @@ func main() {
 ```go
 func main() {
     ctx := context.Background()
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: "info"})
+    logger := logfx.NewLoggerWithDefaults()
 
     process := processfx.New(ctx, logger)
 
@@ -204,7 +204,7 @@ ProcessFX automatically handles these OS signals:
 ```go
 func runApplication() {
     ctx := context.Background()
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: "info"})
+    logger := logfx.NewLoggerWithDefaults()
 
     process := processfx.New(ctx, logger)
 
@@ -264,7 +264,7 @@ func runApplication() {
 ```go
 func runWithDatabase() {
     ctx := context.Background()
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: "info"})
+    logger := logfx.NewLoggerWithDefaults()
 
     process := processfx.New(ctx, logger)
 
@@ -309,7 +309,7 @@ func runWithDatabase() {
 ```go
 func runHTTPServer() {
     ctx := context.Background()
-    logger := logfx.NewLogger(os.Stdout, &logfx.Config{Level: "info"})
+    logger := logfx.NewLoggerWithDefaults()
 
     process := processfx.New(ctx, logger)
 

sampleapp/README.md

@@ -292,7 +292,8 @@ The application uses structured logging with LogFX:
 
 ```go
 // Create logger with configuration
-logger := logfx.NewLoggerAsDefault(os.Stdout, &config.Log)
+logger := logfx.NewLogger(os.Stdout, &config.Log)
+logger.SetAsDefault()
 
 // Use throughout the application
 logger.Info("Application started",

sampleapp/appcontext.go

@@ -36,7 +36,8 @@ func NewAppContext(ctx context.Context) (*AppContext, error) {
 	}
 
 	// logger
-	appContext.Logger = logfx.NewLoggerAsDefault(os.Stdout, &appContext.Config.Log)
+	appContext.Logger = logfx.NewLogger(os.Stdout, &appContext.Config.Log)
+	appContext.Logger.SetAsDefault()
 
 	// metrics
 	appContext.Metrics = metricsfx.NewMetricsProvider(appContext.Metrics)