summaryrefslogtreecommitdiff
path: root/aws.go
diff options
context:
space:
mode:
Diffstat (limited to 'aws.go')
-rw-r--r--aws.go16
1 files changed, 8 insertions, 8 deletions
diff --git a/aws.go b/aws.go
index 74e6142..5f1befa 100644
--- a/aws.go
+++ b/aws.go
@@ -187,7 +187,7 @@ func (a *AwsConn) QueueHeartbeat(msg Qmsg, qurl string, duration int64) (Qmsg, e
VisibilityTimeout: aws.Int64(0),
})
- for i := 0; i < int(duration) * 5; i++ {
+ for i := 0; i < int(duration)*5; i++ {
msgResult, err := a.sqssvc.ReceiveMessage(&sqs.ReceiveMessageInput{
MaxNumberOfMessages: aws.Int64(10),
VisibilityTimeout: &duration,
@@ -292,9 +292,9 @@ func (a *AwsConn) ListObjectsWithMeta(bucket string, prefix string) ([]ObjMeta,
func (a *AwsConn) ListObjectPrefixes(bucket string) ([]string, error) {
var prefixes []string
err := a.s3svc.ListObjectsV2Pages(&s3.ListObjectsV2Input{
- Bucket: aws.String(bucket),
+ Bucket: aws.String(bucket),
Delimiter: aws.String("/"),
- MaxKeys: aws.Int64(1),
+ MaxKeys: aws.Int64(1),
}, func(page *s3.ListObjectsV2Output, last bool) bool {
for _, r := range page.CommonPrefixes {
prefixes = append(prefixes, *r.Prefix)
@@ -327,9 +327,9 @@ func (a *AwsConn) CreateQueue(name string) error {
_, err := a.sqssvc.CreateQueue(&sqs.CreateQueueInput{
QueueName: aws.String(name),
Attributes: map[string]*string{
- "VisibilityTimeout": aws.String("120"), // 2 minutes
- "MessageRetentionPeriod": aws.String("1209600"), // 14 days; max allowed by sqs
- "ReceiveMessageWaitTimeSeconds": aws.String("20"),
+ "VisibilityTimeout": aws.String("120"), // 2 minutes
+ "MessageRetentionPeriod": aws.String("1209600"), // 14 days; max allowed by sqs
+ "ReceiveMessageWaitTimeSeconds": aws.String("20"),
},
})
if err != nil {
@@ -339,7 +339,7 @@ func (a *AwsConn) CreateQueue(name string) error {
// quietly ignores the CreateQueue request if it is identical to an
// existing queue.
if ok && aerr.Code() == sqs.ErrCodeQueueNameExists {
- return errors.New("Error: Queue already exists but has different attributes:" + name)
+ return errors.New("Error: Queue already exists but has different attributes:" + name)
} else {
return errors.New(fmt.Sprintf("Error creating queue %s: %v", name, err))
}
@@ -447,7 +447,7 @@ func (a *AwsConn) StartInstances(n int) error {
IamInstanceProfile: &ec2.IamInstanceProfileSpecification{
Arn: aws.String(spotProfile),
},
- ImageId: aws.String(spotImage),
+ ImageId: aws.String(spotImage),
InstanceType: aws.String(spotType),
SecurityGroupIds: []*string{
aws.String(spotSg),