av
41f2f05f2f
- POST /api/v1/ingest: токен, лимит тела, gzip, durable-запись тела в сырой архив, учёт доставки в SQLite - код ответа отражает доставку, а не разбор: битый JSON — 400, непонятое содержимое — 200, данные уже сохранены и доразберутся позже - сохраняется полный набор заголовков запроса с вычисткой секретов по имени и по совпадению значения с токеном
53 lines
1.6 KiB
Go
53 lines
1.6 KiB
Go
// Package logging собирает slog-логгер по настройкам из конфига.
|
|
package logging
|
|
|
|
import (
|
|
"log/slog"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
// New возвращает slog-логгер с указанным уровнем и форматом ("json"|"text").
|
|
func New(level, format string) *slog.Logger {
|
|
opts := &slog.HandlerOptions{Level: parseLevel(level), ReplaceAttr: utcTime}
|
|
|
|
var handler slog.Handler
|
|
if strings.EqualFold(format, "text") {
|
|
handler = slog.NewTextHandler(os.Stdout, opts)
|
|
} else {
|
|
handler = slog.NewJSONHandler(os.Stdout, opts)
|
|
}
|
|
return slog.New(handler)
|
|
}
|
|
|
|
// NewStderr — JSON-логгер в stderr (UTC) для фатальных ошибок старта, когда
|
|
// основной логгер ещё не собран (конфиг не прочитан).
|
|
func NewStderr() *slog.Logger {
|
|
return slog.New(slog.NewJSONHandler(os.Stderr, &slog.HandlerOptions{ReplaceAttr: utcTime}))
|
|
}
|
|
|
|
// utcTime приводит метку времени записи к UTC: однозначный порядок событий и
|
|
// лексикографическая сортировка.
|
|
func utcTime(groups []string, a slog.Attr) slog.Attr {
|
|
if len(groups) == 0 && a.Key == slog.TimeKey {
|
|
if t, ok := a.Value.Any().(time.Time); ok {
|
|
a.Value = slog.TimeValue(t.UTC())
|
|
}
|
|
}
|
|
return a
|
|
}
|
|
|
|
func parseLevel(level string) slog.Level {
|
|
switch strings.ToLower(level) {
|
|
case "debug":
|
|
return slog.LevelDebug
|
|
case "warn", "warning":
|
|
return slog.LevelWarn
|
|
case "error":
|
|
return slog.LevelError
|
|
default:
|
|
return slog.LevelInfo
|
|
}
|
|
}
|