Versions in this module Expand all Collapse all v1 v1.1.0 Sep 13, 2020 Changes in this version + var User1PrivateKey string + func InitWsQueue(queue common.IQueue) + func InsertOrder(order *models.Order) error + func InsertTrade(trade *models.Trade) error + func Run(ctx context.Context, startMetrics func()) + func UpdateOrder(order *models.Order) error + func UpdateTrade(trade *models.Trade) error + type DexEngine struct + HydroEngine *engine.Engine + Wg sync.WaitGroup + func NewDexEngine(ctx context.Context) *DexEngine + type MarketHandler struct + func NewMarketHandler(ctx context.Context, market *models.Market, engine *engine.Engine) (*MarketHandler, error) + func (m *MarketHandler) Run() + func (m *MarketHandler) Stop() + type MatchResultWithOrders struct + Sequence uint64 + func NewMatchResultWithOrders(takerOrder *models.Order, result *common.MatchResult) *MatchResultWithOrders + type RedisOrderBookActivitiesHandler struct + func (handler RedisOrderBookActivitiesHandler) Update(webSocketMessages []common.WebSocketMessage) sync.WaitGroup + type RedisOrderBookSnapshotHandler struct + func (handler RedisOrderBookSnapshotHandler) Update(key string, bookSnapshot *common.SnapshotV2) sync.WaitGroup
Go to main page