From 0913731a5f381be02bfafbabddd32446361dbecd Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 19 十月 2020 19:10:30 +0800
Subject: [PATCH] add members clear
---
agent_test.go | 28 ++++++++++++++++++++--------
1 files changed, 20 insertions(+), 8 deletions(-)
diff --git a/agent_test.go b/agent_test.go
index af68f8f..da7e004 100644
--- a/agent_test.go
+++ b/agent_test.go
@@ -14,28 +14,38 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package serf
+package syncdb
import (
"context"
+ "fmt"
+ "github.com/hashicorp/serf/serf"
"testing"
"time"
-
- "github.com/hashicorp/serf/serf"
)
func TestAgent(t *testing.T) {
conf := DefaultConfig()
- agent, err := Create(conf)
+ conf.ClusterID = "testCluster"
+ conf.NodeName = "testnode"
+ agent, err := Create(conf, "./snapshotfile")
if err != nil {
t.Errorf("create agent failed, error: %s", err)
}
+
+ fmt.Println("LocalMember1:", agent.LocalMember())
+
agent.Start(context.Background())
- <- agent.readyCh
+ //<- agent.readyCh
go func() {
agent.ShutdownCh()
}()
time.Sleep(time.Second)
+
+ fmt.Println("LocalMember2:", agent.LocalMember())
+
+ fmt.Println("ClusterID:", agent.conf.ClusterID)
+ fmt.Println("NodeName:", agent.conf.NodeName)
err = agent.UserEvent("test", []byte("test"), true)
if err != nil {
@@ -46,13 +56,15 @@
if err != nil {
t.Errorf("query for other node failed, error: %s", err)
}
- agent.LocalMember()
+ fmt.Println("LocalMember:", agent.LocalMember())
+ //agent.LocalMember()
- agent.Member("testnode")
+ mb := agent.Member("testnode")
+ fmt.Println("mb:", mb)
agent.SerfConfig()
- _, err = agent.Join([]string{"127.0.0.1:9999"}, true)
+ _, err = agent.Join([]string{"192.168.1.123:5000"}, true)
if err != nil {
t.Logf("join to other node failed, error: %s", err)
}
--
Gitblit v1.8.0