GetTableDataFromCluster ret *string
| | |
| | | |
| | | //GetDbFromCluster get the newest database after join cluster |
| | | //dbPathWrite the path where to write after got a database, |
| | | func (a *Agent) GetTableDataFromCluster(tableNames []string) (*[]string, error) { |
| | | func (a *Agent) GetTableDataFromCluster(tableNames []string) (*string, error) { |
| | | //members: get name of first member |
| | | mbs := a.GroupMembers(a.conf.ClusterID) |
| | | specmembername := "" |
| | |
| | | |
| | | var wg sync.WaitGroup |
| | | wg.Add(1) |
| | | var dumpSqls []string |
| | | var dumpSqls string |
| | | go func() { |
| | | defer wg.Done() |
| | | respCh := resp.ResponseCh() |