repository

Documentation

Index

• type CassandraHistory
  • func (r *CassandraHistory) GetMsgByGroupSeqList(groupId string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
  • func (r *CassandraHistory) GetMsgBySeqList(uid string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
• type IPullHistoryMsg
• type MongoHistory
  • func (r *MongoHistory) GetMsgByGroupSeqList(groupId string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
  • func (r *MongoHistory) GetMsgBySeqList(uid string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
• type Rep
  • func NewRep(svcCtx *svc.ServiceContext) *Rep
  • func (r *Rep) GetGroupMaxSeq(groupId string) (uint64, error)
  • func (r *Rep) GetGroupMinSeq(groupId string) (uint64, error)
  • func (r *Rep) GetUserMaxSeq(uid string) (uint64, error)
  • func (r *Rep) GetUserMinSeq(uid string) (uint64, error)

Types

type CassandraHistory

type CassandraHistory struct {
	CassandraClient *gocql.Session
	// contains filtered or unexported fields
}

func (*CassandraHistory) GetMsgByGroupSeqList

func (r *CassandraHistory) GetMsgByGroupSeqList(groupId string, seqList []uint32) (seqMsg []*pb.MsgData, err error)

func (*CassandraHistory) GetMsgBySeqList

func (r *CassandraHistory) GetMsgBySeqList(uid string, seqList []uint32) (seqMsg []*pb.MsgData, err error)

type IPullHistoryMsg

type IPullHistoryMsg interface {
	GetMsgBySeqList(uid string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
	GetMsgByGroupSeqList(groupId string, seqList []uint32) (seqMsg []*pb.MsgData, err error)
}

type MongoHistory

type MongoHistory struct {
	MongoClient *mongo.Client
	// contains filtered or unexported fields
}

func (*MongoHistory) GetMsgByGroupSeqList

func (r *MongoHistory) GetMsgByGroupSeqList(groupId string, seqList []uint32) (seqMsg []*pb.MsgData, err error)

func (*MongoHistory) GetMsgBySeqList

func (r *MongoHistory) GetMsgBySeqList(uid string, seqList []uint32) (seqMsg []*pb.MsgData, err error)

type Rep

type Rep struct {
	Cache redis.UniversalClient
	IPullHistoryMsg
	// contains filtered or unexported fields
}

func NewRep

func NewRep(svcCtx *svc.ServiceContext) *Rep

func (*Rep) GetGroupMaxSeq

func (r *Rep) GetGroupMaxSeq(groupId string) (uint64, error)

func (*Rep) GetGroupMinSeq

func (r *Rep) GetGroupMinSeq(groupId string) (uint64, error)

func (*Rep) GetUserMaxSeq

func (r *Rep) GetUserMaxSeq(uid string) (uint64, error)

func (*Rep) GetUserMinSeq

func (r *Rep) GetUserMinSeq(uid string) (uint64, error)