repository

package

v1.0.0-rc1 Latest Latest Go to latest Published: Jun 7, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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