(size)

(err error)

(gid int)

(state *redis.ReplicationState, g *models.Group)

()

(ctx *context.Context, client *redis.Client, list string, random_str string)

(i int64)

(self)

(conn *zk.Conn, path string)

(client *fsclient.Client)

(timeout time.Duration, filter func(index int, g *models.GroupServer) bool, wg *sync.WaitGroup)

(sid int)

(addr string)

(d map[string]interface{})

(d map[string]interface{})

(n int, b *bytes.Buffer)

(inx *int, elements []string)

(num, size)

(text string)

(line []byte)

(ctx *context, p *models.Proxy, c *proxy.ApiClient)

(self)

(self)

(serverAddr, masterAddr string, auth string, force bool)

()

(d time.Duration, do, cleanup func() error)

(g *models.Group)

(g *models.Group)

(p *models.Proxy)

(p *models.Sentinel)

(s string)

(serverAddr, masterAddr string, auth string)

(c *ApiClient, expect map[int]*models.Slot)

(d map[string]interface{}, name string)

(b []byte)

()