Merge remote-tracking branch 'origin/3.0' into 3.0
diff --git a/registry/polaris/core.go b/registry/polaris/core.go
index e87fac7..7e9f304 100644
--- a/registry/polaris/core.go
+++ b/registry/polaris/core.go
@@ -32,13 +32,13 @@
"dubbo.apache.org/dubbo-go/v3/remoting"
)
-type subscriber func(remoting.EventType, []model.Instance)
+type item func(remoting.EventType, []model.Instance)
type PolarisServiceWatcher struct {
consumer api.ConsumerAPI
subscribeParam *api.WatchServiceRequest
lock *sync.RWMutex
- subscribers []subscriber
+ subscribers []item
execOnce *sync.Once
}
@@ -48,7 +48,7 @@
subscribeParam: param,
consumer: consumer,
lock: &sync.RWMutex{},
- subscribers: make([]subscriber, 0),
+ subscribers: make([]item, 0),
execOnce: &sync.Once{},
}
return watcher, nil
diff --git a/registry/polaris/core_test.go b/registry/polaris/core_test.go
index 463d88a..26a573c 100644
--- a/registry/polaris/core_test.go
+++ b/registry/polaris/core_test.go
@@ -25,7 +25,7 @@
consumer api.ConsumerAPI
subscribeParam *api.WatchServiceRequest
lock *sync.RWMutex
- subscribers []subscriber
+ subscribers []item
execOnce *sync.Once
}
type args struct {
@@ -42,7 +42,7 @@
subscribeParam: &newParam,
consumer: newConsumer,
lock: &sync.RWMutex{},
- subscribers: make([]subscriber, 0),
+ subscribers: make([]item, 0),
execOnce: &sync.Once{},
}
assert.Empty(t, watcher)
