Method reconnect

client/session.go:1415–1435

()

}

func (s *Session) reconnect() bool {
	var err error
	connectedSuccess := false

	for i := 0; i < s.config.ConnectRetryMax; i++ {
		for i := range s.endPointList {
			ep := s.endPointList[i]
			err = s.initClusterConn(ep)
			if err == nil {
				connectedSuccess = true
				break
			} else {
				log.Println("Connection refused:", ep)
			}
		}
		if connectedSuccess {
			break
		}
	}
	return connectedSuccess
}

func (s *Session) SetFetchSize(fetchSize int32) {
	s.config.FetchSize = fetchSize