support access key override in options (#12)

Author: bivas

README.md

@@ -48,6 +48,7 @@ spec:
       options:
         container: bigdata      # data container name
         cluster: default        # which cluster to connect to (optional, default to "default")
+        accessKey: some-some    # data access key (optional)
 ---
 apiVersion: v1
 kind: Secret

pkg/flex/mounter.go

@@ -134,7 +134,7 @@ func (m *Mounter) Unmount() *Response {
 }
 
 func (m *Mounter) validate() error {
-	if m.Spec.AccessKey == "" {
+	if m.Spec.AccessKey == "" && m.Spec.OverrideAccessKey == "" {
 		return errors.New("required access key is missing")
 	}
 	if m.Spec.SubPath != "" && m.Spec.Container == "" {

pkg/flex/types.go

@@ -81,13 +81,14 @@ func (r *Response) ToJSON() {
 }
 
 type VolumeSpec struct {
-	SubPath   string `json:"subPath"`
-	Container string `json:"container"`
-	Cluster   string `json:"cluster"`
-	AccessKey string `json:"kubernetes.io/secret/accessKey"`
-	PodName   string `json:"kubernetes.io/pod.name"`
-	Namespace string `json:"kubernetes.io/pod.namespace"`
-	Name      string `json:"kubernetes.io/pvOrVolumeName"`
+	SubPath           string `json:"subPath"`
+	Container         string `json:"container"`
+	Cluster           string `json:"cluster"`
+	OverrideAccessKey string `json:"accessKey"`
+	AccessKey         string `json:"kubernetes.io/secret/accessKey"`
+	PodName           string `json:"kubernetes.io/pod.name"`
+	Namespace         string `json:"kubernetes.io/pod.namespace"`
+	Name              string `json:"kubernetes.io/pvOrVolumeName"`
 }
 
 func (VolumeSpec) decodeOrDefault(value string) string {
@@ -99,7 +100,10 @@ func (VolumeSpec) decodeOrDefault(value string) string {
 }
 
 func (vs *VolumeSpec) GetAccessKey() string {
-	return vs.decodeOrDefault(vs.AccessKey)
+	if vs.OverrideAccessKey == "" {
+		return vs.decodeOrDefault(vs.AccessKey)
+	}
+	return vs.OverrideAccessKey
 }
 
 func (vs *VolumeSpec) GetClusterName() string {