engine

Documentation

Index

• type DBHandler
• type Engine
  • func NewEngine(ctx context.Context) *Engine
  • func (e *Engine) HandleNewOrder(order *common.MemoryOrder) (matchResult common.MatchResult, hasMatch bool)
  • func (e *Engine) RegisterDBHandler(handler DBHandler)
  • func (e *Engine) RegisterOrderBookActivitiesHandler(handler OrderBookActivitiesHandler)
  • func (e *Engine) RegisterOrderBookSnapshotHandler(handler OrderBookSnapshotHandler)
• type MarketHandler
  • func NewMarketHandler(ctx context.Context, market string) (*MarketHandler, error)
• type OrderBookActivitiesHandler
• type OrderBookSnapshotHandler

Types

type DBHandler

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

type Engine

type Engine struct {

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

func NewEngine

func NewEngine(ctx context.Context) *Engine

func (*Engine) HandleNewOrder

func (e *Engine) HandleNewOrder(order *common.MemoryOrder) (matchResult common.MatchResult, hasMatch bool)

func (*Engine) RegisterDBHandler

func (e *Engine) RegisterDBHandler(handler DBHandler)

func (*Engine) RegisterOrderBookActivitiesHandler

func (e *Engine) RegisterOrderBookActivitiesHandler(handler OrderBookActivitiesHandler)

func (*Engine) RegisterOrderBookSnapshotHandler

func (e *Engine) RegisterOrderBookSnapshotHandler(handler OrderBookSnapshotHandler)

type MarketHandler

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

func NewMarketHandler

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

type OrderBookActivitiesHandler

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

type OrderBookSnapshotHandler

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