50822600ad
- Added Redis Streams operations to the message bus interface and implementation. - Introduced StreamCheckpoint model to track last processed stream entry per document. - Implemented UpsertStreamCheckpoint and GetStreamCheckpoint methods in the Postgres store. - Created document_update_history table for storing update payloads for recovery and replay. - Developed update persist worker to handle Redis Stream updates and persist them to Postgres. - Enhanced Docker Compose configuration for Redis with persistence. - Updated frontend API to support fetching document state with optional share token. - Added connection stability monitoring in the Yjs document hook.
42 lines
1.1 KiB
Go
42 lines
1.1 KiB
Go
package logger
|
|
|
|
import (
|
|
"os"
|
|
|
|
"go.uber.org/zap"
|
|
"go.uber.org/zap/zapcore"
|
|
)
|
|
|
|
// NewLogger creates a production-grade logger with appropriate configuration
|
|
func NewLogger(isDevelopment bool) (*zap.Logger, error) {
|
|
var config zap.Config
|
|
|
|
if isDevelopment {
|
|
config = zap.NewDevelopmentConfig()
|
|
config.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder
|
|
} else {
|
|
config = zap.NewProductionConfig()
|
|
config.EncoderConfig.TimeKey = "timestamp"
|
|
config.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
|
|
}
|
|
|
|
// 👇 关键修改：直接拉到 Fatal 级别
|
|
// 这样 Error, Warn, Info, Debug 全部都会被忽略
|
|
// 彻底消除 IO 锁竞争
|
|
config.Level = zap.NewAtomicLevelAt(zapcore.InfoLevel)
|
|
|
|
logger, err := config.Build()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return logger, nil
|
|
}
|
|
|
|
// NewLoggerFromEnv creates logger based on environment
|
|
func NewLoggerFromEnv() (*zap.Logger, error) {
|
|
env := os.Getenv("ENVIRONMENT")
|
|
isDev := env == "" || env == "development" || env == "dev"
|
|
return NewLogger(isDev)
|
|
}
|