repository

Documentation

Index

• type Rep
  • func NewRep(svcCtx *svc.ServiceContext) *Rep
  • func (r *Rep) CheckMongoIndexSingle()
  • func (r *Rep) CheckMongoIndexSuperGroup()
  • func (r *Rep) IncrSuperGroupSeq(groupId string) (uint64, error)
  • func (r *Rep) IncrUserSeq(uid string) (uint64, error)
  • func (r *Rep) SaveSuperGroupChatMongo2(spanCtx context.Context, groupId string, sendTime int64, m *chatpb.MsgDataToDB) error
  • func (r *Rep) SaveUserChatMongo2(spanCtx context.Context, uid string, sendTime int64, m *chatpb.MsgDataToDB) error

Types

type Rep

type Rep struct {
	Cache redis.UniversalClient
	//mysql       *gorm.DB
	MongoClient *mongo.Client
	// contains filtered or unexported fields
}

func NewRep

func NewRep(svcCtx *svc.ServiceContext) *Rep

func (*Rep) CheckMongoIndexSingle

func (r *Rep) CheckMongoIndexSingle()

func (*Rep) CheckMongoIndexSuperGroup

func (r *Rep) CheckMongoIndexSuperGroup()

func (*Rep) IncrSuperGroupSeq

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

func (*Rep) IncrUserSeq

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

func (*Rep) SaveSuperGroupChatMongo2

func (r *Rep) SaveSuperGroupChatMongo2(spanCtx context.Context, groupId string, sendTime int64, m *chatpb.MsgDataToDB) error

func (*Rep) SaveUserChatMongo2

func (r *Rep) SaveUserChatMongo2(spanCtx context.Context, uid string, sendTime int64, m *chatpb.MsgDataToDB) error