forked from openfresh/ecs-formation
/
aws.go
69 lines (57 loc) · 1.53 KB
/
aws.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
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
package aws
import (
"time"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/credentials"
"github.com/aws/aws-sdk-go/aws/credentials/ec2rolecreds"
"github.com/aws/aws-sdk-go/aws/ec2metadata"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/autoscaling"
"github.com/aws/aws-sdk-go/service/ecs"
"github.com/aws/aws-sdk-go/service/elb"
"github.com/aws/aws-sdk-go/service/s3"
"github.com/aws/aws-sdk-go/service/sns"
)
type AwsManager struct {
session *session.Session
}
func NewAwsManager(region string) *AwsManager {
sess := session.New()
cred := credentials.NewChainCredentials([]credentials.Provider{
&credentials.EnvProvider{},
&credentials.SharedCredentialsProvider{Filename: "", Profile: ""},
&ec2rolecreds.EC2RoleProvider{
Client: ec2metadata.New(sess),
ExpiryWindow: 5 * time.Minute,
},
})
conf := aws.NewConfig().WithCredentials(cred).WithMaxRetries(aws.UseServiceDefaultRetries).WithRegion(region)
return &AwsManager{
session: session.New(conf),
}
}
func (self *AwsManager) EcsApi() *EcsApi {
return &EcsApi{
service: ecs.New(self.session),
}
}
func (self *AwsManager) ElbApi() *ElbApi {
return &ElbApi{
service: elb.New(self.session),
}
}
func (self *AwsManager) AutoscalingApi() *AutoscalingApi {
return &AutoscalingApi{
service: autoscaling.New(self.session),
}
}
func (self *AwsManager) SnsApi() *SnsApi {
return &SnsApi{
service: sns.New(self.session),
}
}
func (self *AwsManager) S3Api() *S3Api {
return &S3Api{
service: s3.New(self.session),
}
}