| | |
|---|
| | | "strings" |
|---|
| | | "time" |
|---|
| | | |
|---|
| | | "syncdb/serf/cmd/serf/command/agent" |
|---|
| | | "syncdb/serf/serf" |
|---|
| | | "basic.com/valib/serf.git/serf" |
|---|
| | | "basic.com/valib/serf.git/cmd/serf/command/agent" |
|---|
| | | //"github.com/apache/servicecomb-service-center/pkg/log" |
|---|
| | | "basic.com/valib/logger.git" |
|---|
| | | ) |
|---|
| | |
|---|
| | | go a.BroadcastMemberlist(BroadcastInterval * time.Second) |
|---|
| | | } |
|---|
| | | |
|---|
| | | var SyncDbTablePersonCacheChan = make(chan []byte,0) |
|---|
| | | var SyncDbTablePersonCacheChan = make(chan []byte,512) |
|---|
| | | |
|---|
| | | // HandleEvent Handles serf.EventMemberJoin events, |
|---|
| | | // which will wait for members to join until the number of group members is equal to "groupExpect" |
|---|
