51 lines
2 KiB
Go
51 lines
2 KiB
Go
package lh
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"github.com/olekukonko/ll/lx"
|
|
)
|
|
|
|
// MultiHandler combines multiple handlers to process log entries concurrently.
|
|
// It holds a list of lx.Handler instances and delegates each log entry to all handlers,
|
|
// collecting any errors into a single combined error.
|
|
// Thread-safe if the underlying handlers are thread-safe.
|
|
type MultiHandler struct {
|
|
Handlers []lx.Handler // List of handlers to process each log entry
|
|
}
|
|
|
|
// NewMultiHandler creates a new MultiHandler with the specified handlers.
|
|
// It accepts a variadic list of handlers to be executed in order.
|
|
// The returned handler processes log entries by passing them to each handler in sequence.
|
|
// Example:
|
|
//
|
|
// textHandler := NewTextHandler(os.Stdout)
|
|
// jsonHandler := NewJSONHandler(os.Stdout)
|
|
// multi := NewMultiHandler(textHandler, jsonHandler)
|
|
// logger := ll.New("app").Enable().Handler(multi)
|
|
// logger.Info("Test") // Processed by both text and JSON handlers
|
|
func NewMultiHandler(h ...lx.Handler) *MultiHandler {
|
|
return &MultiHandler{
|
|
Handlers: h, // Initialize with provided handlers
|
|
}
|
|
}
|
|
|
|
// Handle implements the Handler interface, calling Handle on each handler in sequence.
|
|
// It collects any errors from handlers and combines them into a single error using errors.Join.
|
|
// If no errors occur, it returns nil. Thread-safe if the underlying handlers are thread-safe.
|
|
// Example:
|
|
//
|
|
// multi.Handle(&lx.Entry{Message: "test", Level: lx.LevelInfo}) // Calls Handle on all handlers
|
|
func (h *MultiHandler) Handle(e *lx.Entry) error {
|
|
var errs []error // Collect errors from handlers
|
|
for i, handler := range h.Handlers {
|
|
// Process entry with each handler
|
|
if err := handler.Handle(e); err != nil {
|
|
// fmt.Fprintf(os.Stderr, "MultiHandler error for handler %d: %v\n", i, err)
|
|
// Wrap error with handler index for context
|
|
errs = append(errs, fmt.Errorf("handler %d: %w", i, err))
|
|
}
|
|
}
|
|
// Combine errors into a single error, or return nil if no errors
|
|
return errors.Join(errs...)
|
|
}
|