repository

Documentation

Index

• type Rep
  • func NewRep(svcCtx *svc.ServiceContext) *Rep
  • func (r *Rep) CheckTable()
  • func (r *Rep) IncrGroupSeq(groupId string) (uint64, error)
  • func (r *Rep) IncrUserSeq(uid string) (uint64, error)
  • func (r *Rep) SaveGroupChatCassandra(spanCtx context.Context, groupId string, sendTime int64, m *chatpb.MsgDataToDB) error
  • func (r *Rep) SaveUserChatCassandra2(spanCtx context.Context, uid string, sendTime int64, m *chatpb.MsgDataToDB) error

Types

type Rep

type Rep struct {
	Cache redis.UniversalClient
	//mysql       *gorm.DB
	CassandraClient *gocql.Session
	// contains filtered or unexported fields
}

func NewRep

func NewRep(svcCtx *svc.ServiceContext) *Rep

func (*Rep) CheckTable

func (r *Rep) CheckTable()

func (*Rep) IncrGroupSeq

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

func (*Rep) IncrUserSeq

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

func (*Rep) SaveGroupChatCassandra

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

func (*Rep) SaveUserChatCassandra2

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