//package main
|
package androidSync
|
|
import (
|
sdb "basic.com/Android/syncdb.git"
|
"fmt"
|
"time"
|
)
|
|
|
|
|
func main() {
|
Leave()
|
InitCluster()
|
clusters := GetClusters("bjbasic123"+"123455")
|
fmt.Println(string(clusters))
|
clusters1, _ := sdb.CreateSearchNode("bjbasic123"+"123455")
|
fmt.Println(clusters1)
|
if 1==1 {
|
return;
|
}
|
Leave()
|
InitCluster()
|
InitAgent("node2")
|
SyncInit("c4d03d5d-64c3-4941-bb53-152277a3271a","123455","node2","", "")
|
//JoinByNodeAddrs("192.168.222.103:30190")
|
//JoinByNodeAddrs("192.168.5.22:30190")
|
fmt.Println("hello1")
|
var count = 0
|
for {
|
//SyncSql("select * from table1 count="+strconv.Itoa(count))
|
count++
|
//nodes := string(GetNodes())
|
//fmt.Println("nodes:",nodes)
|
time.Sleep(5*time.Second)
|
//SyncSql("select * from table1")
|
}
|
|
}
|
|
//func main1() {
|
// InitCluster()
|
// InitAgent("node2")
|
// SyncInit("cluster1","YmpiYXNpYzEyMzEyMzQ1Ng==","node2","")
|
// JoinByNodeAddrs("ip:30190")
|
// SyncSql("select * from table1")
|
// fmt.Println("hello")
|
//
|
//}
|
