repository

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

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 struct {
	MongoClient *mongo.Client
	// contains filtered or unexported fields
}

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