Merge branch 'master' of http://192.168.1.14:10010/r/syncdb

chenshijun

2019-08-06 6ef6050a854cb9a20bef8005a5f2a8463374ef17

Merge branch 'master' of http://192.168.1.14:10010/r/syncdb

# Conflicts:
#	agent.go
#	config.go
#	dbself.go

格式化代码

 agent.go

@@ -40,6 +40,7 @@
    QueryEventGetDB = "GetDatabase"
    QueryEventUpdateDBData = "UpdateDBData"
)

// Agent warps the serf agent
type Agent struct {
    *agent.Agent
@@ -184,7 +185,6 @@
            //var res []*Rows
            //json.Unmarshal(bytesReturn, &res)
        }


    default:
        fmt.Printf("Unknown event type: %s\n", ev.EventType().String())
@@ -462,7 +462,7 @@
    time.Sleep(time.Second)
    fmt.Println("Stats:",agent.Agent.Serf().Stats())
    fmt.Println("EncryptionEnabled:",agent.Agent.Serf().EncryptionEnabled())
    fmt.Printf("create agent sucess!!")
    fmt.Println("create agent sucess!!")

    return agent, nil
}
@@ -510,7 +510,3 @@

    return nodes
}





 agent_test.go

@@ -35,7 +35,6 @@

    fmt.Println("LocalMember1:", agent.LocalMember())


    agent.Start(context.Background())
    //<- agent.readyCh
    go func() {
@@ -85,5 +84,3 @@
        t.Errorf("angent shutdown failed, error: %s", err)
    }
}



 config.go

@@ -42,14 +42,17 @@
    BroadcastIP = "255.255.255.255"
    BroadcastPort = 30193
    BroadcastInterval = 5
    MaxQueryRespSize   = 50 * 1024 * 1024
    MaxQuerySize       = 50 * 1024 * 1024
    MaxUserEventSize   = 5 * 1024
)

// DefaultConfig default config
func DefaultConfig() *Config {
    agentConf := agent.DefaultConfig()
    agentConf.QueryResponseSizeLimit = 50 * 1024 *1024
    agentConf.QuerySizeLimit = 50 * 1024 *1024
    agentConf.UserEventSizeLimit = 1024
    agentConf.QueryResponseSizeLimit = MaxQueryRespSize
    agentConf.QuerySizeLimit = MaxQuerySize
    agentConf.UserEventSizeLimit = MaxUserEventSize
    agentConf.BindAddr = fmt.Sprintf("0.0.0.0:%d", DefaultBindPort)
    agentConf.RPCAddr = fmt.Sprintf("0.0.0.0:%d", DefaultRPCPort)
    return &Config{
@@ -136,4 +139,3 @@

    return addr.IP.String(), addr.Port, nil
}


 dbself.go

@@ -10,7 +10,6 @@
    "sync"
)


const (
    PersonSqliteDBPath = "~/workspace/gitblit/dbserver/config/testdb.db"
)

 searcher.go

@@ -108,4 +108,3 @@
func GetSearchNodes()[][]byte {
    return members
}