aboutsummaryrefslogtreecommitdiff
path: root/weed/command/s3.go
diff options
context:
space:
mode:
authorSmsS4 <36403983+SmsS4@users.noreply.github.com>2023-05-16 20:09:43 +0330
committerGitHub <noreply@github.com>2023-05-16 09:39:43 -0700
commit17e91d29179a41131e2a707ac2c5e63be4a21530 (patch)
treece0aa8417e2c4d983b7f085b8f1498dc3bd4f9d4 /weed/command/s3.go
parentb7f011f777bd9fa396a607e6228f43e3be5f5437 (diff)
downloadseaweedfs-17e91d29179a41131e2a707ac2c5e63be4a21530.tar.xz
seaweedfs-17e91d29179a41131e2a707ac2c5e63be4a21530.zip
Use filerGroup for s3 buckets collection prefix (#4465)
* Use filerGroup for s3 buckets collection prefix * Fix templates * Remove flags * Remove s3CollectionPrefix
Diffstat (limited to 'weed/command/s3.go')
-rw-r--r--weed/command/s3.go3
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/command/s3.go b/weed/command/s3.go
index 39d1c6fce..8f82ac946 100644
--- a/weed/command/s3.go
+++ b/weed/command/s3.go
@@ -155,6 +155,7 @@ func (s3opt *S3Options) startS3Server() bool {
filerAddress := pb.ServerAddress(*s3opt.filer)
filerBucketsPath := "/buckets"
+ filerGroup := ""
grpcDialOption := security.LoadClientTLS(util.GetViper(), "grpc.client")
@@ -169,6 +170,7 @@ func (s3opt *S3Options) startS3Server() bool {
return fmt.Errorf("get filer %s configuration: %v", filerAddress, err)
}
filerBucketsPath = resp.DirBuckets
+ filerGroup = resp.FilerGroup
metricsAddress, metricsIntervalSec = resp.MetricsAddress, int(resp.MetricsIntervalSec)
glog.V(0).Infof("S3 read filer buckets dir: %s", filerBucketsPath)
return nil
@@ -200,6 +202,7 @@ func (s3opt *S3Options) startS3Server() bool {
AllowDeleteBucketNotEmpty: *s3opt.allowDeleteBucketNotEmpty,
LocalFilerSocket: localFilerSocket,
DataCenter: *s3opt.dataCenter,
+ FilerGroup: filerGroup,
})
if s3ApiServer_err != nil {
glog.Fatalf("S3 API Server startup error: %v", s3ApiServer_err)