本文整理汇总了Golang中github.com/reborndb/go/redis/resp.NewInt函数的典型用法代码示例。如果您正苦于以下问题:Golang NewInt函数的具体用法?Golang NewInt怎么用?Golang NewInt使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了NewInt函数的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: RoleCmd
// ROLE
func RoleCmd(s Session, args [][]byte) (redis.Resp, error) {
if len(args) != 0 {
return toRespErrorf("len(args) = %d, expect = 0", len(args))
}
c, _ := s.(*conn)
if c == nil {
return nil, errors.New("invalid connection")
}
ay := redis.NewArray()
if masterAddr := c.h.masterAddr.Get(); masterAddr == "" {
// master
ay.Append(redis.NewBulkBytesWithString("master"))
c.h.repl.RLock()
defer c.h.repl.RUnlock()
ay.Append(redis.NewInt(c.h.repl.masterOffset))
slaves := redis.NewArray()
for slave, _ := range c.h.repl.slaves {
a := redis.NewArray()
if addr := slave.nc.RemoteAddr(); addr == nil {
continue
} else {
a.Append(redis.NewBulkBytesWithString(strings.Split(addr.String(), ":")[0]))
}
a.Append(redis.NewBulkBytesWithString(fmt.Sprintf("%d", slave.listeningPort.Get())))
a.Append(redis.NewBulkBytesWithString(fmt.Sprintf("%d", slave.syncOffset.Get())))
slaves.Append(a)
}
ay.Append(slaves)
} else {
// slave
ay.Append(redis.NewBulkBytesWithString("slave"))
seps := strings.Split(masterAddr, ":")
if len(seps) == 2 {
port, err := strconv.ParseInt(seps[1], 10, 16)
if err != nil {
return toRespError(err)
}
ay.Append(redis.NewBulkBytesWithString(seps[0]))
ay.Append(redis.NewInt(int64(port)))
} else {
return toRespErrorf("invalid master addr, must ip:port, but %s", masterAddr)
}
ay.Append(redis.NewBulkBytesWithString(c.h.masterConnState.Get()))
ay.Append(redis.NewInt(c.h.syncOffset.Get()))
}
return ay, nil
}
开发者ID:CowLeo,项目名称:qdb,代码行数:52,代码来源:repl.go
示例2: SlotsMgrtTagOneCmd
// SLOTSMGRTTAGONE host port timeout key
func SlotsMgrtTagOneCmd(s Session, args [][]byte) (redis.Resp, error) {
if n, err := s.Store().SlotsMgrtTagOne(s.DB(), args); err != nil {
return toRespError(err)
} else {
return redis.NewInt(n), nil
}
}
开发者ID:cuiwm,项目名称:reborn,代码行数:8,代码来源:slots.go
示例3: HIncrByCmd
// HINCRBY key field delta
func HIncrByCmd(s Session, args [][]byte) (redis.Resp, error) {
if v, err := s.Store().HIncrBy(s.DB(), args); err != nil {
return toRespError(err)
} else {
return redis.NewInt(v), nil
}
}
开发者ID:cuiwm,项目名称:reborn,代码行数:8,代码来源:hash.go
示例4: HLenCmd
// HLEN key
func HLenCmd(s Session, args [][]byte) (redis.Resp, error) {
if n, err := s.Store().HLen(s.DB(), args); err != nil {
return toRespError(err)
} else {
return redis.NewInt(n), nil
}
}
开发者ID:cuiwm,项目名称:reborn,代码行数:8,代码来源:hash.go
示例5: HExistsCmd
// HEXISTS key field
func HExistsCmd(s Session, args [][]byte) (redis.Resp, error) {
if x, err := s.Store().HExists(s.DB(), args); err != nil {
return toRespError(err)
} else {
return redis.NewInt(x), nil
}
}
开发者ID:cuiwm,项目名称:reborn,代码行数:8,代码来源:hash.go
示例6: ZRemRangeByScoreCmd
// ZREMRANGEBYSCORE key min max
func ZRemRangeByScoreCmd(s Session, args [][]byte) (redis.Resp, error) {
if v, err := s.Store().ZRemRangeByScore(s.DB(), args); err != nil {
return toRespError(err)
} else {
return redis.NewInt(v), nil
}
}
开发者ID:CowLeo,项目名称:qdb,代码行数:8,代码来源:zset.go
示例7: ZRevRankCmd
// ZREVRANK key member
func ZRevRankCmd(s Session, args [][]byte) (redis.Resp, error) {
if v, err := s.Store().ZRevRank(s.DB(), args); err != nil {
return toRespError(err)
} else if v >= 0 {
return redis.NewInt(v), nil
} else {
return redis.NewBulkBytes(nil), nil
}
}
开发者ID:CowLeo,项目名称:qdb,代码行数:10,代码来源:zset.go
示例8: RegisterIntReply
func RegisterIntReply(name string, f CommandIntFunc, flag CommandFlag) {
v := func(s Session, args [][]byte) (redis.Resp, error) {
r, err := f(s, args)
if err != nil {
return toRespError(err)
}
return redis.NewInt(r), nil
}
register(name, v, flag)
}
开发者ID:CowLeo,项目名称:qdb,代码行数:11,代码来源:command.go
示例9: checkInt
func (pc *testPoolConn) checkInt(c *C, expect int64, cmd string, args ...interface{}) {
resp := pc.doCmd(c, cmd, args...)
c.Assert(resp, DeepEquals, redis.NewInt(expect))
}
开发者ID:CowLeo,项目名称:qdb,代码行数:4,代码来源:main_test.go
注:本文中的github.com/reborndb/go/redis/resp.NewInt函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论