接管集群

func main() {
    ips := []string{
        "10.10.10.1",
        "10.10.10.2",
        "10.10.10.3",
    }

    workDir := "/data/ob" // OceanBase 数据库的工作目录
    nodeConfigs := make([]util.NodeConfig, 0)
    for _, ip := range ips {
        nodeConfigs = append(nodeConfigs, util.NewNodeConfig(ip, workDir, 2886))
    }

    // 参数说明： 
    // password: 待被接管集群 root@sys 密码
    // configs: 节点配置信息
    if err := util.Takeover("pwd", nodeConfigs...); err != nil {
        panic(err)
    }
}