txmanager

Documentation

Index

• Constants
• Variables
• func ExistFillOwnerCache(txhash common.Hash, owner common.Address) (bool, error)
• func GetAllTransactionCount(ownerStr, symbol, status, typ string) (int, error)
• func GetAllTransactions(owner, symbol, status, typ string, limit, offset int) ([]txtyp.TransactionJsonResult, error)
• func GetPendingTransactions(owner string) ([]txtyp.TransactionJsonResult, error)
• func GetTransactionsByHash(owner string, hashList []string) ([]txtyp.TransactionJsonResult, error)
• func NewTxView(db dao.RdsService)
• func RollbackCache(from, to int64) error
• func SaveEntityCache(entity dao.TransactionEntity) error
• func SetFillOwnerCache(txhash common.Hash, owner common.Address) error
• type TransactionEntityMap
  • func GetEntityCache(db dao.RdsService, views []dao.TransactionView) TransactionEntityMap
• type TransactionManager
  • func NewTxManager(db dao.RdsService, accountmanager *market.AccountManager) TransactionManager
  • func (tm *TransactionManager) ForkProcess(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveApproveEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveCutoffAllEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveCutoffPairEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveEthTransferEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveOrderCancelledEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveOrderFilledEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveTransferEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveWethDepositEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) SaveWethWithdrawalEvent(input eventemitter.EventData) error
  • func (tm *TransactionManager) Start()
  • func (tm *TransactionManager) Stop()
• type TransactionViewer
• type TransactionViewerImpl
  • func (impl *TransactionViewerImpl) GetAllTransactionCount(ownerStr, symbolStr, statusStr, typStr string) (int, error)
  • func (impl *TransactionViewerImpl) GetAllTransactions(ownerStr, symbolStr, statusStr, typStr string, limit, offset int) ([]txtyp.TransactionJsonResult, error)
  • func (impl *TransactionViewerImpl) GetPendingTransactions(ownerStr string) ([]txtyp.TransactionJsonResult, error)
  • func (impl *TransactionViewerImpl) GetTransactionsByHash(ownerStr string, hashList []string) ([]txtyp.TransactionJsonResult, error)

Constants

const (
	FillOwnerPrefix = "txm_fill_owner_"
	FillOwnerTtl    = 600           // todo 临时数据,只存储10分钟,系统性宕机后无法重启后丢失?
	TxEntityPrefix  = "txm_entity_" // txm_entity_blocknumber_txhash_logIndex,不用hash结构,避免不同用户数据在同一个key的情况
	TxEntityTtl     = 86400
)

Variables

var (
	ErrOwnerAddressInvalid error = errors.New("owner address invalid")
	ErrHashListEmpty       error = errors.New("hash list is empty")
	ErrNonTransaction      error = errors.New("no transaction found")
)

Functions

func ExistFillOwnerCache

func ExistFillOwnerCache(txhash common.Hash, owner common.Address) (bool, error)

func GetAllTransactionCount

func GetAllTransactionCount(ownerStr, symbol, status, typ string) (int, error)

func GetAllTransactions

func GetAllTransactions(owner, symbol, status, typ string, limit, offset int) ([]txtyp.TransactionJsonResult, error)

func GetPendingTransactions

func GetPendingTransactions(owner string) ([]txtyp.TransactionJsonResult, error)

func GetTransactionsByHash

func GetTransactionsByHash(owner string, hashList []string) ([]txtyp.TransactionJsonResult, error)

func NewTxView

func NewTxView(db dao.RdsService)

todo(fuk): 在分布式锁以及wallet_service事件通知推送落地后使用redis缓存(当前版本暂时不考虑redis),考虑到分叉及用户tx总量， 缓存应该有三个数据类型: 1. user key 存储用户pengding&mined first page transactions,设置过期时间 2. user tx number key存储某个用户所有tx数量的key,设置过期时间 3. block key 存储某个block涉及到的用户key(用于分叉),设置过期时间

func RollbackCache

func RollbackCache(from, to int64) error

func SaveEntityCache

func SaveEntityCache(entity dao.TransactionEntity) error

func SetFillOwnerCache

func SetFillOwnerCache(txhash common.Hash, owner common.Address) error

Types

type TransactionEntityMap

type TransactionEntityMap map[string]map[int64]dao.TransactionEntity

func GetEntityCache

func GetEntityCache(db dao.RdsService, views []dao.TransactionView) TransactionEntityMap

GetEntityCache return map[hash][logindex]dao.transactionEntity todo get multi key from redis with lua

type TransactionManager

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

func NewTxManager

func NewTxManager(db dao.RdsService, accountmanager *market.AccountManager) TransactionManager

func (*TransactionManager) ForkProcess

func (tm *TransactionManager) ForkProcess(input eventemitter.EventData) error

todo: check and test

func (*TransactionManager) SaveApproveEvent

func (tm *TransactionManager) SaveApproveEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveCutoffAllEvent

func (tm *TransactionManager) SaveCutoffAllEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveCutoffPairEvent

func (tm *TransactionManager) SaveCutoffPairEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveEthTransferEvent

func (tm *TransactionManager) SaveEthTransferEvent(input eventemitter.EventData) error

普通的transaction 当value大于0时认为是eth转账 当value等于0时认为是调用系统不支持的合约,默认使用fromTransferEvent/send type为unsupported_contract

func (*TransactionManager) SaveOrderCancelledEvent

func (tm *TransactionManager) SaveOrderCancelledEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveOrderFilledEvent

func (tm *TransactionManager) SaveOrderFilledEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveTransferEvent

func (tm *TransactionManager) SaveTransferEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveWethDepositEvent

func (tm *TransactionManager) SaveWethDepositEvent(input eventemitter.EventData) error

func (*TransactionManager) SaveWethWithdrawalEvent

func (tm *TransactionManager) SaveWethWithdrawalEvent(input eventemitter.EventData) error

func (*TransactionManager) Start

func (tm *TransactionManager) Start()

Start start orderbook as a service

func (*TransactionManager) Stop

func (tm *TransactionManager) Stop()

type TransactionViewer

type TransactionViewer interface {
	GetPendingTransactions(owner string) ([]txtyp.TransactionJsonResult, error)
	GetAllTransactionCount(owner, symbol, status, typ string) (int, error)
	GetAllTransactions(owner, symbol, status, typ string, limit, offset int) ([]txtyp.TransactionJsonResult, error)
	GetTransactionsByHash(owner string, hashList []string) ([]txtyp.TransactionJsonResult, error)
}

type TransactionViewerImpl

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

func (*TransactionViewerImpl) GetAllTransactionCount

func (impl *TransactionViewerImpl) GetAllTransactionCount(ownerStr, symbolStr, statusStr, typStr string) (int, error)

func (*TransactionViewerImpl) GetAllTransactions

func (impl *TransactionViewerImpl) GetAllTransactions(ownerStr, symbolStr, statusStr, typStr string, limit, offset int) ([]txtyp.TransactionJsonResult, error)

func (*TransactionViewerImpl) GetPendingTransactions

func (impl *TransactionViewerImpl) GetPendingTransactions(ownerStr string) ([]txtyp.TransactionJsonResult, error)

func (*TransactionViewerImpl) GetTransactionsByHash

func (impl *TransactionViewerImpl) GetTransactionsByHash(ownerStr string, hashList []string) ([]txtyp.TransactionJsonResult, error)