Kubernetes related configuration.

Author: Otávio Fernandes

pkg/vault-handler/config.go

@@ -13,6 +13,10 @@ type Config struct {
 	VaultToken    string // vault token
 	VaultRoleID   string // vault approle role-id
 	VaultSecretID string // vault approle secret-id
+	InCluster     bool   // kubernetes in-cluster
+	Context       string // kubernetes context
+	Namespace     string // kubernetes namespace
+	KubeConfig    string // kubernetes config
 }
 
 // Validate configuration object.
@@ -35,6 +39,19 @@ func (c *Config) Validate() error {
 	if c.OutputDir != "" && !isDir(c.OutputDir) {
 		return fmt.Errorf("output-dir '%s' is not found", c.OutputDir)
 	}
+	return nil
+}
 
+// ValidateKubernetes configuration related to Kubernetes.
+func (c *Config) ValidateKubernetes() error {
+	if c.InCluster && c.Context != "" {
+		return fmt.Errorf("configuration 'context' cannot be used in combination with 'in-cluster'")
+	}
+	if c.Namespace == "" {
+		return fmt.Errorf("namespace is not informed")
+	}
+	if c.KubeConfig != "" && !fileExists(c.KubeConfig) {
+		return fmt.Errorf("can't find kube-config file at '%s'", c.KubeConfig)
+	}
 	return nil
 }

pkg/vault-handler/config_test.go

@@ -8,6 +8,7 @@ import (
 
 func TestConfigValidate(t *testing.T) {
 	config := &Config{}
+
 	err := config.Validate()
 	assert.NotNil(t, err)
 
@@ -18,3 +19,23 @@ func TestConfigValidate(t *testing.T) {
 	err = config.Validate()
 	assert.Nil(t, err)
 }
+
+func TestConfigValidateKubernetes(t *testing.T) {
+	config := &Config{}
+
+	err := config.ValidateKubernetes()
+	assert.NotNil(t, err)
+
+	config.InCluster = true
+	config.Context = "context"
+
+	err = config.ValidateKubernetes()
+	assert.NotNil(t, err)
+
+	config.InCluster = false
+	config.Namespace = "namespace"
+	config.KubeConfig = "../../test/manifest.yaml"
+
+	err = config.ValidateKubernetes()
+	assert.Nil(t, err)
+}