Merge pull request #14 from zuoyebang/dev

modify readme

go.mod

@@ -15,7 +15,6 @@ require (
 	github.com/goccy/go-json v0.10.2
 	github.com/golang/snappy v0.0.4
 	github.com/gomodule/redigo v2.0.0+incompatible
-	github.com/google/gops v0.3.28
 	github.com/hashicorp/memberlist v0.2.4
 	github.com/json-iterator/go v1.1.12
 	github.com/juju/ratelimit v1.0.2-0.20191002062651-f60b32039441

go.sum

@@ -137,8 +137,6 @@ github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
 github.com/google/go-querystring v1.0.0/go.mod h1:odCYkC5MyYFN7vkCjXpyrEuKhc/BUO6wN/zVPAxq5ck=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
 github.com/google/gofuzz v1.2.0 h1:xRy4A+RhZaiKjJ1bPfwQ8sedCA+YS2YcCHW6ec7JMi0=
-github.com/google/gops v0.3.28 h1:2Xr57tqKAmQYRAfG12E+yLcoa2Y42UJo2lOrUFL9ark=
-github.com/google/gops v0.3.28/go.mod h1:6f6+Nl8LcHrzJwi8+p0ii+vmBFSlB4f8cOOkTJ7sk4c=
 github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=
 github.com/gorilla/context v1.1.1/go.mod h1:kBGZzfjB9CEq2AlWe17Uuf7NDRt0dE0s8S51q0aT7Yg=
 github.com/gorilla/context v1.1.2 h1:WRkNAv2uoa03QNIc1A6u4O7DAGMUVoopZhkiXWA2V1o=

stored/cmd/main.go

@@ -25,7 +25,6 @@ import (
 	"github.com/zuoyebang/bitalostored/stored/internal/tclock"
 	"github.com/zuoyebang/bitalostored/stored/plugin/anticc"
 	"github.com/zuoyebang/bitalostored/stored/plugin/catch_panic"
-	"github.com/zuoyebang/bitalostored/stored/plugin/gops"
 	"github.com/zuoyebang/bitalostored/stored/plugin/info"
 	"github.com/zuoyebang/bitalostored/stored/plugin/pprof"
 	"github.com/zuoyebang/bitalostored/stored/plugin/raft"
@@ -71,7 +70,6 @@ func main() {
 	info.Init()
 	catch_panic.Init()
 	pprof.Init()
-	gops.Init()
 	raft.Init()
 	anticc.Init()
 

stored/server/cmd_global.go

@@ -15,8 +15,11 @@
 package server
 
 import (
+	"os"
 	"runtime/debug"
+	"syscall"
 
+	"github.com/zuoyebang/bitalostored/stored/internal/errn"
 	"github.com/zuoyebang/bitalostored/stored/internal/resp"
 	"github.com/zuoyebang/bitalostored/stored/internal/utils"
 )
@@ -30,9 +33,21 @@ func init() {
 		"debuginfo":  {Sync: false, Handler: debugInfoCommand, NoKey: true},
 		"cacheinfo":  {Sync: false, Handler: cacheInfoCommand, NoKey: true},
 		"freememory": {Sync: false, Handler: freeOsMemoryCommand, NoKey: true},
+		"shutdown":   {Sync: false, Handler: shutdownCommand, NoKey: true},
 	})
 }
 
+func shutdownCommand(c *Client) error {
+	c.conn.Close()
+
+	p, _ := os.FindProcess(os.Getpid())
+
+	p.Signal(syscall.SIGTERM)
+	p.Signal(os.Interrupt)
+
+	return errn.ErrClientQuit
+}
+
 func freeOsMemoryCommand(c *Client) error {
 	debug.FreeOSMemory()
 	c.RespWriter.WriteStatus(resp.ReplyOK)