daemon.go

func (daemon *Daemon) Run() {
    defer func() {
        if r:= recover(); r != nil {
            fmt.Printf("RECOVER daemon=%s\n", daemon.Slug)
            fmt.Println(r)
            statsd.Increment(fmt.Sprintf("daemon.recover.%s", daemon.Slug))
        }
        // Schedule next run
        time.Sleep(daemon.UpdateFrequency) // (2 seconds)
        go daemon.Run()
    }()
    statsd.Increment(fmt.Sprintf("daemon.run.%s-%s", daemon.Exchange.Slug(), daemon.CurrencyPair))
    daemon.UpdateIntervals()
    daemon.UpdateOrderBook()
}

init.go

func Initialize(run bool) {
    InitializeDaemon(exchanges.Get("huobi"),     "btccny", run)
    InitializeDaemon(exchanges.Get("huobi"),     "ltccny", run)
    InitializeDaemon(exchanges.Get("okcoin"),     "btccny", run)
    InitializeDaemon(exchanges.Get("okcoin"),     "ltccny", run)
    InitializeDaemon(exchanges.Get("btce"),     "btcusd", run)
    InitializeDaemon(exchanges.Get("bitfinex"),     "btcusd", run)
    InitializeDaemon(exchanges.Get("bitfinex"),     "ltcusd", run)
    InitializeDaemon(exchanges.Get("bitfinex"),     "ltcbtc", run)
    InitializeDaemon(exchanges.Get("bitstamp"), "btcusd", run)
    InitializeDaemon(exchanges.Get("cryptsy"),  "dogebtc", run)
    InitializeDaemon(exchanges.Get("mtgox"),    "btcusd", false)
    InitializeDaemon(exchanges.Get("btce"),     "ltcusd", run)
    InitializeDaemon(exchanges.Get("btce"),     "ltcbtc", run)
    InitializeDaemon(exchanges.Get("btce"),     "nmcusd", run)
    InitializeDaemon(exchanges.Get("btce"),     "ppcusd", run)
    go BroadcastUserCount()
}