app/config: load nats connect timeout from env var

metal-toolbox · Jun 1, 2023 · 5a5773e · 5a5773e
1 parent e9636ad
commit 5a5773e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/app/config.go b/internal/app/config.go
@@ -240,6 +240,10 @@ func (a *App) envVarNatsOverrides() error {
 		return errors.New("missing parameter: nats.consumer.filterSubject")
 	}
 
+	if a.v.GetDuration("nats.connect.timeout") != 0 {
+		a.Config.NatsOptions.ConnectTimeout = a.v.GetDuration("nats.connect.timeout")
+	}
+
 	if a.Config.NatsOptions.ConnectTimeout == 0 {
 		a.Config.NatsOptions.ConnectTimeout = defaultNatsConnectTimeout
 	}