unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 280 Wiki Activity

remove rcache reference

Browse Source
This commit is contained in:
Asim Aslam 2019-05-31 16:00:44 +01:00
parent f9f893fa85
commit 7a3a7e2eaf
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
selector/default.go
View File

@ -4,22 +4,22 @@ import (
"time"
"github.com/micro/go-micro/registry"
"github.com/micro/go-rcache"
"github.com/micro/go-micro/registry/cache"
)
type registrySelector struct {
so Options
rc rcache.Cache
rc cache.Cache
}
func (c *registrySelector) newRCache() rcache.Cache {
ropts := []rcache.Option{}
func (c *registrySelector) newCache() cache.Cache {
ropts := []cache.Option{}
if c.so.Context != nil {
if t, ok := c.so.Context.Value("selector_ttl").(time.Duration); ok {
ropts = append(ropts, rcache.WithTTL(t))
ropts = append(ropts, cache.WithTTL(t))
}
}
return rcache.New(c.so.Registry, ropts...)
return cache.New(c.so.Registry, ropts...)
}
func (c *registrySelector) Init(opts ...Option) error {
@ -28,7 +28,7 @@ func (c *registrySelector) Init(opts ...Option) error {
}
c.rc.Stop()
c.rc = c.newRCache()
c.rc = c.newCache()
return nil
}
@ -100,7 +100,7 @@ func NewSelector(opts ...Option) Selector {
s := &registrySelector{
so: sopts,
}
s.rc = s.newRCache()
s.rc = s.newCache()
return s
}