Versions in this module Expand all Collapse all v1 v1.5.0 Jun 21, 2018 Changes in this version + const DefaultP2POrderExpireTime + const FORK_EVT_TYPE_CANCEL + const FORK_EVT_TYPE_CUTOFF + const FORK_EVT_TYPE_CUTOFF_PAIR + const FORK_EVT_TYPE_FILL + func FlexCancelOrder(event *types.FlexCancelOrderEvent) error + func HandleCutoffEvent(event *types.CutoffEvent) error + func HandleCutoffPair(event *types.CutoffPairEvent) error + func HandleGatewayOrder(state *types.OrderState) error + func HandleOrderCancelledEvent(event *types.OrderCancelledEvent) error + func HandleOrderFilledEvent(event *types.OrderFilledEvent) error + func HandleP2PRingMined(input eventemitter.EventData) error + func HandleRingMinedEvent(event *types.RingMinedEvent) error + func HandleSubmitRingMethodEvent(event *types.SubmitRingMethodEvent) error + func IsEventDuplicate(eventStatus types.TxStatus, modelStatus uint8) bool + func IsP2PMakerLocked(maker string) bool + func MinerOrders(delegate, tokenS, tokenB common.Address, length int, ...) []*types.OrderState + func NewOrderEntity(state *types.OrderState, blockNumber *big.Int) (*dao.Order, error) + func SaveP2POrderRelation(takerOwner, taker, makerOwner, maker, txHash string) error + func SettleOrderAmountOnChain(state *types.OrderState) error + func SettleOrderStatus(state *types.OrderState, isCancel bool) + func UpdateBroadcastTimeByHash(hash common.Hash, bt int) error + type BaseHandler struct + CutoffCache *omcm.CutoffCache + MarketCap marketcap.MarketCapProvider + Rds *dao.RdsService + TxInfo types.TxInfo + type EventStatusHandler interface + HandleFailed func() error + HandlePending func() error + HandleSuccess func() error + type ForkProcessor struct + func NewForkProcess() *ForkProcessor + func (p *ForkProcessor) Fork(event *types.ForkedEvent) error + func (p *ForkProcessor) GetForkEvents(from, to int64) (InnerForkEventList, error) + func (p *ForkProcessor) MarkForkEvents(from, to int64) error + func (p *ForkProcessor) RollBackSingleCancel(evt *types.OrderCancelledEvent) error + func (p *ForkProcessor) RollBackSingleCutoff(evt *types.CutoffEvent) error + func (p *ForkProcessor) RollBackSingleCutoffPair(evt *types.CutoffPairEvent) error + func (p *ForkProcessor) RollBackSingleFill(evt *types.OrderFilledEvent) error + type InnerForkEvent struct + BlockNumber int64 + Event interface{} + LogIndex int64 + Type string + type InnerForkEventList []InnerForkEvent + func (l InnerForkEventList) Len() int + func (l InnerForkEventList) Less(i, j int) bool + func (l InnerForkEventList) Swap(i, j int) + type OrderManager interface + Start func() + Stop func() + type OrderManagerImpl struct + func NewOrderManager(options *common.OrderManagerOptions, db *dao.RdsService, ...) *OrderManagerImpl + func (om *OrderManagerImpl) HandleOrderCorrelatedEvent(input eventemitter.EventData) error + func (om *OrderManagerImpl) HandlerOrderRelatedEvent(input eventemitter.EventData) error + func (om *OrderManagerImpl) Start() + func (om *OrderManagerImpl) Stop() + type OrderTxHandler struct + Event *omtyp.OrderTx + TxStatus types.TxStatus + func BaseOrderTxHandler(txinfo types.TxInfo) *OrderTxHandler + func FullOrderTxHandler(txinfo types.TxInfo, orderhash common.Hash, orderstatus types.OrderStatus) *OrderTxHandler + func (handler *OrderTxHandler) HandlerOrderCorrelatedTx() error + func (handler *OrderTxHandler) HandlerOrderRelatedTx() error
Go to main page