From dde54b7b7acb6feb605cd4d00a34a852fe41bc54 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期四, 08 八月 2019 09:54:54 +0800
Subject: [PATCH] 增加接口说明
---
agent_test.go | 26 +++++++++++++++++++-------
1 files changed, 19 insertions(+), 7 deletions(-)
diff --git a/agent_test.go b/agent_test.go
index af68f8f..fbabde6 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()
+ conf.ClusterID = "testCluster"
+ conf.NodeName = "testnode"
agent, err := Create(conf)
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