unistack-org/micro-registry-cache
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

move reg util to own package (#1523)

Browse Source 
* move reg util to own package

* fix test

* fix broken static router
This commit is contained in:
Asim Aslam 2020-04-10 17:41:10 +01:00 committed by Vasiliy Tolstov
parent 031e2fbfcb
commit 58cd0f660f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cache.go
View File

@ -9,6 +9,7 @@ import (
"github.com/micro/go-micro/v2/logger" "github.com/micro/go-micro/v2/logger"
"github.com/micro/go-micro/v2/registry" "github.com/micro/go-micro/v2/registry"
util "github.com/micro/go-micro/v2/util/registry"
) )
// Cache is the registry cache interface // Cache is the registry cache interface
@ -119,7 +120,7 @@ func (c *cache) get(service string) ([]*registry.Service, error) {
// get cache ttl // get cache ttl
ttl := c.ttls[service] ttl := c.ttls[service]
// make a copy // make a copy
cp := registry.Copy(services) cp := util.Copy(services)
// got services && within ttl so return cache // got services && within ttl so return cache
if c.isValid(cp, ttl) { if c.isValid(cp, ttl) {
@ -152,7 +153,7 @@ func (c *cache) get(service string) ([]*registry.Service, error) {
// cache results // cache results
c.Lock() c.Lock()
c.set(service, registry.Copy(services)) c.set(service, util.Copy(services))
c.Unlock() c.Unlock()
return services, nil return services, nil