aboutsummaryrefslogtreecommitdiff
path: root/weed/command/s3.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-07-19 01:21:44 -0700
committerChris Lu <chris.lu@gmail.com>2018-07-19 01:21:44 -0700
commitc7228fefa70ef4f88d66484f4ac362b1be2d5a5c (patch)
tree87a09312e3e7207aa42282b022fa3fdf8dea205b /weed/command/s3.go
parent702fbdf7310aa266bc0854492a83589d663d803e (diff)
downloadseaweedfs-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.go11
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)