From 206f7979325e4b4f7c59e3445b8ebf7e58f31319 Mon Sep 17 00:00:00 2001 From: Samuel Attwood Date: Tue, 21 Jan 2025 05:44:33 -0500 Subject: [PATCH] Create configured cache dir if DNE --- cmd/jetstream-controller/main.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/cmd/jetstream-controller/main.go b/cmd/jetstream-controller/main.go index e58ff7ce..0d9d34d4 100644 --- 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)