logger: add encoding config option (#2999)

Closes #2982.
nspcc-dev · Nov 6, 2024 · bfe1c70 · bfe1c70
2 parents c8137af + 4bf94da
commit bfe1c70
Show file tree

Hide file tree

Showing 15 changed files with 51 additions and 13 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -17,6 +17,7 @@ attribute, which is used for container domain name in NNS contracts (#2954)
 - `neofs-cli control object revive` command (#2968)
 - `--disable-auto-gen-tag` flag for gendoc command (#2983)
 - Docs files for cli commands to the `docs/cli-commands` folder (#2983)
+- `logger.encoding` config option (#2999)
 
 ### Fixed
 - Do not search for tombstones when handling their expiration, use local indexes instead (#2929)

diff --git a/cmd/neofs-ir/defaults.go b/cmd/neofs-ir/defaults.go
@@ -45,6 +45,7 @@ func newConfig(path string) (*viper.Viper, error) {
 
 func defaultConfiguration(cfg *viper.Viper) {
 	cfg.SetDefault("logger.level", "info")
+	cfg.SetDefault("logger.encoding", "console")
 
 	cfg.SetDefault("pprof.address", "localhost:6060")
 	cfg.SetDefault("pprof.shutdown_timeout", "30s")

diff --git a/cmd/neofs-ir/internal/validate/config.go b/cmd/neofs-ir/internal/validate/config.go
@@ -4,7 +4,8 @@ import "time"
 
 type validConfig struct {
 	Logger struct {
-		Level string `mapstructure:"level"`
+		Level    string `mapstructure:"level"`
+		Encoding string `mapstructure:"encoding"`
 	} `mapstructure:"logger"`
 
 	Wallet struct {

diff --git a/cmd/neofs-ir/main.go b/cmd/neofs-ir/main.go
@@ -65,7 +65,7 @@ func main() {
 
 	c := zap.NewProductionConfig()
 	c.Level = logLevel
-	c.Encoding = "console"
+	c.Encoding = cfg.GetString("logger.encoding")
 	if term.IsTerminal(int(os.Stdout.Fd())) {
 		c.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
 	} else {

diff --git a/cmd/neofs-node/config.go b/cmd/neofs-node/config.go
@@ -87,7 +87,8 @@ type applicationConfiguration struct {
 	_read bool
 
 	logger struct {
-		level string
+		level    string
+		encoding string
 	}
 
 	engine struct {
@@ -144,6 +145,7 @@ func (a *applicationConfiguration) readConfig(c *config.Config) error {
 	// Logger
 
 	a.logger.level = loggerconfig.Level(c)
+	a.logger.encoding = loggerconfig.Encoding(c)
 
 	// Policer
 
@@ -567,7 +569,7 @@ func initCfg(appCfg *config.Config) *cfg {
 
 	logCfg := zap.NewProductionConfig()
 	logCfg.Level = c.internals.logLevel
-	logCfg.Encoding = "console"
+	logCfg.Encoding = c.logger.encoding
 	if term.IsTerminal(int(os.Stdout.Fd())) {
 		logCfg.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
 	} else {

diff --git a/cmd/neofs-node/config/internal/validate/config.go b/cmd/neofs-node/config/internal/validate/config.go
@@ -6,7 +6,8 @@ import (
 
 type valideConfig struct {
 	Logger struct {
-		Level string `mapstructure:"level"`
+		Level    string `mapstructure:"level"`
+		Encoding string `mapstructure:"encoding"`
 	} `mapstructure:"logger"`
 
 	Pprof struct {

diff --git a/cmd/neofs-node/config/logger/config.go b/cmd/neofs-node/config/logger/config.go
@@ -7,6 +7,9 @@ import (
 const (
 	// LevelDefault is a default logger level.
 	LevelDefault = "info"
+
+	// EncodingDefault is a default logger encoding.
+	EncodingDefault = "console"
 )
 
 // Level returns the value of "level" config parameter
@@ -24,3 +27,19 @@ func Level(c *config.Config) string {
 
 	return LevelDefault
 }
+
+// Encoding returns the value of "encoding" config parameter
+// from "logger" section.
+//
+// Returns EncodingDefault if the value is not a non-empty string.
+func Encoding(c *config.Config) string {
+	v := config.StringSafe(
+		c.Sub("logger"),
+		"encoding",
+	)
+	if v != "" {
+		return v
+	}
+
+	return EncodingDefault
+}
diff --git a/cmd/neofs-node/config/logger/config_test.go b/cmd/neofs-node/config/logger/config_test.go
@@ -11,15 +11,16 @@ import (
 
 func TestLoggerSection_Level(t *testing.T) {
 	t.Run("defaults", func(t *testing.T) {
-		v := loggerconfig.Level(configtest.EmptyConfig())
-		require.Equal(t, loggerconfig.LevelDefault, v)
+		emptyConfig := configtest.EmptyConfig()
+		require.Equal(t, loggerconfig.LevelDefault, loggerconfig.Level(emptyConfig))
+		require.Equal(t, loggerconfig.EncodingDefault, loggerconfig.Encoding(emptyConfig))
 	})
 
 	const path = "../../../../config/example/node"
 
 	var fileConfigTest = func(c *config.Config) {
-		v := loggerconfig.Level(c)
-		require.Equal(t, "debug", v)
+		require.Equal(t, "debug", loggerconfig.Level(c))
+		require.Equal(t, "json", loggerconfig.Encoding(c))
 	}
 
 	configtest.ForEachFileType(path, fileConfigTest)

diff --git a/cmd/neofs-node/validate.go b/cmd/neofs-node/validate.go
@@ -23,6 +23,11 @@ func validateConfig(c *config.Config) error {
 		return fmt.Errorf("invalid logger level: %w", err)
 	}
 
+	logEncoding := loggerconfig.Encoding(c)
+	if logEncoding != "console" && logEncoding != "json" {
+		return fmt.Errorf("invalid logger encoding: %s", logEncoding)
+	}
+
 	// shard configuration validation
 
 	shardNum := 0

diff --git a/config/example/ir.env b/config/example/ir.env
@@ -1,4 +1,5 @@
 NEOFS_IR_LOGGER_LEVEL=info
+NEOFS_IR_LOGGER_ENCODING=console
 
 NEOFS_IR_WALLET_PATH=/path/to/wallet.json
 NEOFS_IR_WALLET_ADDRESS=NUHtW3eM6a4mmFCgyyr4rj4wygsTKB88XX

diff --git a/config/example/ir.yaml b/config/example/ir.yaml
@@ -2,6 +2,7 @@
 
 logger:
   level: info # Logger level: one of "debug", "info" (default), "warn", "error", "dpanic", "panic", "fatal"
+  encoding: console # Logger encoding: one of "console" (default) or "json"
 
 wallet:
   path: /path/to/wallet.json                  # Path to NEP-6 NEO wallet file

diff --git a/config/example/node.env b/config/example/node.env
@@ -1,4 +1,5 @@
 NEOFS_LOGGER_LEVEL=debug
+NEOFS_LOGGER_ENCODING=json
 
 NEOFS_PPROF_ENABLED=true
 NEOFS_PPROF_ADDRESS=localhost:6060

diff --git a/config/example/node.json b/config/example/node.json
@@ -1,6 +1,7 @@
 {
   "logger": {
-    "level": "debug"
+    "level": "debug",
+    "encoding": "json"
   },
   "pprof": {
     "enabled": true,

diff --git a/config/example/node.yaml b/config/example/node.yaml
@@ -1,5 +1,6 @@
 logger:
   level: debug  # logger level: one of "debug", "info" (default), "warn", "error", "dpanic", "panic", "fatal"
+  encoding: json # logger encoding: one of "console" (default) or "json"
 
 pprof:
   enabled: true

diff --git a/docs/storage-node-configuration.md b/docs/storage-node-configuration.md
@@ -101,11 +101,13 @@ Contains logger parameters.
 ```yaml
 logger:
   level: info
+  encoding: console
 ```
 
-| Parameter | Type     | Default value | Description                                                                                       |
-|-----------|----------|---------------|---------------------------------------------------------------------------------------------------|
-| `level`   | `string` | `info`        | Logging level.<br/>Possible values:  `debug`, `info`, `warn`, `error`, `dpanic`, `panic`, `fatal` |
+| Parameter   | Type       | Default value | Description                                                                                       |
+|-------------|------------|---------------|---------------------------------------------------------------------------------------------------|
+| `level`     | `string`   | `info`        | Logging level.<br/>Possible values:  `debug`, `info`, `warn`, `error`, `dpanic`, `panic`, `fatal` |
+| `encoding`  | `string`   | `console`     | Logging encoding.<br/>Possible values: `console`, `json`                                          |
 
 # `contracts` section
 Contains override values for NeoFS side-chain contract hashes. Most of the time contract