client: fast resolve address (#244)

zc · web-flow · commit 333f86113b59 · 2020-08-17T11:33:02.000+08:00
diff --git a/client/resolver/eru/resolver.go b/client/resolver/eru/resolver.go
@@ -29,6 +29,7 @@ func New(cc resolver.ClientConn, endpoint string, authority string) *Resolver {
 		cc:        cc,
 		discovery: servicediscovery.New(endpoint, authConfig),
 	}
+	cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: endpoint}}})
 	go r.sync()
 	return r
 }
diff --git a/cluster/calcium/service_test.go b/cluster/calcium/service_test.go
@@ -48,7 +48,7 @@ func TestServiceStatusStream(t *testing.T) {
 	}
 	time.Sleep(100 * time.Millisecond)
 	for _, v := range registered {
-		assert.Equal(t, v, 2)
+		assert.GreaterOrEqual(t, v, 2)
 	}
 	unregister()
 	assert.Equal(t, len(registered), 0)

Original file line number	Diff line number	Diff line change
`@@ -29,6 +29,7 @@ func New(cc resolver.ClientConn, endpoint string, authority string) *Resolver {`
`29`	`29`	`cc: cc,`
`30`	`30`	`discovery: servicediscovery.New(endpoint, authConfig),`
`31`	`31`	`}`
	`32`	`+ cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: endpoint}}})`
`32`	`33`	`go r.sync()`
`33`	`34`	`return r`
`34`	`35`	`}`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ func TestServiceStatusStream(t *testing.T) {`
`48`	`48`	`}`
`49`	`49`	`time.Sleep(100 * time.Millisecond)`
`50`	`50`	`for _, v := range registered {`
`51`		`- assert.Equal(t, v, 2)`
	`51`	`+ assert.GreaterOrEqual(t, v, 2)`
`52`	`52`	`}`
`53`	`53`	`unregister()`
`54`	`54`	`assert.Equal(t, len(registered), 0)`