Adjust test cases
diff --git a/syncer/serf/agent_test.go b/syncer/serf/agent_test.go
index cde0217..af68f8f 100644
--- a/syncer/serf/agent_test.go
+++ b/syncer/serf/agent_test.go
@@ -17,6 +17,7 @@
package serf
import (
+ "context"
"testing"
"time"
@@ -25,12 +26,12 @@
func TestAgent(t *testing.T) {
conf := DefaultConfig()
- agent, err := Create(conf, nil)
+ agent, err := Create(conf)
if err != nil {
t.Errorf("create agent failed, error: %s", err)
}
- agent.Start()
-
+ agent.Start(context.Background())
+ <- agent.readyCh
go func() {
agent.ShutdownCh()
}()
diff --git a/syncer/servicecenter/servicecenter_test.go b/syncer/servicecenter/servicecenter_test.go
index f6628c8..0e13774 100644
--- a/syncer/servicecenter/servicecenter_test.go
+++ b/syncer/servicecenter/servicecenter_test.go
@@ -21,10 +21,11 @@
"errors"
"testing"
+ "github.com/apache/servicecomb-service-center/syncer/pkg/mock/mocksotrage"
+
"github.com/apache/servicecomb-service-center/server/core/proto"
"github.com/apache/servicecomb-service-center/syncer/config"
"github.com/apache/servicecomb-service-center/syncer/pkg/mock/mockplugin"
- "github.com/apache/servicecomb-service-center/syncer/pkg/mock/mocksotrage"
"github.com/apache/servicecomb-service-center/syncer/plugins"
pb "github.com/apache/servicecomb-service-center/syncer/proto"
)
@@ -36,12 +37,12 @@
t.Log(err)
}
}()
- _, err := NewServicecenter([]string{"127.0.0.1:30100"}, nil)
+ _, err := NewServicecenter([]string{"127.0.0.1:30100"})
if err != nil {
t.Log(err)
}
- _, err = NewServicecenter([]string{"127.0.0.1:30100"}, nil)
+ _, err = NewServicecenter([]string{"127.0.0.1:30100"})
if err != nil {
t.Fatal(err)
return
@@ -52,11 +53,12 @@
conf := config.DefaultConfig()
conf.ServicecenterPlugin = mockplugin.PluginName
initPlugin(conf)
- dc, err := NewServicecenter([]string{"http://127.0.0.1:30100"}, mocksotrage.New())
+ dc, err := NewServicecenter([]string{"http://127.0.0.1:30100"})
if err != nil {
t.Fatal(err)
return
}
+ dc.SetStorage(mocksotrage.New())
mockplugin.SetGetAll(func(ctx context.Context) (data *pb.SyncData, e error) {
return nil, errors.New("test error")
