基于serf的数据库同步模块库
liuxiaolong
2019-08-09 1bd25d38c58785102004948b420e931578be7012
test
1个文件已修改
6 ■■■■■ 已修改文件
agent.go 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
agent.go
@@ -422,7 +422,8 @@
    mbs := a.GroupMembers(a.conf.ClusterID)
    var specmembername string
    for _, m := range mbs {
        if m.Addr.String() != a.conf.BindAddr {
        fmt.Println("m",m)
        if m.Name != a.conf.NodeName {
            specmembername = m.Name
            break
        }
@@ -431,7 +432,8 @@
    //query: get db file.
    params := serf.QueryParam{
        FilterNodes: strings.Fields(specmembername),
        //FilterNodes: strings.Fields(specmembername),
        FilterNodes: strings.Fields(a.conf.NodeName),
    }
    //SQL