diff --git a/remoting/zookeeper/client_test.go b/remoting/zookeeper/client_test.go index d2f231c6b04bb47bb8b05edf8845f558f439fe33..34741700ca2a9d86ee5321b0b19ed64b2b1a25a8 100644 --- a/remoting/zookeeper/client_test.go +++ b/remoting/zookeeper/client_test.go @@ -24,7 +24,7 @@ import ( import ( "github.com/dubbogo/go-zookeeper/zk" - "github.com/stretchr/testify/require" + "github.com/stretchr/testify/assert" ) import ( @@ -80,7 +80,7 @@ func verifyEventStateOrder(t *testing.T, c <-chan zk.Event, expectedStates []zk. func Test_newMockZookeeperClient(t *testing.T) { ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second) - require.NoError(t, err) + assert.NoError(t, err) defer ts.Stop() states := []zk.State{zk.StateConnecting, zk.StateConnected, zk.StateHasSession} verifyEventStateOrder(t, event, states, "event channel") @@ -91,10 +91,10 @@ func Test_newMockZookeeperClient(t *testing.T) { func TestCreate(t *testing.T) { ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second) - require.NoError(t, err) + assert.NoError(t, err) defer ts.Stop() err = z.Create("test1/test2/test3/test4") - require.NoError(t, err) + assert.NoError(t, err) states := []zk.State{zk.StateConnecting, zk.StateConnected, zk.StateHasSession} verifyEventStateOrder(t, event, states, "event channel") @@ -102,41 +102,41 @@ func TestCreate(t *testing.T) { func TestCreateDelete(t *testing.T) { ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second) - require.NoError(t, err) + assert.NoError(t, err) defer ts.Stop() states := []zk.State{zk.StateConnecting, zk.StateConnected, zk.StateHasSession} verifyEventStateOrder(t, event, states, "event channel") err = z.Create("/test1/test2/test3/test4") - require.NoError(t, err) + assert.NoError(t, err) err = z.Delete("/test1/test2/test3/test4") - require.NoError(t, err) + assert.NoError(t, err) // verifyEventOrder(t, event, []zk.EventType{zk.EventNodeCreated}, "event channel") } func TestRegisterTemp(t *testing.T) { ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second) - require.NoError(t, err) + assert.NoError(t, err) defer ts.Stop() err = z.Create("/test1/test2/test3") - require.NoError(t, err) + assert.NoError(t, err) tmpath, err := z.RegisterTemp("/test1/test2/test3", "test4") - require.NoError(t, err) - require.Equal(t, "/test1/test2/test3/test4", tmpath) + assert.NoError(t, err) + assert.Equal(t, "/test1/test2/test3/test4", tmpath) states := []zk.State{zk.StateConnecting, zk.StateConnected, zk.StateHasSession} verifyEventStateOrder(t, event, states, "event channel") } func TestRegisterTempSeq(t *testing.T) { ts, z, event, err := NewMockZookeeperClient("test", 15*time.Second) - require.NoError(t, err) + assert.NoError(t, err) defer ts.Stop() err = z.Create("/test1/test2/test3") - require.NoError(t, err) + assert.NoError(t, err) tmpath, err := z.RegisterTempSeq("/test1/test2/test3", []byte("test")) - require.NoError(t, err) - require.Equal(t, "/test1/test2/test3/0000000000", tmpath) + assert.NoError(t, err) + assert.Equal(t, "/test1/test2/test3/0000000000", tmpath) states := []zk.State{zk.StateConnecting, zk.StateConnected, zk.StateHasSession} verifyEventStateOrder(t, event, states, "event channel") }