update gcache pool

lib/base/base_hmap.go

@@ -15,6 +15,11 @@ func NewHmap() *Hmap {
 	}
 }
 
+// Data :
+func (h *Hmap) Data() map[string]interface{} {
+	return h.data
+}
+
 // Len :
 func (h *Hmap) Len() int {
 	return h.size

lib/example/gcacheclient/example_gcacheclient.go

@@ -1,6 +1,7 @@
 package examplegcacheclient
 
 import (
+	"strconv"
 	"time"
 
 	"github.com/jameschz/go-base/lib/gcache"
@@ -55,12 +56,12 @@ func TestDriver() {
 	cache.Close()
 
 	// test connection timeout
-	// for i := 0; i < 5; i++ {
-	// 	time.Sleep(10 * time.Second)
-	// 	cache = gcache.D("default")
-	// 	cache.Set("test11", "test1")
-	// 	cache.Close()
-	// }
+	for i := 0; i < 5; i++ {
+		time.Sleep(10 * time.Second)
+		cache = gcache.D("default")
+		cache.Set("test.timeout."+strconv.Itoa(i), "test1")
+		cache.Close()
+	}
 
 }
 

lib/gcache/pool/gcache_pool.go

@@ -52,7 +52,7 @@ func createDataSource(driver *gcachedriver.Driver, node string) *gcachebase.Data
 			Addr: addr,
 			DB:   db,
 			// Pool Settings
-			PoolSize:     driver.PoolIdleMinSize,
+			PoolSize:     driver.PoolInitSize,
 			MinIdleConns: driver.PoolIdleMinSize,
 			IdleTimeout:  time.Duration(driver.PoolIdleTimeoutMin * int(time.Minute)),
 		})
@@ -105,6 +105,13 @@ func Init() (err error) {
 			_cPool.Set(cKey, createDataSource(cDriver, cNode))
 		}
 	}
+	// heart beat
+	go func() {
+		time.Sleep(1 * time.Minute)
+		for _, ds := range _cPool.Data() {
+			ds.(*gcachebase.DataSource).RedisConn.Ping()
+		}
+	}()
 	// for debug
 	debugPrint("gcachepool.Init", _cPool)
 	// init ok status