Versions in this module Expand all Collapse all v1 v1.0.1 Feb 25, 2019 v1.0.0 Jan 30, 2019 Changes in this version + type Operator struct + Broker *rabbitmq.Connection + EthereumProvider interfaces.EthereumProvider + Exchange interfaces.Exchange + OrderService interfaces.OrderService + QueueAddressIndex map[common.Address]*TxQueue + TradeService interfaces.TradeService + TxQueues []*TxQueue + WalletService interfaces.WalletService + func NewOperator(walletService interfaces.WalletService, tradeService interfaces.TradeService, ...) (*Operator, error) + func (op *Operator) FeeAccount() (common.Address, error) + func (op *Operator) GetShortestQueue() (*TxQueue, int, error) + func (op *Operator) GetTxSendOptions() (*bind.TransactOpts, error) + func (op *Operator) HandleError(m *types.Matches) + func (op *Operator) HandleEvents() error + func (op *Operator) HandleTrades(msg *types.OperatorMessage) error + func (op *Operator) HandleTxError(m *types.Matches, id int) + func (op *Operator) HandleTxSuccess(m *types.Matches, receipt *eth.Receipt) + func (op *Operator) Operator(addr common.Address) (bool, error) + func (op *Operator) PurgeQueues() error + func (op *Operator) QueueTrade(m *types.Matches) error + type OperatorInterface interface + FeeAccount func() (common.Address, error) + GetShortestQueue func() (*TxQueue, int, error) + Operator func(addr common.Address) (bool, error) + QueueTrade func(o *types.Order, t *types.Trade) error + type TxQueue struct + Broker *rabbitmq.Connection + EthereumProvider interfaces.EthereumProvider + Exchange interfaces.Exchange + Name string + OrderService interfaces.OrderService + TradeService interfaces.TradeService + Wallet *types.Wallet + func NewTxQueue(n string, tr interfaces.TradeService, p interfaces.EthereumProvider, ...) (*TxQueue, error) + func (txq *TxQueue) ExecuteTrade(m *types.Matches, tag uint64) error + func (txq *TxQueue) GetChannel() *amqp.Channel + func (txq *TxQueue) GetTxCallOptions() *ethereum.CallMsg + func (txq *TxQueue) GetTxSendOptions() *bind.TransactOpts + func (txq *TxQueue) HandleError(m *types.Matches) error + func (txq *TxQueue) HandleTradeInvalid(m *types.Matches) error + func (txq *TxQueue) HandleTxError(m *types.Matches) error + func (txq *TxQueue) HandleTxSuccess(m *types.Matches, receipt *eth.Receipt) error + func (txq *TxQueue) Length() int + func (txq *TxQueue) PublishPendingTrades(m *types.Matches) error + func (txq *TxQueue) PurgePendingTrades() error
Go to main page