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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
package funcs
import (
"context"
"sync"
"github.com/hairyhenderson/gomplate/v3/aws"
"github.com/hairyhenderson/gomplate/v3/conv"
)
// AWSNS - the aws namespace
// Deprecated: don't use
//nolint:golint
func AWSNS() *Funcs {
return &Funcs{}
}
// AWSFuncs -
// Deprecated: use CreateAWSFuncs instead
func AWSFuncs(f map[string]interface{}) {
f2 := CreateAWSFuncs(context.Background())
for k, v := range f2 {
f[k] = v
}
}
// CreateAWSFuncs -
func CreateAWSFuncs(ctx context.Context) map[string]interface{} {
f := map[string]interface{}{}
ns := &Funcs{
ctx: ctx,
awsopts: aws.GetClientOptions(),
}
f["aws"] = func() interface{} { return ns }
// global aliases - for backwards compatibility
f["ec2meta"] = ns.EC2Meta
f["ec2dynamic"] = ns.EC2Dynamic
f["ec2tag"] = ns.EC2Tag
f["ec2tags"] = ns.EC2Tags
f["ec2region"] = ns.EC2Region
return f
}
// Funcs -
type Funcs struct {
ctx context.Context
meta *aws.Ec2Meta
info *aws.Ec2Info
kms *aws.KMS
sts *aws.STS
metaInit sync.Once
infoInit sync.Once
kmsInit sync.Once
stsInit sync.Once
awsopts aws.ClientOptions
}
// EC2Region -
func (a *Funcs) EC2Region(def ...string) (string, error) {
a.metaInit.Do(a.initMeta)
return a.meta.Region(def...)
}
// EC2Meta -
func (a *Funcs) EC2Meta(key string, def ...string) (string, error) {
a.metaInit.Do(a.initMeta)
return a.meta.Meta(key, def...)
}
// EC2Dynamic -
func (a *Funcs) EC2Dynamic(key string, def ...string) (string, error) {
a.metaInit.Do(a.initMeta)
return a.meta.Dynamic(key, def...)
}
// EC2Tag -
func (a *Funcs) EC2Tag(tag string, def ...string) (string, error) {
a.infoInit.Do(a.initInfo)
return a.info.Tag(tag, def...)
}
// EC2Tag -
func (a *Funcs) EC2Tags() (map[string]string, error) {
a.infoInit.Do(a.initInfo)
return a.info.Tags()
}
// KMSEncrypt -
func (a *Funcs) KMSEncrypt(keyID, plaintext interface{}) (string, error) {
a.kmsInit.Do(a.initKMS)
return a.kms.Encrypt(conv.ToString(keyID), conv.ToString(plaintext))
}
// KMSDecrypt -
func (a *Funcs) KMSDecrypt(ciphertext interface{}) (string, error) {
a.kmsInit.Do(a.initKMS)
return a.kms.Decrypt(conv.ToString(ciphertext))
}
// UserID - Gets the unique identifier of the calling entity. The exact value
// depends on the type of entity making the call. The values returned are those
// listed in the aws:userid column in the Principal table
// (http://docs.aws.amazon.com/IAM/latest/UserGuide/reference_policies_variables.html#principaltable)
// found on the Policy Variables reference page in the IAM User Guide.
func (a *Funcs) UserID() (string, error) {
a.stsInit.Do(a.initSTS)
return a.sts.UserID()
}
// Account - Gets the AWS account ID number of the account that owns or
// contains the calling entity.
func (a *Funcs) Account() (string, error) {
a.stsInit.Do(a.initSTS)
return a.sts.Account()
}
// ARN - Gets the AWS ARN associated with the calling entity
func (a *Funcs) ARN() (string, error) {
a.stsInit.Do(a.initSTS)
return a.sts.Arn()
}
func (a *Funcs) initMeta() {
if a.meta == nil {
a.meta = aws.NewEc2Meta(a.awsopts)
}
}
func (a *Funcs) initInfo() {
if a.info == nil {
a.info = aws.NewEc2Info(a.awsopts)
}
}
func (a *Funcs) initKMS() {
if a.kms == nil {
a.kms = aws.NewKMS(a.awsopts)
}
}
func (a *Funcs) initSTS() {
if a.sts == nil {
a.sts = aws.NewSTS(a.awsopts)
}
}
|
