|
|
@ -37,8 +37,6 @@ func (ct *Cointop) updateCoins() error {
|
|
|
|
|
|
|
|
|
|
|
|
for coins := range ch {
|
|
|
|
for coins := range ch {
|
|
|
|
go ct.processCoins(coins)
|
|
|
|
go ct.processCoins(coins)
|
|
|
|
ct.cache.Set(cachekey, ct.allcoinsslugmap, 10*time.Second)
|
|
|
|
|
|
|
|
filecache.Set(cachekey, ct.allcoinsslugmap, 24*time.Hour)
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
ct.processCoinsMap(allcoinsslugmap)
|
|
|
|
ct.processCoinsMap(allcoinsslugmap)
|
|
|
@ -59,6 +57,11 @@ func (ct *Cointop) processCoinsMap(coinsMap map[string]types.Coin) {
|
|
|
|
func (ct *Cointop) processCoins(coins []types.Coin) {
|
|
|
|
func (ct *Cointop) processCoins(coins []types.Coin) {
|
|
|
|
updatecoinsmux.Lock()
|
|
|
|
updatecoinsmux.Lock()
|
|
|
|
defer updatecoinsmux.Unlock()
|
|
|
|
defer updatecoinsmux.Unlock()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cachekey := ct.cacheKey("allcoinsslugmap")
|
|
|
|
|
|
|
|
ct.cache.Set(cachekey, ct.allcoinsslugmap, 10*time.Second)
|
|
|
|
|
|
|
|
filecache.Set(cachekey, ct.allcoinsslugmap, 24*time.Hour)
|
|
|
|
|
|
|
|
|
|
|
|
for _, v := range coins {
|
|
|
|
for _, v := range coins {
|
|
|
|
k := v.Name
|
|
|
|
k := v.Name
|
|
|
|
last := ct.allcoinsslugmap[k]
|
|
|
|
last := ct.allcoinsslugmap[k]
|
|
|
|