diff options
| author | chrislusf <chrislu@Chriss-MacBook-Air.local> | 2014-12-08 20:27:26 -0800 |
|---|---|---|
| committer | chrislusf <chrislu@Chriss-MacBook-Air.local> | 2014-12-08 20:27:26 -0800 |
| commit | ba972694c730429889c696bd9853a38843f64f65 (patch) | |
| tree | 89ce6b445537a4b0478b13c13788b69d1b82d87f /go/weed/filer.go | |
| parent | 7a6394378cfd3a09bb273211e9bad1ec19e01e84 (diff) | |
| download | seaweedfs-ba972694c730429889c696bd9853a38843f64f65.tar.xz seaweedfs-ba972694c730429889c696bd9853a38843f64f65.zip | |
Add filer option to redirect instead of proxying to volume server on file GET requests.
Diffstat (limited to 'go/weed/filer.go')
| -rw-r--r-- | go/weed/filer.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/go/weed/filer.go b/go/weed/filer.go index b3fc9c878..5ae3a3496 100644 --- a/go/weed/filer.go +++ b/go/weed/filer.go @@ -21,6 +21,7 @@ type FilerOptions struct { collection *string defaultReplicaPlacement *string dir *string + redirectOnRead *bool } func init() { @@ -29,7 +30,8 @@ func init() { f.collection = cmdFiler.Flag.String("collection", "", "all data will be stored in this collection") f.port = cmdFiler.Flag.Int("port", 8888, "filer server http listen port") f.dir = cmdFiler.Flag.String("dir", os.TempDir(), "directory to store meta data") - f.defaultReplicaPlacement = cmdFiler.Flag.String("defaultReplicaPlacement", "000", "Default replication type if not specified.") + f.defaultReplicaPlacement = cmdFiler.Flag.String("defaultReplicaPlacement", "000", "default replication type if not specified") + f.redirectOnRead = cmdFiler.Flag.Bool("redirectOnRead", false, "whether proxy or redirect to volume server during file GET request") } var cmdFiler = &Command{ @@ -60,7 +62,9 @@ func runFiler(cmd *Command, args []string) bool { } r := http.NewServeMux() - _, nfs_err := weed_server.NewFilerServer(r, *f.port, *f.master, *f.dir, *f.collection) + _, nfs_err := weed_server.NewFilerServer(r, *f.port, *f.master, *f.dir, *f.collection, + *f.defaultReplicaPlacement, *f.redirectOnRead, + ) if nfs_err != nil { glog.Fatalf(nfs_err.Error()) } |
