add rpc

liuxiaolong

2021-06-07 aea48291949e54554f5c484cca32a1d3119d8e76

 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)
   }