aboutsummaryrefslogtreecommitdiff
path: root/go/weed/compact.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2013-11-12 02:21:22 -0800
committerChris Lu <chris.lu@gmail.com>2013-11-12 02:21:22 -0800
commit3b687111399fd08468e4a6232bcbe6068df961bf (patch)
treecde07f3ba6c9ae411d55b25c331bca6827253c30 /go/weed/compact.go
parent8f0e2f31afad1fcb2f06ef3ae55866313b7b4b02 (diff)
downloadseaweedfs-3b687111399fd08468e4a6232bcbe6068df961bf.tar.xz
seaweedfs-3b687111399fd08468e4a6232bcbe6068df961bf.zip
support for collections!
Diffstat (limited to 'go/weed/compact.go')
-rw-r--r--go/weed/compact.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/go/weed/compact.go b/go/weed/compact.go
index 30ae6abd2..2600b3362 100644
--- a/go/weed/compact.go
+++ b/go/weed/compact.go
@@ -21,8 +21,9 @@ var cmdCompact = &Command{
}
var (
- compactVolumePath = cmdCompact.Flag.String("dir", "/tmp", "data directory to store files")
- compactVolumeId = cmdCompact.Flag.Int("volumeId", -1, "a volume id. The volume should already exist in the dir.")
+ compactVolumePath = cmdCompact.Flag.String("dir", "/tmp", "data directory to store files")
+ compactVolumeCollection = cmdCompact.Flag.String("collection", "", "volume collection name")
+ compactVolumeId = cmdCompact.Flag.Int("volumeId", -1, "a volume id. The volume should already exist in the dir.")
)
func runCompact(cmd *Command, args []string) bool {
@@ -32,7 +33,7 @@ func runCompact(cmd *Command, args []string) bool {
}
vid := storage.VolumeId(*compactVolumeId)
- v, err := storage.NewVolume(*compactVolumePath, vid, storage.CopyNil)
+ v, err := storage.NewVolume(*compactVolumePath, *compactVolumeCollection, vid, storage.CopyNil)
if err != nil {
glog.Fatalf("Load Volume [ERROR] %s\n", err)
}