empayre/fleet
14
0
Fork 0
mirror of https://github.com/empayre/fleet.git synced 2024-11-06 08:55:24 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Allow Firehose authentication using sts credentials (#2034)

Browse Source
This commit is contained in:
Eduardo Lopez 2019-04-24 16:30:16 -07:00 committed by Zachary Wasserman
parent 75868a7005
commit ad12ee4db4
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Gopkg.lock generated
View File

@ -711,8 +711,10 @@
"github.com/VividCortex/mysqlerr",
"github.com/WatchBeam/clock",
"github.com/aws/aws-sdk-go/aws",
"github.com/aws/aws-sdk-go/aws/awserr",
"github.com/aws/aws-sdk-go/aws/credentials",
"github.com/aws/aws-sdk-go/aws/session",
"github.com/aws/aws-sdk-go/service/firehose",
"github.com/aws/aws-sdk-go/service/firehose/firehoseiface",
"github.com/beevik/etree",
"github.com/briandowns/spinner",

13
server/logging/firehose.go
View File

@ -34,10 +34,17 @@ type firehoseLogWriter struct {
}
func NewFirehoseLogWriter(region, id, secret, stream string, logger log.Logger) (*firehoseLogWriter, error) {
sess, err := session.NewSession(&aws.Config{
Credentials: credentials.NewStaticCredentials(id, secret, ""),
conf := &aws.Config{
Region: &region,
})
}
// Only provide static credentials if we have them
// otherwise use the default credentials provider chain
if id != "" && secret != "" {
conf.Credentials = credentials.NewStaticCredentials(id, secret, "")
}
sess, err := session.NewSession(conf)
if err != nil {
return nil, errors.Wrap(err, "create Firehose client")
}