فهرست منبع

DefaultPort to Port: I tink it make more sense like that

juliendsv 11 سال پیش
والد
کامیت
838e2ab56b
2فایلهای تغییر یافته به همراه9 افزوده شده و 5 حذف شده
  1. 6 2
      cluster.go
  2. 3 3
      connectionpool.go

+ 6 - 2
cluster.go

@@ -12,6 +12,10 @@ import (
 	"github.com/golang/groupcache/lru"
 )
 
+const (
+	defaultPort = 9042
+)
+
 //Package global reference to Prepared Statements LRU
 var stmtsLRU preparedLRU
 
@@ -49,7 +53,7 @@ type ClusterConfig struct {
 	CQLVersion       string        // CQL version (default: 3.0.0)
 	ProtoVersion     int           // version of the native protocol (default: 2)
 	Timeout          time.Duration // connection timeout (default: 600ms)
-	DefaultPort      int           // default port (default: 9042)
+	Port             int           // port (default: 9042)
 	Keyspace         string        // initial keyspace (optional)
 	NumConns         int           // number of connections per host (default: 2)
 	NumStreams       int           // number of streams per connection (default: 128)
@@ -71,7 +75,7 @@ func NewCluster(hosts ...string) *ClusterConfig {
 		CQLVersion:       "3.0.0",
 		ProtoVersion:     2,
 		Timeout:          600 * time.Millisecond,
-		DefaultPort:      9042,
+		Port:             defaultPort,
 		NumConns:         2,
 		NumStreams:       128,
 		Consistency:      Quorum,

+ 3 - 3
connectionpool.go

@@ -30,7 +30,7 @@ Example of Single Connection Pool:
 	func NewSingleConnection(cfg *ClusterConfig) ConnectionPool {
 		addr := strings.TrimSpace(cfg.Hosts[0])
 		if strings.Index(addr, ":") < 0 {
-			addr = fmt.Sprintf("%s:%d", addr, cfg.DefaultPort)
+			addr = fmt.Sprintf("%s:%d", addr, cfg.Port)
 		}
 		connCfg := ConnConfig{
 			ProtoVersion:  cfg.ProtoVersion,
@@ -146,7 +146,7 @@ func NewSimplePool(cfg *ClusterConfig) ConnectionPool {
 	for i := 0; i < len(cfg.Hosts); i++ {
 		addr := strings.TrimSpace(cfg.Hosts[i])
 		if strings.Index(addr, ":") < 0 {
-			addr = fmt.Sprintf("%s:%d", addr, cfg.DefaultPort)
+			addr = fmt.Sprintf("%s:%d", addr, cfg.Port)
 		}
 
 		if pool.connect(addr) == nil {
@@ -236,7 +236,7 @@ func (c *SimplePool) fillPool() {
 	for host := range c.hosts {
 		addr := strings.TrimSpace(host)
 		if strings.Index(addr, ":") < 0 {
-			addr = fmt.Sprintf("%s:%d", addr, c.cfg.DefaultPort)
+			addr = fmt.Sprintf("%s:%d", addr, c.cfg.Port)
 		}
 
 		numConns := 1