watchers

Documentation

Index

• type CancelledWatcher
  • func NewCancelledWatcher(book orderbook.OrderBook, in <-chan *consumers.CancelledMessage) CancelledWatcher
  • func (cw *CancelledWatcher) Watch()
• type TradeWatcher
  • func NewTradeWatcher(history history.History, exchange *contracts.Exchange, ...) TradeWatcher
  • func (tf *TradeWatcher) Watch()
• type Watcher

Types

type CancelledWatcher

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

func NewCancelledWatcher

func NewCancelledWatcher(book orderbook.OrderBook, in <-chan *consumers.CancelledMessage) CancelledWatcher

func (*CancelledWatcher) Watch

func (cw *CancelledWatcher) Watch()

type TradeWatcher

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

func NewTradeWatcher

func NewTradeWatcher(history history.History, exchange *contracts.Exchange, book orderbook.OrderBook, in <-chan *consumers.TradedMessage) TradeWatcher

func (*TradeWatcher) Watch

func (tf *TradeWatcher) Watch()

type Watcher

type Watcher interface {
	Watch()
}