luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update S3 emitter initialization

Browse source
This commit is contained in:
Harlow Ward 2016-05-01 15:07:58 -07:00
parent 07efe9750c
commit 8d71bbd0ec
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
emitter/s3/emitter.go
View file

@ -23,9 +23,7 @@ type Emitter struct {
func (e Emitter) Emit(s3Key string, b io.ReadSeeker) error { func (e Emitter) Emit(s3Key string, b io.ReadSeeker) error {
svc := s3.New( svc := s3.New(
session.New(aws.NewConfig().WithMaxRetries(10)), session.New(aws.NewConfig().WithMaxRetries(10)),
&aws.Config{ aws.NewConfig().WithRegion(e.Region),
Region: aws.String(e.Region),
},
) )
params := &s3.PutObjectInput{ params := &s3.PutObjectInput{