engine

Documentation

Index

• type Engine
  • func NewEngine(rabbitMQConn *rabbitmq.Connection, orderDao interfaces.OrderDao, ...) *Engine
  • func (e *Engine) HandleOrders(msg *rabbitmq.Message) error
• type OrderBook
  • func (ob *OrderBook) InvalidateOrder(o *types.Order) (*types.EngineResponse, error)

Types

type Engine

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

Engine

func NewEngine

func NewEngine(
	rabbitMQConn *rabbitmq.Connection,
	orderDao interfaces.OrderDao,
	tradeDao interfaces.TradeDao,
	pairDao interfaces.PairDao,
) *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

type OrderBook

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

func (*OrderBook) InvalidateOrder

func (ob *OrderBook) InvalidateOrder(o *types.Order) (*types.EngineResponse, error)