fix

cluster/cluster_impl/failover_cluster_invoker.go

@@ -40,7 +40,7 @@ func newFailoverClusterInvoker(directory cluster.Directory) protocol.Invoker {
 
 func (invoker *failoverClusterInvoker) Invoke(invocation protocol.Invocation) protocol.Result {
 
-	invokers, _ := invoker.directory.List(invocation)
+	invokers := invoker.directory.List(invocation)
 	err := invoker.checkInvokers(invokers, invocation)
 
 	if err != nil {
@@ -70,7 +70,7 @@ func (invoker *failoverClusterInvoker) Invoke(invocation protocol.Invocation) pr
 			if err != nil {
 				return &protocol.RPCResult{Err: err}
 			}
-			invokers, _ = invoker.directory.List(invocation)
+			invokers := invoker.directory.List(invocation)
 			err = invoker.checkInvokers(invokers, invocation)
 			if err != nil {
 				return &protocol.RPCResult{Err: err}

cluster/cluster_impl/registry_aware_cluster_invoker.go

@@ -34,7 +34,7 @@ func newRegistryAwareClusterInvoker(directory cluster.Directory) protocol.Invoke
 }
 
 func (invoker *registryAwareClusterInvoker) Invoke(invocation protocol.Invocation) protocol.Result {
-	invokers, _ := invoker.directory.List(invocation)
+	invokers := invoker.directory.List(invocation)
 	//First, pick the invoker (XXXClusterInvoker) that comes from the local registry, distinguish by a 'default' key.
 	for _, invoker := range invokers {
 		if invoker.IsAvailable() && invoker.GetUrl().GetParam(constant.REGISTRY_DEFAULT_KEY, "false") == "true" {

cluster/directory/static_directory_test.go

@@ -41,7 +41,7 @@ func Test_StaticDirList(t *testing.T) {
 	}
 
 	staticDir := NewStaticDirectory(invokers)
-	list, _ := staticDir.List(&invocation.RPCInvocation{})
+	list := staticDir.List(&invocation.RPCInvocation{})
 
 	assert.Len(t, list, 10)
 }