blob: 60fb9122b94d8bde62d7b19d37bbe116a361a33b (
plain) (
tree)
|
|
package api
import (
"immae.eu/Immae/Projets/Cryptomonnaies/Cryptoportfolio/Front/markets"
)
var Poloniex *markets.Poloniex
func OpenMarketsConnection() error {
for {
err := Poloniex.StartTicker()
if err != nil {
return err
}
log.Warn("connection to poloniex stream ended, restarting it...")
}
}
func init() {
Poloniex = markets.NewPoloniex()
// We open markets connections in the background as it can take time.
go func() {
err := OpenMarketsConnection()
if err != nil {
ErrorChan <- err
}
}()
}
|