-
Создадим конфигурационный объект.
Подробнее описано в README CCXT_BeYANG
cfg := config.New(bybitWS.HostPublicMainnetSpot, true)
-
Создадим объект подключения, указав относительный путь до файла-логера, куда будет выводиться вся информация в дальнейшем. Коннектимся к бирже
b := bybitWS.New(bybitWS.SpotTrading, cfg, "bybitTestLog.log")
ws.Start(b)
-
Создаем элемент или массив элементов, которые нам необходимо отправить.
Например, если отправляемые данные - валютные пары (tickers.{symbol}), то отправляем именно их
symbols1 := []string{
"btc",
"eth",
"xrp",
"ada",
"sol",
}
symbol2 := "usdt"
var pairs []string
for _, symbol1 := range symbols1 {
pairs = append(pairs, b.GetPair(symbol1, symbol2))
}
ws.Subscribe(b, bybitWS.ChannelTicker, pairs)
-
Подключаем к потоку с каналом, на который мы только что подписались, функцию, для взаимодействия с получаемыми данными
Примечание
Иногда, возвращаемые данные зависят от того, к каналу с каким видом торговли совершенно подключение (Spot/Optional/Linear/Inverse)
Функция:
func handleBookTicker(name string, symbol string, data bybitWS.TickerSpot) {
log.Printf("%s TickerSpot %s: %v", name, symbol, data)
}
Подключение:
b.GetEmitter().On(bybitWS.ChannelTicker, handleBookTicker)
-
Не забываем создать что-нибудь, чтобы функция не завершилась. Это необходимо, т.к. все действия производятся в отдельных потоках
forever := make(chan struct{})
<-forever