resolver: Read endpoint slice from config

Signed-off-by: Evgenii Baidakov <[email protected]>

CHANGELOG.md

@@ -4,6 +4,23 @@ This document outlines major changes between releases.
 
 ## [Unreleased]
 
+### Changed
+- Single `rpc_endpoint` config option replaced with multiple endpoints `fschain.endpoints` option (#968)
+
+### Updating from 0.30.1
+
+Notice that the configuration parameter `fschain.endpoints` contains multiple endpoints.
+For migration, you should update config from old notation
+```yaml
+rpc_endpoint: http://some-host:30333
+```
+to the new one
+```yaml
+fschain:
+  endpoints:
+    - http://some-host:30333
+```
+
 ## [0.30.1] - 2024-06-19
 
 ### Added

cmd/s3-gw/app.go

@@ -223,11 +223,11 @@ func (a *App) initMetrics() {
 }
 
 func (a *App) initResolver(ctx context.Context) {
-	endpoint := a.cfg.GetString(cfgRPCEndpoint)
+	endpoints := a.cfg.GetStringSlice(cfgRPCEndpoints)
 
-	a.log.Info("rpc endpoint", zap.String("address", endpoint))
+	a.log.Info("rpc endpoints", zap.Strings("address", endpoints))
 
-	res, err := resolver.NewContainer(ctx, []string{endpoint})
+	res, err := resolver.NewContainer(ctx, endpoints)
 	if err != nil {
 		a.log.Fatal("resolver", zap.Error(err))
 	}
@@ -496,7 +496,7 @@ func (a *App) configReload(ctx context.Context) {
 		return
 	}
 
-	if err := a.resolverContainer.UpdateResolvers(ctx, []string{a.cfg.GetString(cfgRPCEndpoint)}); err != nil {
+	if err := a.resolverContainer.UpdateResolvers(ctx, a.cfg.GetStringSlice(cfgRPCEndpoints)); err != nil {
 		a.log.Warn("failed to update resolvers", zap.Error(err))
 	}
 

cmd/s3-gw/app_settings.go

@@ -106,7 +106,7 @@ const ( // Settings.
 	cfgTreeServiceEndpoint = "tree.service"
 
 	// NeoGo.
-	cfgRPCEndpoint = "rpc_endpoint"
+	cfgRPCEndpoints = "fschain.endpoints"
 
 	// Application.
 	cfgApplicationBuildTime = "app.build_time"
@@ -237,7 +237,7 @@ func newSettings() *viper.Viper {
 
 	peers := flags.StringArrayP(cfgPeers, "p", nil, "set NeoFS nodes")
 
-	flags.StringP(cfgRPCEndpoint, "r", "", "set RPC endpoint")
+	flags.StringP(cfgRPCEndpoints, "r", "", "set RPC endpoints")
 
 	domains := flags.StringSliceP(cfgListenDomains, "d", nil, "set domains to be listened")
 
@@ -356,7 +356,7 @@ func bindFlags(v *viper.Viper, flags *pflag.FlagSet) error {
 	if err := v.BindPFlag(cfgMaxClientsDeadline, flags.Lookup(cfgMaxClientsDeadline)); err != nil {
 		return err
 	}
-	if err := v.BindPFlag(cfgRPCEndpoint, flags.Lookup(cfgRPCEndpoint)); err != nil {
+	if err := v.BindPFlag(cfgRPCEndpoints, flags.Lookup(cfgRPCEndpoints)); err != nil {
 		return err
 	}
 

config/config.yaml

@@ -49,7 +49,9 @@ tree:
   service: node1.neofs:8080
 
 # RPC endpoint and order of resolving of bucket names
-rpc_endpoint: http://morph-chain.neofs.devenv:30333
+fschain:
+  endpoints:
+    - http://morph-chain.neofs.devenv:30333
 
 # Metrics
 pprof: