Create configured cache dir if DNE

nats-io · Jan 21, 2025 · 206f797 · 206f797
1 parent 4e441c2
commit 206f797
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/cmd/jetstream-controller/main.go b/cmd/jetstream-controller/main.go
@@ -182,6 +182,13 @@ func runControlLoop(config *rest.Config, natsCfg *controller.NatsConfig, control
 		}
 		defer os.RemoveAll(cacheDir)
 		controllerCfg.CacheDir = cacheDir
+	} else {
+		if _, err := os.Stat(controllerCfg.CacheDir); os.IsNotExist(err) {
+			err = os.MkdirAll(controllerCfg.CacheDir, 0o755)
+			if err != nil {
+				return fmt.Errorf("create cache dir: %w", err)
+			}
+		}
 	}
 
 	err = controller.RegisterAll(mgr, natsCfg, controllerCfg)