aboutsummaryrefslogtreecommitdiff
path: root/go/weed/filer.go
diff options
context:
space:
mode:
authorchrislusf <chrislu@Chriss-MacBook-Air.local>2014-12-08 20:27:26 -0800
committerchrislusf <chrislu@Chriss-MacBook-Air.local>2014-12-08 20:27:26 -0800
commitba972694c730429889c696bd9853a38843f64f65 (patch)
tree89ce6b445537a4b0478b13c13788b69d1b82d87f /go/weed/filer.go
parent7a6394378cfd3a09bb273211e9bad1ec19e01e84 (diff)
downloadseaweedfs-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.go8
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())
}