Versions in this module Expand all Collapse all v0 v0.0.2 Oct 30, 2019 v0.0.1 Oct 30, 2019 Changes in this version + type Backend interface + Consume func() interface{} + Publish func(interface{}) error + type Batch struct + Asks []matcheng.AggregatePrice + Bids []matcheng.AggregatePrice + BlockNumber int64 + BlockTime time.Time + ClearingPrice sdk.Uint + MarketID store.EntityID + type BurnCreated struct + AssetID store.EntityID + Beneficiary []byte + BlockNumber int64 + Burner sdk.AccAddress + ID store.EntityID + Quantity sdk.Uint + type EventHandler interface + OnEvent func(event interface{}) error + type Fill struct + BlockNumber int64 + BlockTime int64 + Direction matcheng.Direction + MarketID store.EntityID + OrderID store.EntityID + Owner sdk.AccAddress + Pair string + Price sdk.Uint + QtyFilled sdk.Uint + QtyUnfilled sdk.Uint + type LocalConsumer struct + func NewLocalConsumer(queue Backend, hdlrs []EventHandler) *LocalConsumer + func (s *LocalConsumer) Start() + func (s *LocalConsumer) Stop() + type MemBackend struct + func NewMemBackend() *MemBackend + func (m *MemBackend) Consume() interface{} + func (m *MemBackend) Publish(item interface{}) error + func (m *MemBackend) Start() + func (m *MemBackend) Stop() + type OrderCancelled struct + OrderID store.EntityID + type OrderCreated struct + CreatedBlock int64 + Direction matcheng.Direction + ID store.EntityID + MarketID store.EntityID + Owner sdk.AccAddress + Price sdk.Uint + Quantity sdk.Uint + TimeInForceBlocks uint16