manager

Documentation

Index

• type TransactionManager
  • func NewTxManager(db *dao.RdsService) 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) SaveUnSupportedContractEvent(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()

Types

type TransactionManager

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

func NewTxManager

func NewTxManager(db *dao.RdsService) 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) SaveUnSupportedContractEvent

func (tm *TransactionManager) SaveUnSupportedContractEvent(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()