/
volume.go
42 lines (36 loc) · 1.18 KB
/
volume.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package utils
import (
"fmt"
"os"
"strings"
corev1 "k8s.io/api/core/v1"
)
type VolumeReader struct {
secretPath string
}
func NewVolumeReader(secretPath string) *VolumeReader {
return &VolumeReader{
secretPath: secretPath,
}
}
// GetSecretFromVolume retrieves the value of mounted secret volume
func (vr *VolumeReader) GetSecretFromVolume(selector *corev1.SecretKeySelector) (string, error) {
filePath, err := vr.GetSecretVolumePath(selector)
if err != nil {
return "", err
}
data, err := os.ReadFile(filePath)
if err != nil {
return "", fmt.Errorf("failed to get secret value of name: %s, key: %s, %w", selector.Name, selector.Key, err)
}
// Secrets edited by tools like "vim" always have an extra invisible "\n" in the end,
// and it's often neglected, but it makes differences for some applications.
return strings.TrimSuffix(string(data), "\n"), nil
}
// GetSecretVolumePath returns the path of the mounted secret
func (vr *VolumeReader) GetSecretVolumePath(selector *corev1.SecretKeySelector) (string, error) {
if selector == nil {
return "", fmt.Errorf("secret key selector is nil")
}
return fmt.Sprintf("%s/%s/%s", vr.secretPath, selector.Name, selector.Key), nil
}