server

Documentation

Index

• Constants
• Variables
• type Stat
  • func Bench(nconn, nreq int64, hosts []string, cmds []string, ...) (*Stat, error)

Constants

const (
	REDIS = "redis"
)

const (
	REDIS_SERVER_START = "redis.server.start"
)

const SERVER = "server"

Variables

var Index = &ice.Context{Name: REDIS, Help: "redis", Configs: map[string]*ice.Config{
	SERVER: {Name: SERVER, Help: "服务器", Value: kit.Data(
		cli.SOURCE, "http://download.redis.io/releases/redis-5.0.4.tar.gz",
	)},
}, Commands: map[string]*ice.Command{
	ice.CTX_INIT: {Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {
		m.Load()
	}},
	ice.CTX_EXIT: {Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {
		m.Save()
	}},

	SERVER: {Name: "server port path auto bench start build download", Help: "服务器", Action: map[string]*ice.Action{
		web.DOWNLOAD: {Name: "download", Help: "下载", Hand: func(m *ice.Message, arg ...string) {
			m.Cmdy(code.INSTALL, web.DOWNLOAD, m.Conf(SERVER, kit.META_SOURCE))
		}},
		cli.BUILD: {Name: "build", Help: "构建", Hand: func(m *ice.Message, arg ...string) {
			m.Optionv(code.PREPARE, func(p string) {})
			m.Cmdy(code.INSTALL, cli.BUILD, m.Conf(SERVER, kit.META_SOURCE))
		}},
		cli.START: {Name: "start", Help: "启动", Hand: func(m *ice.Message, arg ...string) {
			m.Optionv(code.PREPARE, func(p string) []string { return []string{"--port", path.Base(p)} })
			m.Cmdy(code.INSTALL, cli.START, m.Conf(SERVER, kit.META_SOURCE), "bin/redis-server")

			m.Sleep("1s").Event(REDIS_SERVER_START, tcp.HOST, tcp.LOCALHOST, tcp.PORT, path.Base(m.Option(cli.CMD_DIR)))
		}},
		cli.BENCH: {Name: "bench nconn=100 nreq=1000 cmdList=", Help: "压测", Hand: func(m *ice.Message, arg ...string) {
			for _, k := range kit.Split(kit.Select(m.Option("cmdList"), "get,set")) {
				begin := time.Now()
				if s, e := Bench(kit.Int64(m.Option("nconn")), kit.Int64(m.Option("nreq")), []string{tcp.LOCALHOST + ":" + m.Option(tcp.PORT)}, []string{k}, func(cmd string, arg []interface{}, res interface{}) {

				}); m.Assert(e) {
					m.Push("time", begin)
					m.Push("cmd", k)
					m.Push("cost", kit.Format(s.EndTime.Sub(s.BeginTime)))
					m.Push("nreqs", s.NReq)
					m.Push("nerr", s.NErr)
					m.Push("qps", s.QPS)
					m.Push("avg", s.AVG)
				}
			}
			m.Process(ice.PROCESS_INNER)
		}},
	}, Hand: func(m *ice.Message, c *ice.Context, cmd string, arg ...string) {
		if m.Cmdy(code.INSTALL, path.Base(m.Conf(SERVER, kit.META_SOURCE)), arg); len(arg) == 0 {
			m.PushAction(cli.BENCH)
		}
	}},
},
}

Types

type Stat

type Stat struct {
	NReq int64
	NErr int64
	NOK  int64

	NRead  int64
	NWrite int64

	BeginTime time.Time
	EndTime   time.Time

	Cost time.Duration

	Up   float64
	Down float64
	QPS  float64
	AVG  time.Duration
	// contains filtered or unexported fields
}

func Bench

func Bench(nconn, nreq int64, hosts []string, cmds []string, check func(cmd string, arg []interface{}, res interface{})) (*Stat, error)