diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-07-19 01:21:44 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-07-19 01:21:44 -0700 |
| commit | c7228fefa70ef4f88d66484f4ac362b1be2d5a5c (patch) | |
| tree | 87a09312e3e7207aa42282b022fa3fdf8dea205b /weed/command/s3.go | |
| parent | 702fbdf7310aa266bc0854492a83589d663d803e (diff) | |
| download | seaweedfs-c7228fefa70ef4f88d66484f4ac362b1be2d5a5c.tar.xz seaweedfs-c7228fefa70ef4f88d66484f4ac362b1be2d5a5c.zip | |
add bucket creation and deletion
1. option for "weed s3 -filer.dir.buckets" to choose a folder for buckets
2. create a bucket
3. delete a bucket, recursively delete all metadata on filer
Diffstat (limited to 'weed/command/s3.go')
| -rw-r--r-- | weed/command/s3.go | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/weed/command/s3.go b/weed/command/s3.go index 535ffbcb1..03fa80ed8 100644 --- a/weed/command/s3.go +++ b/weed/command/s3.go @@ -16,16 +16,18 @@ var ( ) type S3Options struct { - filer *string - filerGrpcPort *int - port *int - domainName *string + filer *string + filerGrpcPort *int + filerBucketsPath *string + port *int + domainName *string } func init() { cmdS3.Run = runS3 // break init cycle s3options.filer = cmdS3.Flag.String("filer", "localhost:8888", "filer server address") s3options.filerGrpcPort = cmdS3.Flag.Int("filer.grpcPort", 0, "filer server grpc port, default to filer http port plus 10000") + s3options.filerBucketsPath = cmdS3.Flag.String("filer.dir.buckets", "/s3buckets", "folder on filer to store all buckets") s3options.port = cmdS3.Flag.Int("port", 8333, "s3options server http listen port") s3options.domainName = cmdS3.Flag.String("domainName", "", "suffix of the host name, {bucket}.{domainName}") } @@ -52,6 +54,7 @@ func runS3(cmd *Command, args []string) bool { Filer: *s3options.filer, FilerGrpcAddress: filerGrpcAddress, DomainName: *s3options.domainName, + BucketsPath: *s3options.filerBucketsPath, }) if s3ApiServer_err != nil { glog.Fatalf("S3 API Server startup error: %v", s3ApiServer_err) |
