Versions in this module Expand all Collapse all v1 v1.0.0 Jun 11, 2018 Changes in this version + type Executor struct + EtcdClient *clientv3.Client + func NewExecutor() *Executor + func (e *Executor) NewTrade(initiator *model.Order, completion *model.Order, price decimal.Decimal, ...) error + type Level struct + Order []*model.Order + Price decimal.Decimal + type LevelHeap []Level + func (h *LevelHeap) Peek() *Level + func (h *LevelHeap) Pop() interface{} + func (h *LevelHeap) Push(x interface{}) + func (h *LevelHeap) Remove(o model.Order) error + func (h LevelHeap) Len() int + func (h LevelHeap) Less(i, j int) bool + func (h LevelHeap) Swap(i, j int) + type MarketData struct + Executor *Executor + func NewMarketData(futuresID string) *MarketData + func (m *MarketData) BroadcastOrderBook() + func (m *MarketData) NewCancelOrder(o model.Order) + func (m *MarketData) NewLimitOrder(order model.Order) + func (m *MarketData) NewMarketOrder(order model.Order) + func (m *MarketData) NewStopOrder(order model.Order) + func (m *MarketData) TriggerStopOrder(prev decimal.Decimal, current decimal.Decimal) + type MatchHandler struct + func (h *MatchHandler) HandleMessage(m *nsq.Message) error + type Matcher struct + MarketDataMap map[string]*MarketData + func NewMatcher() *Matcher + type MaxHeap struct + func NewMaxHeap() *MaxHeap + func (h MaxHeap) Less(i, j int) bool + type MinHeap struct + func NewMinHeap() *MinHeap + func (h MinHeap) Less(i, j int) bool