From fcf11011b886af4642875cdf4c95edc396e746e6 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Fri, 31 May 2019 16:19:31 +0100 Subject: [PATCH] remove rcache --- broker/http_broker.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/broker/http_broker.go b/broker/http_broker.go index a7f6243d..3e7fa648 100644 --- a/broker/http_broker.go +++ b/broker/http_broker.go @@ -25,7 +25,7 @@ import ( maddr "github.com/micro/go-micro/util/addr" mnet "github.com/micro/go-micro/util/net" mls "github.com/micro/go-micro/util/tls" - "github.com/micro/go-rcache" + "github.com/micro/go-micro/registry/cache" "golang.org/x/net/http2" ) @@ -412,8 +412,8 @@ func (h *httpBroker) Connect() error { if !ok { reg = registry.DefaultRegistry } - // set rcache - h.r = rcache.New(reg) + // set cache + h.r = cache.New(reg) // set running h.running = true @@ -432,8 +432,8 @@ func (h *httpBroker) Disconnect() error { h.Lock() defer h.Unlock() - // stop rcache - rc, ok := h.r.(rcache.Cache) + // stop cache + rc, ok := h.r.(cache.Cache) if ok { rc.Stop() } @@ -477,13 +477,13 @@ func (h *httpBroker) Init(opts ...Option) error { reg = registry.DefaultRegistry } - // get rcache - if rc, ok := h.r.(rcache.Cache); ok { + // get cache + if rc, ok := h.r.(cache.Cache); ok { rc.Stop() } // set registry - h.r = rcache.New(reg) + h.r = cache.New(reg) // reconfigure tls config if c := h.opts.TLSConfig; c != nil {