aboutsummaryrefslogtreecommitdiff
path: root/weed/replication
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-09-01 02:45:42 -0700
committerChris Lu <chris.lu@gmail.com>2021-09-01 02:45:42 -0700
commit7ce97b59d828b3f6d7bcdab323209740280da3f3 (patch)
treeb4f50634e183c2bc8ba897baefbf3d62731bf9f8 /weed/replication
parentd1a4e19a3f0aeaabcf87aba3c99880f82bde87a3 (diff)
downloadseaweedfs-7ce97b59d828b3f6d7bcdab323209740280da3f3.tar.xz
seaweedfs-7ce97b59d828b3f6d7bcdab323209740280da3f3.zip
go fmt
Diffstat (limited to 'weed/replication')
-rw-r--r--weed/replication/sink/s3sink/s3_sink.go6
-rw-r--r--weed/replication/sub/notification_aws_sqs.go2
2 files changed, 4 insertions, 4 deletions
diff --git a/weed/replication/sink/s3sink/s3_sink.go b/weed/replication/sink/s3sink/s3_sink.go
index 81cb87a18..c3da1ee3f 100644
--- a/weed/replication/sink/s3sink/s3_sink.go
+++ b/weed/replication/sink/s3sink/s3_sink.go
@@ -74,9 +74,9 @@ func (s3sink *S3Sink) initialize(awsAccessKeyId, awsSecretAccessKey, region, buc
s3sink.endpoint = endpoint
config := &aws.Config{
- Region: aws.String(s3sink.region),
- Endpoint: aws.String(s3sink.endpoint),
- S3ForcePathStyle: aws.Bool(true),
+ Region: aws.String(s3sink.region),
+ Endpoint: aws.String(s3sink.endpoint),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {
diff --git a/weed/replication/sub/notification_aws_sqs.go b/weed/replication/sub/notification_aws_sqs.go
index 844aa023d..08133533f 100644
--- a/weed/replication/sub/notification_aws_sqs.go
+++ b/weed/replication/sub/notification_aws_sqs.go
@@ -41,7 +41,7 @@ func (k *AwsSqsInput) Initialize(configuration util.Configuration, prefix string
func (k *AwsSqsInput) initialize(awsAccessKeyId, awsSecretAccessKey, region, queueName string) (err error) {
config := &aws.Config{
- Region: aws.String(region),
+ Region: aws.String(region),
S3DisableContentMD5Validation: aws.Bool(true),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {