watchers

Documentation

Index

• type Balance
• type BalanceWatcher
  • func NewBalanceWatcher(ob *orderbook.MongoOrderBook, v *contracts.Vault, in <-chan Balance) BalanceWatcher
  • func (bw *BalanceWatcher) Watch()
• 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 Balance

type Balance struct {
	User  types.Address
	Token types.Address
}

type BalanceWatcher

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

func NewBalanceWatcher

func NewBalanceWatcher(ob *orderbook.MongoOrderBook, v *contracts.Vault, in <-chan Balance) BalanceWatcher

func (*BalanceWatcher) Watch

func (bw *BalanceWatcher) Watch()

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()
}