redis_dao

Documentation

Overview

TODO(@benqi): 可以使用如下方法来生成seq - 如果运维能保证redis数据可靠性，可移除数据库seq_updates_ngen的存储 - 可使用[seqsvr](https://github.com/nebula-in/seqsvr)服务来生成seq - 可调研艺龙的序列号生成器 - 直接使用etcd或zk

Index

• type SequenceDAO
  • func NewSequenceDAO(redis *redis_client.RedisPool) *SequenceDAO
  • func (dao *SequenceDAO) CurrentChannelMessageBoxId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) CurrentChannelPtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) CurrentMessageBoxId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) CurrentPtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) CurrentQtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) CurrentSeqId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) FetchNextSequence(key string) (seq int64, err error)
  • func (dao *SequenceDAO) GetCurrentSequence(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextChannelMessageBoxId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextChannelPtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextMessageBoxId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextPtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextQtsId(key string) (seq int64, err error)
  • func (dao *SequenceDAO) NextSeqId(key string) (seq int64, err error)

Types

type SequenceDAO

type SequenceDAO struct {
	// contains filtered or unexported fields
}

func NewSequenceDAO

func NewSequenceDAO(redis *redis_client.RedisPool) *SequenceDAO

func (*SequenceDAO) CurrentChannelMessageBoxId

func (dao *SequenceDAO) CurrentChannelMessageBoxId(key string) (seq int64, err error)

func (*SequenceDAO) CurrentChannelPtsId

func (dao *SequenceDAO) CurrentChannelPtsId(key string) (seq int64, err error)

func (*SequenceDAO) CurrentMessageBoxId

func (dao *SequenceDAO) CurrentMessageBoxId(key string) (seq int64, err error)

func (*SequenceDAO) CurrentPtsId

func (dao *SequenceDAO) CurrentPtsId(key string) (seq int64, err error)

func (*SequenceDAO) CurrentQtsId

func (dao *SequenceDAO) CurrentQtsId(key string) (seq int64, err error)

func (*SequenceDAO) CurrentSeqId

func (dao *SequenceDAO) CurrentSeqId(key string) (seq int64, err error)

func (*SequenceDAO) FetchNextSequence

func (dao *SequenceDAO) FetchNextSequence(key string) (seq int64, err error)

func (*SequenceDAO) GetCurrentSequence

func (dao *SequenceDAO) GetCurrentSequence(key string) (seq int64, err error)

func (*SequenceDAO) NextChannelMessageBoxId

func (dao *SequenceDAO) NextChannelMessageBoxId(key string) (seq int64, err error)

func (*SequenceDAO) NextChannelPtsId

func (dao *SequenceDAO) NextChannelPtsId(key string) (seq int64, err error)

func (*SequenceDAO) NextMessageBoxId

func (dao *SequenceDAO) NextMessageBoxId(key string) (seq int64, err error)

func (*SequenceDAO) NextPtsId

func (dao *SequenceDAO) NextPtsId(key string) (seq int64, err error)

func (*SequenceDAO) NextQtsId

func (dao *SequenceDAO) NextQtsId(key string) (seq int64, err error)

func (*SequenceDAO) NextSeqId

func (dao *SequenceDAO) NextSeqId(key string) (seq int64, err error)