mirror of
https://github.com/alibaba/higress.git
synced 2026-06-02 17:17:27 +08:00
fix eureka service discovery not work in standalone mode (#714)
This commit is contained in:
@@ -23,9 +23,7 @@ import (
|
|||||||
|
|
||||||
"github.com/hudl/fargo"
|
"github.com/hudl/fargo"
|
||||||
"istio.io/api/networking/v1alpha3"
|
"istio.io/api/networking/v1alpha3"
|
||||||
versionedclient "istio.io/client-go/pkg/clientset/versioned"
|
|
||||||
"istio.io/pkg/log"
|
"istio.io/pkg/log"
|
||||||
ctrl "sigs.k8s.io/controller-runtime"
|
|
||||||
|
|
||||||
apiv1 "github.com/alibaba/higress/api/networking/v1"
|
apiv1 "github.com/alibaba/higress/api/networking/v1"
|
||||||
"github.com/alibaba/higress/pkg/common"
|
"github.com/alibaba/higress/pkg/common"
|
||||||
@@ -49,7 +47,6 @@ type watcher struct {
|
|||||||
cache memory.Cache
|
cache memory.Cache
|
||||||
mutex *sync.Mutex
|
mutex *sync.Mutex
|
||||||
stop chan struct{}
|
stop chan struct{}
|
||||||
istioClient *versionedclient.Clientset
|
|
||||||
isStop bool
|
isStop bool
|
||||||
updateCacheWhenEmpty bool
|
updateCacheWhenEmpty bool
|
||||||
|
|
||||||
@@ -70,18 +67,6 @@ func NewWatcher(cache memory.Cache, opts ...WatcherOption) (provider.Watcher, er
|
|||||||
stop: make(chan struct{}),
|
stop: make(chan struct{}),
|
||||||
}
|
}
|
||||||
|
|
||||||
config, err := ctrl.GetConfig()
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
ic, err := versionedclient.NewForConfig(config)
|
|
||||||
if err != nil {
|
|
||||||
log.Errorf("can not new istio client, err:%v", err)
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
w.istioClient = ic
|
|
||||||
|
|
||||||
w.fullRefreshIntervalLimit = DefaultFullRefreshIntervalLimit
|
w.fullRefreshIntervalLimit = DefaultFullRefreshIntervalLimit
|
||||||
|
|
||||||
for _, opt := range opts {
|
for _, opt := range opts {
|
||||||
|
|||||||
Reference in New Issue
Block a user