FMT registry/etcdv3 remoting/v3

registry/etcdv3/listener_test.go

@@ -11,39 +11,36 @@ import (
 	"github.com/apache/dubbo-go/remoting"
 )
 
+func startETCDServer(t *testing.T) {
 
-func startETCDServer(t *testing.T){
-
-	cmd := exec.Command("./load.sh",  "start")
+	cmd := exec.Command("./load.sh", "start")
 	//cmd := exec.Command("pwd")
-	cmd.Stdout= os.Stdout
+	cmd.Stdout = os.Stdout
 	cmd.Stderr = os.Stdout
 	cmd.Dir = "../../remoting/etcdv3/single"
 
-	if err := cmd.Run(); err != nil{
+	if err := cmd.Run(); err != nil {
 		t.Fatal(err)
 	}
 
 }
 
-func stopETCDServer(t *testing.T){
+func stopETCDServer(t *testing.T) {
 
-	cmd := exec.Command("./load.sh",  "stop")
+	cmd := exec.Command("./load.sh", "stop")
 	//cmd := exec.Command("pwd")
-	cmd.Stdout= os.Stdout
+	cmd.Stdout = os.Stdout
 	cmd.Stderr = os.Stdout
 	cmd.Dir = "../../remoting/etcdv3/single"
 
-	if err := cmd.Run(); err != nil{
+	if err := cmd.Run(); err != nil {
 		t.Fatal(err)
 	}
 
 }
 
-
 func Test_DataChange(t *testing.T) {
 
-
 	startETCDServer(t)
 	defer stopETCDServer(t)
 

registry/etcdv3/registry.go

@@ -157,7 +157,6 @@ func (r *etcdV3Registry) stop() {
 	// close current client
 	r.client.Close()
 
-
 	r.cltLock.Lock()
 	r.client = nil
 	r.services = nil

registry/etcdv3/registry_test.go

@@ -105,7 +105,6 @@ func Test_ConsumerDestory(t *testing.T) {
 
 func Test_ProviderDestory(t *testing.T) {
 
-
 	startETCDServer(t)
 	defer stopETCDServer(t)
 
@@ -118,5 +117,3 @@ func Test_ProviderDestory(t *testing.T) {
 	reg.Destroy()
 	assert.Equal(t, false, reg.IsAvailable())
 }
-
-

remoting/etcdv3/client_test.go

@@ -61,25 +61,25 @@ func initClient(t *testing.T) *Client {
 	return c
 }
 
-func startETCDServer(t *testing.T){
+func startETCDServer(t *testing.T) {
 
-	cmd := exec.Command("./load.sh",  "start")
-	cmd.Stdout= os.Stdout
+	cmd := exec.Command("./load.sh", "start")
+	cmd.Stdout = os.Stdout
 	cmd.Stderr = os.Stdout
 	cmd.Dir = "./single"
 
-	if err := cmd.Run(); err != nil{
+	if err := cmd.Run(); err != nil {
 		t.Fatal(err)
 	}
 }
 
-func stopETCDServer(t *testing.T){
-	cmd := exec.Command("./load.sh",  "stop")
-	cmd.Stdout= os.Stdout
+func stopETCDServer(t *testing.T) {
+	cmd := exec.Command("./load.sh", "stop")
+	cmd.Stdout = os.Stdout
 	cmd.Stderr = os.Stdout
 	cmd.Dir = "./single"
 
-	if err := cmd.Run(); err != nil{
+	if err := cmd.Run(); err != nil {
 		t.Fatal(err)
 	}
 
@@ -343,7 +343,6 @@ func TestClient_Valid(t *testing.T) {
 
 func TestClient_Done(t *testing.T) {
 
-
 	startETCDServer(t)
 	defer stopETCDServer(t)
 

remoting/etcdv3/listener_test.go

@@ -85,4 +85,3 @@ func (m *mockDataListener) DataChange(eventType remoting.Event) bool {
 	}
 	return true
 }
-