seaweedfs/go/weed/filer.go

96 lines
3.2 KiB
Go
Raw Normal View History

2014-03-31 03:57:25 +00:00
package main
import (
"net/http"
"os"
"strconv"
"time"
2014-12-14 08:35:26 +00:00
"github.com/chrislusf/weed-fs/go/glog"
"github.com/chrislusf/weed-fs/go/util"
"github.com/chrislusf/weed-fs/go/weed/weed_server"
2014-03-31 03:57:25 +00:00
)
var (
f FilerOptions
)
type FilerOptions struct {
master *string
port *int
collection *string
defaultReplicaPlacement *string
dir *string
redirectOnRead *bool
cassandra_server *string
cassandra_keyspace *string
redis_server *string
redis_database *int
2014-03-31 03:57:25 +00:00
}
func init() {
cmdFiler.Run = runFiler // break init cycle
f.master = cmdFiler.Flag.String("master", "localhost:9333", "master server location")
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.redirectOnRead = cmdFiler.Flag.Bool("redirectOnRead", false, "whether proxy or redirect to volume server during file GET request")
f.cassandra_server = cmdFiler.Flag.String("cassandra.server", "", "host[:port] of the cassandra server")
f.cassandra_keyspace = cmdFiler.Flag.String("cassandra.keyspace", "seaweed", "keyspace of the cassandra server")
f.redis_server = cmdFiler.Flag.String("redis.server", "", "host:port of the redis server, e.g., 127.0.0.1:6379")
f.redis_database = cmdFiler.Flag.Int("redis.database", 0, "the database on the redis server")
2014-03-31 03:57:25 +00:00
}
var cmdFiler = &Command{
UsageLine: "filer -port=8888 -dir=/tmp -master=<ip:port>",
Short: "start a file server that points to a master server",
Long: `start a file server which accepts REST operation for any files.
2014-03-31 03:57:25 +00:00
//create or overwrite the file, the directories /path/to will be automatically created
POST /path/to/file
//get the file content
GET /path/to/file
//create or overwrite the file, the filename in the multipart request will be used
POST /path/to/
//return a json format subdirectory and files listing
GET /path/to/
2014-03-31 03:57:25 +00:00
Current <fullpath~fileid> mapping metadata store is local embedded leveldb.
It should be highly scalable to hundreds of millions of files on a modest machine.
2014-03-31 03:57:25 +00:00
Future we will ensure it can avoid of being SPOF.
`,
}
func runFiler(cmd *Command, args []string) bool {
2014-12-14 08:20:21 +00:00
2014-03-31 03:57:25 +00:00
if err := util.TestFolderWritable(*f.dir); err != nil {
glog.Fatalf("Check Meta Folder (-dir) Writable %s : %s", *f.dir, err)
}
r := http.NewServeMux()
2015-01-07 03:26:48 +00:00
_, nfs_err := weed_server.NewFilerServer(r, *f.port, *f.master, *f.dir, *f.collection,
*f.defaultReplicaPlacement, *f.redirectOnRead,
*f.cassandra_server, *f.cassandra_keyspace,
*f.redis_server, *f.redis_database,
)
2014-03-31 03:57:25 +00:00
if nfs_err != nil {
2015-01-14 01:04:41 +00:00
glog.Fatalf("Filer startup error: %v", nfs_err)
2014-03-31 03:57:25 +00:00
}
2014-09-21 04:18:26 +00:00
glog.V(0).Infoln("Start Seaweed Filer", util.VERSION, "at port", strconv.Itoa(*f.port))
2014-03-31 03:57:25 +00:00
filerListener, e := util.NewListener(
":"+strconv.Itoa(*f.port),
time.Duration(10)*time.Second,
)
if e != nil {
2015-01-14 01:04:41 +00:00
glog.Fatalf("Filer listener error: %v", e)
2014-03-31 03:57:25 +00:00
}
if e := http.Serve(filerListener, r); e != nil {
2015-01-14 01:04:41 +00:00
glog.Fatalf("Filer Fail to serve: %v", e)
2014-03-31 03:57:25 +00:00
}
return true
}