| | |
|---|
| | | // 启动后查询一次集群状态 |
|---|
| | | ss.QueryClusterStat() |
|---|
| | | |
|---|
| | | if ss.ClusterStatus != "" { |
|---|
| | | ss.sqlDB.LogMode(true) |
|---|
| | | } |
|---|
| | | //if ss.ClusterStatus != "" { |
|---|
| | | ss.sqlDB.LogMode(true) |
|---|
| | | //} |
|---|
| | | |
|---|
| | | initChan <- true |
|---|
| | | <-q |
|---|
| | |
|---|
| | | // 退出集群, 开启日志跟踪, 设置角色slave |
|---|
| | | ss.clusterEventFn(EventLeaveCluster) |
|---|
| | | ss.ClusterStatus = "" |
|---|
| | | ss.sqlDB.LogMode(false) |
|---|
| | | ss.sqlDB.LogMode(true) |
|---|
| | | case "slave2master": |
|---|
| | | ss.clusterEventFn(EventSlave2Master) |
|---|
| | | ss.ClusterStatus = "master" |
|---|
| | |
|---|
| | | shard = fmt.Sprintf("%s%s;", shard, sql) |
|---|
| | | } |
|---|
| | | |
|---|
| | | if len(shard) >0 { |
|---|
| | | if len(shard) > 0 { |
|---|
| | | err = ss.pubSyncSqlMessage([]byte(shard), targetId) |
|---|
| | | } |
|---|
| | | } |
|---|
