redis

Documentation

Index

• func NewUserAssetCallBack(daClient paymentservice.Client, locker *redsync.Redsync, ...) domain.IUserAssetCallBack
• func NewUserAssetEventRepository(redisClient redis.UniversalClient, cb domain.IUserAssetCallBack, method string) domain.IUserAssetEventRepository
• func NewUserAssetRepository(redisClient redis.UniversalClient) domain.IUserAssetRepository
• type UserAssetCallBack
  • func (m *UserAssetCallBack) GetAssets(ctx context.Context, userIds []int64) (assetDtos []*base.UserAsset, err error)
  • func (m *UserAssetCallBack) GetUserAssetByType(ctx context.Context, userId int64, assetType base.AssetType) (assetDto *base.UserAsset, err error)
  • func (m *UserAssetCallBack) SetAsset(ctx context.Context, userId int64, assetType base.AssetType) (err error)
• type UserAssetEventRepository
  • func (m *UserAssetEventRepository) GetUserAssetEventMsg(ctx context.Context, userId int64, eventId string) (res int, err error)
  • func (m *UserAssetEventRepository) UserAssetChangeTx(ctx context.Context, eventId string, changeInfo *station.UserAssetChangeInfo, ...) (userAsset *base.UserAsset, err error)
• type UserAssetRepository
  • func (m *UserAssetRepository) GetAsset(ctx context.Context, key string) (assetObj *base.UserAsset, err error)
  • func (m *UserAssetRepository) SetAsset(ctx context.Context, key string, assetObj *base.UserAsset) (err error)

Functions

func NewUserAssetCallBack

func NewUserAssetCallBack(daClient paymentservice.Client, locker *redsync.Redsync, userAssetRepos domain.IUserAssetRepository, sfGroup *singleflight.Group) domain.IUserAssetCallBack

func NewUserAssetEventRepository

func NewUserAssetEventRepository(redisClient redis.UniversalClient, cb domain.IUserAssetCallBack, method string) domain.IUserAssetEventRepository

func NewUserAssetRepository

func NewUserAssetRepository(redisClient redis.UniversalClient) domain.IUserAssetRepository

Types

type UserAssetCallBack

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

func (*UserAssetCallBack) GetAssets

func (m *UserAssetCallBack) GetAssets(ctx context.Context, userIds []int64) (assetDtos []*base.UserAsset, err error)

func (*UserAssetCallBack) GetUserAssetByType

func (m *UserAssetCallBack) GetUserAssetByType(ctx context.Context, userId int64, assetType base.AssetType) (assetDto *base.UserAsset, err error)

func (*UserAssetCallBack) SetAsset

func (m *UserAssetCallBack) SetAsset(ctx context.Context, userId int64, assetType base.AssetType) (err error)

type UserAssetEventRepository

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

func (*UserAssetEventRepository) GetUserAssetEventMsg

func (m *UserAssetEventRepository) GetUserAssetEventMsg(ctx context.Context, userId int64, eventId string) (res int, err error)

func (*UserAssetEventRepository) UserAssetChangeTx

func (m *UserAssetEventRepository) UserAssetChangeTx(ctx context.Context, eventId string, changeInfo *station.UserAssetChangeInfo, handle domain.AssetIncrHandler) (userAsset *base.UserAsset, err error)

type UserAssetRepository

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

func (*UserAssetRepository) GetAsset

func (m *UserAssetRepository) GetAsset(ctx context.Context, key string) (assetObj *base.UserAsset, err error)

func (*UserAssetRepository) SetAsset

func (m *UserAssetRepository) SetAsset(ctx context.Context, key string, assetObj *base.UserAsset) (err error)