Golang resp.NewInt函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了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；未经允许，请勿转载。