domain

Documentation

Index

• Variables
• type AssetIncrHandler
• type IUserAssetCallBack
• type IUserAssetEventMsgListener
• type IUserAssetEventMsgRepository
• type IUserAssetEventRepository
• type IUserAssetEventUseCase
• type IUserAssetRepository
• type UserAssetEventMsg

Variables

var (
	ErrorMsgDecode = errors.New("event msg decode error")
	ErrorEventDone = errors.New("event had been done")

	ErrorInternalRedis = errors.New("internal redis error")

	ErrorNoEnoughAsset             = errors.New("asset not enough")
	ErrorSetAssetFromCBTimeOut     = errors.New("set asset from db exec timeout")
	ErrorSetAssetDoneOut           = errors.New("set asset from db exec done out")
	ErrorWatchAssetCasLoopMaxRetry = errors.New("watch user asset CAS loop reached maximum number of retries")

	ErrorSendAssetChangeEventMsg = errors.New("send user asset change event msg fail")
)

Types

type AssetIncrHandler

type AssetIncrHandler func(ctx context.Context) (incrAssetCn int64)

type IUserAssetCallBack

type IUserAssetCallBack interface {
	GetAssets(ctx context.Context, userIds []int64) (assetDtos []*base.UserAsset, err error)
	SetAsset(ctx context.Context, userId int64, assetType base.AssetType) (err error)
}

type IUserAssetEventMsgListener

type IUserAssetEventMsgListener interface {
	primitive.TransactionListener
}

type IUserAssetEventMsgRepository

type IUserAssetEventMsgRepository interface {
	SendUserAssetChangeMsgTx(ctx context.Context, topicName, tagName string, userId int64, eventMsg *station.BizEventAssetChange, handler primitive.TxHandler) error
}

type IUserAssetEventRepository

type IUserAssetEventRepository interface {
	UserAssetChangeTx(ctx context.Context, eventId string, changeInfo *station.UserAssetChangeInfo, handle AssetIncrHandler) (*base.UserAsset, error)
	GetUserAssetEventMsg(ctx context.Context, userId int64, eventId string) (int, error)
}

type IUserAssetEventUseCase

type IUserAssetEventUseCase interface {
	UserAssetChangeTx(ctx context.Context, opUserType int, event *station.BizEventAssetChange, handle AssetIncrHandler) (*base.UserAsset, error)
}

type IUserAssetRepository

type IUserAssetRepository interface {
	GetAsset(ctx context.Context, key string) (assetObj *base.UserAsset, err error)
	SetAsset(ctx context.Context, key string, assetObj *base.UserAsset) (err error)
}

type UserAssetEventMsg

type UserAssetEventMsg struct {
	*station.BizEventAssetChange
}