exchange

type Exchange interface {
	Start() error
	Stop() error

	// KlineChan get klines
	KlineChan(start, end time.Time, symbol, bSize string) (data chan *Candle, err chan error)

	// watch kline changes
	WatchKline(symbols SymbolInfo) (datas chan *CandleInfo, stopC chan struct{}, err error)
	Watch(WatchParam) error

	// for trade
	// ProcessOrder process order
	ProcessOrder(act TradeAction) (ret *Order, err error)
	CancelAllOrders() (orders []*Order, err error)

	// GetBalanceChan
	GetDataChan() *ExchangeChan
}

type ExchangeChan struct {
	BalanceChan chan Balance
	PosChan     chan Position
	OrderChan   chan Order
	DepthChan   chan Depth
	TradeChan   chan Trade
}

type NewExchangeFn func(cfg *viper.Viper, cltName, symbol string) (t Exchange, err error)

type OrderInfo struct {
	Order
	Action TradeType
	Filled bool
}

type TradeExchange struct {
	BaseProcesser
	// contains filtered or unexported fields
}