mysql

Documentation

Index

• func NewUserAssetEventRepository(db *gorm.DB) domain.IUserAssetEventRepository
• func NewUserAssetRecordRepository(db *gorm.DB) domain.IUserAssetRecordRepository
• func NewUserAssetRepository(db *gorm.DB) domain.IUserAssetRepository
• type UserAssetEventRepository
  • func (m *UserAssetEventRepository) ChangeUsersAssetTx(ctx context.Context, event *station.BizEventAssetChange) (err error)
• type UserAssetRecordRepository
  • func (m *UserAssetRecordRepository) GetRecordsByUserChangeAssetEvent(ctx context.Context, event *station.BizEventAssetChange) (res []*model.UserAssetRecord, err error)
  • func (m *UserAssetRecordRepository) GetRecordsByUserId(ctx context.Context, userId int64) (res []*model.UserAssetRecord, nextCursor string, err error)
• type UserAssetRepository
  • func (m *UserAssetRepository) GetUserAssets(ctx context.Context, userIds []int64) ([]*model.UserAsset, error)

Functions

func NewUserAssetEventRepository

func NewUserAssetEventRepository(db *gorm.DB) domain.IUserAssetEventRepository

func NewUserAssetRecordRepository

func NewUserAssetRecordRepository(db *gorm.DB) domain.IUserAssetRecordRepository

func NewUserAssetRepository

func NewUserAssetRepository(db *gorm.DB) domain.IUserAssetRepository

Types

type UserAssetEventRepository

type UserAssetEventRepository struct {
	// contains filtered or unexported fields
}

func (*UserAssetEventRepository) ChangeUsersAssetTx

func (m *UserAssetEventRepository) ChangeUsersAssetTx(ctx context.Context, event *station.BizEventAssetChange) (err error)

type UserAssetRecordRepository

type UserAssetRecordRepository struct {
	// contains filtered or unexported fields
}

func (*UserAssetRecordRepository) GetRecordsByUserChangeAssetEvent

func (m *UserAssetRecordRepository) GetRecordsByUserChangeAssetEvent(ctx context.Context, event *station.BizEventAssetChange) (res []*model.UserAssetRecord, err error)

func (*UserAssetRecordRepository) GetRecordsByUserId

func (m *UserAssetRecordRepository) GetRecordsByUserId(ctx context.Context, userId int64) (res []*model.UserAssetRecord, nextCursor string, err error)

type UserAssetRepository

type UserAssetRepository struct {
	// contains filtered or unexported fields
}

func (*UserAssetRepository) GetUserAssets

func (m *UserAssetRepository) GetUserAssets(ctx context.Context, userIds []int64) ([]*model.UserAsset, error)