add filer notification

2 files changed, 15 insertions, 10 deletions

diff --git a/weed/command/filer.go b/weed/command/filer.go
index 17f2fbdcf..d42db6418 100644
--- a/weed/command/filer.go
+++ b/weed/command/filer.go
@@ -32,6 +32,7 @@ type FilerOptions struct {
 	secretKey               *string
 	dirListingLimit         *int
 	dataCenter              *string
+	enableNotification      *bool
 }
 
 func init() {
@@ -49,6 +50,7 @@ func init() {
 	f.secretKey = cmdFiler.Flag.String("secure.secret", "", "secret to encrypt Json Web Token(JWT)")
 	f.dirListingLimit = cmdFiler.Flag.Int("dirListLimit", 1000, "limit sub dir listing size")
 	f.dataCenter = cmdFiler.Flag.String("dataCenter", "", "prefer to write to volumes in this data center")
+	f.enableNotification = cmdFiler.Flag.Bool("notify", false, "send file updates to the queue defined in message_queue.toml")
 }
 
 var cmdFiler = &Command{
@@ -90,14 +92,15 @@ func (fo *FilerOptions) start() {
 
 	fs, nfs_err := weed_server.NewFilerServer(defaultMux, publicVolumeMux, &weed_server.FilerOption{
 		Masters:            strings.Split(*f.masters, ","),
-		Collection:         *f.collection,
-		DefaultReplication: *f.defaultReplicaPlacement,
-		RedirectOnRead:     *f.redirectOnRead,
-		DisableDirListing:  *f.disableDirListing,
-		MaxMB:              *f.maxMB,
-		SecretKey:          *f.secretKey,
-		DirListingLimit:    *f.dirListingLimit,
-		DataCenter:         *f.dataCenter,
+		Collection:         *fo.collection,
+		DefaultReplication: *fo.defaultReplicaPlacement,
+		RedirectOnRead:     *fo.redirectOnRead,
+		DisableDirListing:  *fo.disableDirListing,
+		MaxMB:              *fo.maxMB,
+		SecretKey:          *fo.secretKey,
+		DirListingLimit:    *fo.dirListingLimit,
+		DataCenter:         *fo.dataCenter,
+		EnableNotification: *fo.enableNotification,
 	})
 	if nfs_err != nil {
 		glog.Fatalf("Filer startup error: %v", nfs_err)
@@ -127,9 +130,9 @@ func (fo *FilerOptions) start() {
 	}
 
 	// starting grpc server
-	grpcPort := *f.grpcPort
+	grpcPort := *fo.grpcPort
 	if grpcPort == 0 {
-		grpcPort = *f.port + 10000
+		grpcPort = *fo.port + 10000
 	}
 	grpcL, err := util.NewListener(":"+strconv.Itoa(grpcPort), 0)
 	if err != nil {
diff --git a/weed/command/server.go b/weed/command/server.go
index b0c6a1ed5..bef5e635e 100644
--- a/weed/command/server.go
+++ b/weed/command/server.go
@@ -84,12 +84,14 @@ func init() {
 	serverOptions.cpuprofile = cmdServer.Flag.String("cpuprofile", "", "cpu profile output file")
 	filerOptions.collection = cmdServer.Flag.String("filer.collection", "", "all data will be stored in this collection")
 	filerOptions.port = cmdServer.Flag.Int("filer.port", 8888, "filer server http listen port")
+	filerOptions.grpcPort = cmdServer.Flag.Int("filer.port.grpc", 0, "filer grpc server listen port, default to http port + 10000")
 	filerOptions.publicPort = cmdServer.Flag.Int("filer.port.public", 0, "filer server public http listen port")
 	filerOptions.defaultReplicaPlacement = cmdServer.Flag.String("filer.defaultReplicaPlacement", "", "Default replication type if not specified during runtime.")
 	filerOptions.redirectOnRead = cmdServer.Flag.Bool("filer.redirectOnRead", false, "whether proxy or redirect to volume server during file GET request")
 	filerOptions.disableDirListing = cmdServer.Flag.Bool("filer.disableDirListing", false, "turn off directory listing")
 	filerOptions.maxMB = cmdServer.Flag.Int("filer.maxMB", 32, "split files larger than the limit")
 	filerOptions.dirListingLimit = cmdServer.Flag.Int("filer.dirListLimit", 1000, "limit sub dir listing size")
+	filerOptions.enableNotification = cmdServer.Flag.Bool("filer.notify", false, "send file updates to the queue defined in message_queue.toml")
 }
 
 func runServer(cmd *Command, args []string) bool {