engine

package

v0.0.1 Latest Latest Go to latest Published: Apr 16, 2019 License: Apache-2.0 Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

func MessagesForUpdateOrder(order *common.MemoryOrder) []common.WebSocketMessage

type DBHandler interface {
	Update(matchResult common.MatchResult) sync.WaitGroup
}

type Engine struct {

	// Wait for all queue handler exit gracefully
	Wg sync.WaitGroup
	// contains filtered or unexported fields
}

func NewEngine(ctx context.Context) *Engine

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

func NewMarketHandler(ctx context.Context, market string) (*MarketHandler, error)

type OrderBookActivitiesHandler interface {
	Update(webSocketMessages []common.WebSocketMessage) sync.WaitGroup
}

type OrderBookSnapshotHandler interface {
	Update(key string, snapshot *common.SnapshotV2) sync.WaitGroup
}

type Orderbook struct {
	*common.Orderbook
	Sequence uint64
}

func NewOrderbook(marketID string) *Orderbook