aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/backend/s3_backend/s3_sessions.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-03-19 21:13:56 -0700
committerChris Lu <chris.lu@gmail.com>2020-03-19 21:13:56 -0700
commit709f231e23d2ad40e2094a906d50fefad31423be (patch)
treef0814085f12e1e5d4f81af67944f3b206084de80 /weed/storage/backend/s3_backend/s3_sessions.go
parentd848d089448372326edd9f8a20dbc9fc3c46f6dd (diff)
downloadseaweedfs-709f231e23d2ad40e2094a906d50fefad31423be.tar.xz
seaweedfs-709f231e23d2ad40e2094a906d50fefad31423be.zip
tiered storage: add s3 endpoint for private s3 implementation
fix https://github.com/chrislusf/seaweedfs/issues/1238
Diffstat (limited to 'weed/storage/backend/s3_backend/s3_sessions.go')
-rw-r--r--weed/storage/backend/s3_backend/s3_sessions.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/storage/backend/s3_backend/s3_sessions.go b/weed/storage/backend/s3_backend/s3_sessions.go
index 5fdbcb66b..e2fdf1eb6 100644
--- a/weed/storage/backend/s3_backend/s3_sessions.go
+++ b/weed/storage/backend/s3_backend/s3_sessions.go
@@ -24,7 +24,7 @@ func getSession(region string) (s3iface.S3API, bool) {
return sess, found
}
-func createSession(awsAccessKeyId, awsSecretAccessKey, region string) (s3iface.S3API, error) {
+func createSession(awsAccessKeyId, awsSecretAccessKey, region, endpoint string) (s3iface.S3API, error) {
sessionsLock.Lock()
defer sessionsLock.Unlock()
@@ -34,7 +34,8 @@ func createSession(awsAccessKeyId, awsSecretAccessKey, region string) (s3iface.S
}
config := &aws.Config{
- Region: aws.String(region),
+ Region: aws.String(region),
+ Endpoint: aws.String(endpoint),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {
config.Credentials = credentials.NewStaticCredentials(awsAccessKeyId, awsSecretAccessKey, "")