game

Documentation

Index

• Constants
• type CbManager
  • func NewCbManager(tracker TxTracker) *CbManager
  • func (cm *CbManager) Run()
  • func (cm *CbManager) Update(event interface{})
• type NftManager
  • func NewNftManager(tracker NftOwnerTracker) *NftManager
  • func (nm *NftManager) Update(event interface{})
• type NftOwnerTracker
• type NftOwnerUpdateEvent
• type NotifyEvent
• type TxTracker

Constants

const (
	HANDLEDURATION      = 10 * time.Minute
	TXTIMEOUTDURATION   = 20 * time.Minute
	LOCKTIMEOUTDURATION = 5 * time.Minute
)

Types

type CbManager

type CbManager struct {
	TxTracker
}

var (
	CbMgr *CbManager
)

func NewCbManager

func NewCbManager(tracker TxTracker) *CbManager

func (*CbManager) Run

func (cm *CbManager) Run()

func (*CbManager) Update

func (cm *CbManager) Update(event interface{})

type NftManager

type NftManager struct {
	NftOwnerTracker
}

func NewNftManager

func NewNftManager(tracker NftOwnerTracker) *NftManager

func (*NftManager) Update

func (nm *NftManager) Update(event interface{})

type NftOwnerTracker

type NftOwnerTracker interface {
	QueryNftList(ownerAddr string, contractAddr string) ([]model.NftOwner, error)
	AddNftOwner(no model.NftOwner) error
	UpdateNftOwner(ownerAddr string, contractAddr string, tokenId int64, updateTime int64) error
	QueryNftOwner(tokenId int64, contractAddr string) ([]model.NftOwner, error)
}

type NftOwnerUpdateEvent

type NftOwnerUpdateEvent struct {
	OwnerAddr    string
	ContractAddr string
	TokenId      int64
	UpdateTime   int64
}

type NotifyEvent

type NotifyEvent struct {
	TxHash  string
	Status  int
	PayTime int64
}

type TxTracker

type TxTracker interface {
	SaveTxCb(tx model.SpikeTx) error
	RecordTxHash(uuidList []string, txHash string, txStatus int) error
	QueryGameCb(txHash string, notifyStatus int) ([]model.SpikeTx, error)
	UpdateTxStatus(txHash string, txStatus int, payTime int64) error
	UpdateTxNotifyStatus(orderId string, notifyStatus int) error
	QueryNotNotifyTx(notNotifyStatus int) ([]model.SpikeTx, error)
}