compatible some usage

Author: left2right

cmd/ha/main.go

@@ -75,15 +75,15 @@ Options:
 
 	t, err := client.Model()
 	if err != nil {
-		log.PanicErrorf(err, "rpc fetch model failed")
+		log.ErrorErrorf(err, "rpc fetch model failed")
 	}
 	log.Warnf("topom =\n%s", t.Encode())
 
 	client.SetXAuth(t.ProductName)
 
 	overview, err := client.Overview()
 	if err != nil {
-		log.PanicErrorf(err, "rpc fetch overview failed")
+		log.ErrorErrorf(err, "rpc fetch overview failed")
 	}
 	prodcutAuth := overview.Config.ProductAuth
 
@@ -329,6 +329,8 @@ Groups:
 							n, err := strconv.Atoi(stats.Stats["master_link_down_since_seconds"])
 							if err != nil {
 								log.WarnErrorf(err, "try to get %s master_link_down_since_seconds failed", addr)
+								// some backend server like pika doen't support master_link_down_since_seconds, temp resolution
+								picked = i
 								continue
 							}
 							if n >= 0 && n < mindown {

config/proxy.toml

@@ -42,7 +42,7 @@ jodis_compatible = false
 proxy_datacenter = ""
 
 # Set max number of alive sessions.
-proxy_max_clients = 1000
+proxy_max_clients = 20000
 
 # Set max offheap memory size. (0 to disable)
 proxy_max_offheap_size = "1024mb"

pkg/utils/redis/client.go

@@ -170,20 +170,28 @@ func (c *Client) SetMaster(master string) error {
 	if err != nil {
 		return errors.Trace(err)
 	}
-	c.conn.Send("MULTI")
-	c.conn.Send("CONFIG", "SET", "masterauth", c.Auth)
-	c.conn.Send("SLAVEOF", host, port)
-	c.conn.Send("CONFIG", "REWRITE")
-	c.conn.Send("CLIENT", "KILL", "TYPE", "normal")
-	values, err := redigo.Values(c.Do("EXEC"))
-	if err != nil {
+	if _, err := c.Do("CONFIG", "SET", "masterauth", c.Auth); err != nil {
+		return errors.Trace(err)
+	}
+	if _, err := c.Do("SLAVEOF", host, port); err != nil {
 		return errors.Trace(err)
 	}
-	for _, r := range values {
-		if err, ok := r.(redigo.Error); ok {
+	/*
+		c.conn.Send("MULTI")
+		c.conn.Send("CONFIG", "SET", "masterauth", c.Auth)
+		c.conn.Send("SLAVEOF", host, port)
+		c.conn.Send("CONFIG", "REWRITE")
+		c.conn.Send("CLIENT", "KILL", "TYPE", "normal")
+		values, err := redigo.Values(c.Do("EXEC"))
+		if err != nil {
 			return errors.Trace(err)
 		}
-	}
+		for _, r := range values {
+			if err, ok := r.(redigo.Error); ok {
+				return errors.Trace(err)
+			}
+		}
+	*/
 	return nil
 }