logic

Documentation

Index

• type AddUserAssetLogic
  • func NewAddUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AddUserAssetLogic
  • func (l *AddUserAssetLogic) AddUserAsset(in *pb.AddUserAssetReq) (*pb.Empty, error)
• type DeductUserAssetLogic
  • func NewDeductUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeductUserAssetLogic
  • func (l *DeductUserAssetLogic) DeductUserAsset(in *pb.DeductUserAssetReq) (*pb.Empty, error)
• type FreezeUserAssetLogic
  • func NewFreezeUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FreezeUserAssetLogic
  • func (l *FreezeUserAssetLogic) FreezeUserAsset(in *pb.FreezeUserAssetReq) (*pb.Empty, error)
• type GetUserAssetByCoinLogic
  • func NewGetUserAssetByCoinLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserAssetByCoinLogic
  • func (l *GetUserAssetByCoinLogic) GetUserAssetByCoin(in *pb.GetUserAssetReq) (*pb.GetUserAssetResp, error)
• type GetUserAssetListLogic
  • func NewGetUserAssetListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserAssetListLogic
  • func (l *GetUserAssetListLogic) GetUserAssetList(in *pb.GetUserAssetListReq) (*pb.GetUserAssetListResp, error)
• type HandleMatchResultLogic
  • func NewHandleMatchResultLogic(svcCtx *svc.ServiceContext) *HandleMatchResultLogic
  • func (l *HandleMatchResultLogic) HandleCancelOrder(cancelResp *matchMq.MatchResp_Cancel, storeConsumedMessageId func() error) error
  • func (l *HandleMatchResultLogic) HandleMatchResult(result *matchMq.MatchResp_MatchResult, storeConsumedMessageId func() error) error
• type LoginLogic
  • func NewLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginLogic
  • func (l *LoginLogic) Login(in *pb.LoginReq) (*pb.LoginResp, error)
• type LoginOutLogic
  • func NewLoginOutLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginOutLogic
  • func (l *LoginOutLogic) LoginOut(in *pb.LoginOutReq) (*pb.Empty, error)
• type RegisterLogic
  • func NewRegisterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegisterLogic
  • func (l *RegisterLogic) Register(in *pb.RegisterReq) (*pb.RegisterResp, error)
• type UnFreezeUserAssetLogic
  • func NewUnFreezeUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UnFreezeUserAssetLogic
  • func (l *UnFreezeUserAssetLogic) UnFreezeUserAsset(in *pb.FreezeUserAssetReq) (*pb.Empty, error)
• type ValidateTokenLogic
  • func NewValidateTokenLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ValidateTokenLogic
  • func (l *ValidateTokenLogic) ValidateToken(in *pb.ValidateTokenReq) (*pb.ValidateTokenResp, error)

Types

type AddUserAssetLogic

type AddUserAssetLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewAddUserAssetLogic

func NewAddUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AddUserAssetLogic

func (*AddUserAssetLogic) AddUserAsset

func (l *AddUserAssetLogic) AddUserAsset(in *pb.AddUserAssetReq) (*pb.Empty, error)

增加用户资产

type DeductUserAssetLogic

type DeductUserAssetLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeductUserAssetLogic

func NewDeductUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeductUserAssetLogic

func (*DeductUserAssetLogic) DeductUserAsset

func (l *DeductUserAssetLogic) DeductUserAsset(in *pb.DeductUserAssetReq) (*pb.Empty, error)

扣减用户资产

type FreezeUserAssetLogic

type FreezeUserAssetLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewFreezeUserAssetLogic

func NewFreezeUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *FreezeUserAssetLogic

func (*FreezeUserAssetLogic) FreezeUserAsset

func (l *FreezeUserAssetLogic) FreezeUserAsset(in *pb.FreezeUserAssetReq) (*pb.Empty, error)

冻结用户资产。

type GetUserAssetByCoinLogic

type GetUserAssetByCoinLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetUserAssetByCoinLogic

func NewGetUserAssetByCoinLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserAssetByCoinLogic

func (*GetUserAssetByCoinLogic) GetUserAssetByCoin

func (l *GetUserAssetByCoinLogic) GetUserAssetByCoin(in *pb.GetUserAssetReq) (*pb.GetUserAssetResp, error)

获取用户指定币种的资产

type GetUserAssetListLogic

type GetUserAssetListLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetUserAssetListLogic

func NewGetUserAssetListLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetUserAssetListLogic

func (*GetUserAssetListLogic) GetUserAssetList

func (l *GetUserAssetListLogic) GetUserAssetList(in *pb.GetUserAssetListReq) (*pb.GetUserAssetListResp, error)

GetUserAssetList 获取用户所有币中资产。

type HandleMatchResultLogic

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

HandleMatchResultLogic 结算

func NewHandleMatchResultLogic

func NewHandleMatchResultLogic(svcCtx *svc.ServiceContext) *HandleMatchResultLogic

func (*HandleMatchResultLogic) HandleCancelOrder

func (l *HandleMatchResultLogic) HandleCancelOrder(cancelResp *matchMq.MatchResp_Cancel, storeConsumedMessageId func() error) error

HandleCancelOrder 取消订单解冻

func (*HandleMatchResultLogic) HandleMatchResult

func (l *HandleMatchResultLogic) HandleMatchResult(result *matchMq.MatchResp_MatchResult, storeConsumedMessageId func() error) error

HandleMatchResult 结算，扣减用户资产

type LoginLogic

type LoginLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewLoginLogic

func NewLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginLogic

func (*LoginLogic) Login

func (l *LoginLogic) Login(in *pb.LoginReq) (*pb.LoginResp, error)

登录

type LoginOutLogic

type LoginOutLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewLoginOutLogic

func NewLoginOutLogic(ctx context.Context, svcCtx *svc.ServiceContext) *LoginOutLogic

func (*LoginOutLogic) LoginOut

func (l *LoginOutLogic) LoginOut(in *pb.LoginOutReq) (*pb.Empty, error)

登出

type RegisterLogic

type RegisterLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewRegisterLogic

func NewRegisterLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RegisterLogic

func (*RegisterLogic) Register

func (l *RegisterLogic) Register(in *pb.RegisterReq) (*pb.RegisterResp, error)

注册

type UnFreezeUserAssetLogic

type UnFreezeUserAssetLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewUnFreezeUserAssetLogic

func NewUnFreezeUserAssetLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UnFreezeUserAssetLogic

func (*UnFreezeUserAssetLogic) UnFreezeUserAsset

func (l *UnFreezeUserAssetLogic) UnFreezeUserAsset(in *pb.FreezeUserAssetReq) (*pb.Empty, error)

解冻用户资产

type ValidateTokenLogic

type ValidateTokenLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewValidateTokenLogic

func NewValidateTokenLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ValidateTokenLogic

func (*ValidateTokenLogic) ValidateToken

func (l *ValidateTokenLogic) ValidateToken(in *pb.ValidateTokenReq) (*pb.ValidateTokenResp, error)

验证token是否有效。