fix cluster definition

chickenlj · Nov 4, 2023 · 11f3eff · 11f3eff
1 parent 2087cff
commit 11f3eff
Show file tree

Hide file tree

Showing 10 changed files with 11 additions and 11 deletions.
diff --git a/cluster/cluster/adaptivesvc/cluster_invoker.go b/cluster/cluster/adaptivesvc/cluster_invoker.go
@@ -41,7 +41,7 @@ import (
 var _ protocol.Invoker = (*adaptiveServiceClusterInvoker)(nil)
 
 type adaptiveServiceClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newAdaptiveServiceClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/available/cluster_invoker.go b/cluster/cluster/available/cluster_invoker.go
@@ -33,7 +33,7 @@ import (
 )
 
 type availableClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 // NewClusterInvoker returns a availableCluster invoker instance

diff --git a/cluster/cluster/base/cluster_invoker.go b/cluster/cluster/base/cluster_invoker.go
@@ -42,8 +42,8 @@ type BaseClusterInvoker struct {
 	StickyInvoker  protocol.Invoker
 }
 
-func NewBaseClusterInvoker(directory directory.Directory) BaseClusterInvoker {
-	return BaseClusterInvoker{
+func NewBaseClusterInvoker(directory directory.Directory) *BaseClusterInvoker {
+	return &BaseClusterInvoker{
 		Directory:      directory,
 		AvailableCheck: true,
 		Destroyed:      atomic.NewBool(false),

diff --git a/cluster/cluster/broadcast/cluster_invoker.go b/cluster/cluster/broadcast/cluster_invoker.go
@@ -32,7 +32,7 @@ import (
 )
 
 type broadcastClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newBroadcastClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/failback/cluster_invoker.go b/cluster/cluster/failback/cluster_invoker.go
@@ -46,7 +46,7 @@ import (
  * <a href="http://en.wikipedia.org/wiki/Failback">Failback</a>
  */
 type failbackClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 
 	once          sync.Once
 	ticker        *time.Ticker

diff --git a/cluster/cluster/failfast/cluster_invoker.go b/cluster/cluster/failfast/cluster_invoker.go
@@ -28,7 +28,7 @@ import (
 )
 
 type failfastClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newFailfastClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/failover/cluster_invoker.go b/cluster/cluster/failover/cluster_invoker.go
@@ -38,7 +38,7 @@ import (
 )
 
 type failoverClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newFailoverClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/failsafe/cluster_invoker.go b/cluster/cluster/failsafe/cluster_invoker.go
@@ -41,7 +41,7 @@ import (
  *
  */
 type failsafeClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newFailsafeClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/forking/cluster_invoker.go b/cluster/cluster/forking/cluster_invoker.go
@@ -37,7 +37,7 @@ import (
 )
 
 type forkingClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newForkingClusterInvoker(directory directory.Directory) protocol.Invoker {

diff --git a/cluster/cluster/zoneaware/cluster_invoker.go b/cluster/cluster/zoneaware/cluster_invoker.go
@@ -37,7 +37,7 @@ import (
 // 3. Evenly balance traffic between all registries based on each registry's weight.
 // 4. Pick anyone that's available.
 type zoneawareClusterInvoker struct {
-	base.BaseClusterInvoker
+	*base.BaseClusterInvoker
 }
 
 func newZoneawareClusterInvoker(directory directory.Directory) protocol.Invoker {