diff --git a/cmd/flux/main.go b/cmd/flux/main.go index 1226a347..16e4a01f 100644 --- a/cmd/flux/main.go +++ b/cmd/flux/main.go @@ -205,6 +205,8 @@ func main() { func configureDefaultNamespace() { *kubeconfigArgs.Namespace = rootArgs.defaults.Namespace + + // First the FLUX_SYSTEM_NAMESPACE environment variable fromEnv := os.Getenv("FLUX_SYSTEM_NAMESPACE") if fromEnv != "" { // namespace must be a valid DNS label. Assess against validation @@ -214,8 +216,20 @@ func configureDefaultNamespace() { logger.Warningf(" ignoring invalid FLUX_SYSTEM_NAMESPACE: %q", fromEnv) return } - kubeconfigArgs.Namespace = &fromEnv + return + } + + // If no environment variable, check if we should use the namespace from the current context + if os.Getenv("FLUX_SYSTEM_NAMESPACE_FROM_CONTEXT") == "true" { + // Get the current context's namespace from kubeconfig + config, err := kubeconfigArgs.ToRawKubeConfigLoader().RawConfig() + if err == nil { + if ctx, exists := config.Contexts[config.CurrentContext]; exists && ctx.Namespace != "" { + kubeconfigArgs.Namespace = &ctx.Namespace + return + } + } } }