engine

Documentation

Index

• type Engine
  • func NewEngine(rabbitMQConn *rabbitmq.Connection, orderDao interfaces.OrderDao, ...) *Engine
  • func (e *Engine) HandleOrders(msg *rabbitmq.Message) error
  • func (e *Engine) Provider() interfaces.EthereumProvider
• type OrderBook
  • func NewOrderBook(rabbitMQConn *rabbitmq.Connection, orderDao interfaces.OrderDao, ...) *OrderBook

Types

type Engine

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

Engine contains daos required for engine to work

func NewEngine

func NewEngine(
	rabbitMQConn *rabbitmq.Connection,
	orderDao interfaces.OrderDao,
	tradeDao interfaces.TradeDao,
	pairDao interfaces.PairDao,
	provider *ethereum.EthereumProvider,
) *Engine

NewEngine initializes the engine singleton instance

func (*Engine) HandleOrders

func (e *Engine) HandleOrders(msg *rabbitmq.Message) error

HandleOrders parses incoming rabbitmq order messages and redirects them to the appropriate engine function

func (*Engine) Provider

func (e *Engine) Provider() interfaces.EthereumProvider

Provider : implement engine interface

type OrderBook

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

func NewOrderBook

func NewOrderBook(
	rabbitMQConn *rabbitmq.Connection,
	orderDao interfaces.OrderDao,
	tradeDao interfaces.TradeDao,
	p types.Pair,
) *OrderBook