add metric for faster health check and remove unhealth server node

cluster.go

@@ -3,6 +3,7 @@ package gopool
 import (
 	"context"
 	"fmt"
+	"github.com/alwaysthanks/melon"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -31,7 +32,7 @@ func NewPoolCluster(addrList []string, cfg Config, factory IConnFactory) *PoolCl
 		cancel:   cancel,
 		poolList: make([]*Pool, 0),
 		checkInterval: func() {
-			time.Sleep(time.Second * 3)
+			time.Sleep(time.Second * 2)
 		},
 	}
 	for _, addr := range addrList {
@@ -51,6 +52,7 @@ func NewPoolCluster(addrList []string, cfg Config, factory IConnFactory) *PoolCl
 			idleList:  make([]*Conn, 0, cfg.MaxIdleNum),
 			reqBlocks: make(map[int64]chan *Conn),
 			available: true,
+			melon:     melon.New(5000, melon.OptionAnchor(20, 18), melon.OptionAnchor(100, 70)),
 		}
 		pc.poolList = append(pc.poolList, p)
 	}

pool.go

@@ -3,6 +3,7 @@ package gopool
 import (
 	"context"
 	"fmt"
+	"github.com/alwaysthanks/melon"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -61,6 +62,8 @@ type Pool struct {
 	closed bool
 	//pool health
 	available bool
+	//melon metric
+	melon *melon.Ring
 }
 
 //get connection
@@ -180,6 +183,8 @@ func (p *Pool) get(ctx context.Context) (conn *Conn, err error) {
 		return conn, nil
 	}
 	p.mutex.Unlock()
+	//set get conn err metric
+	p.melon.Feed(false)
 	return nil, ErrNewConn
 }
 
@@ -192,6 +197,10 @@ func (p *Pool) put(conn *Conn, broken bool) {
 		conn.mutex.Unlock()
 		return
 	}
+
+	//add metric
+	p.melon.Feed(broken)
+
 	conn.inUse = false
 	conn.mutex.Unlock()
 	//pool closed
@@ -345,6 +354,10 @@ func (p *Pool) health() bool {
 	if p.healthFailedNum > 3 {
 		return false
 	}
+	//add metric check for ok
+	if !p.melon.OK() {
+		return false
+	}
 	return true
 }