sm
/
cache
1
0
Fork 0

Export Item wrapping type, and add an Items() method to cache

This commit is contained in:
Patrick Mylund Nielsen 2013-08-08 14:53:02 -04:00
parent baa5a64da4
commit f8cc27acbc
1 changed files with 21 additions and 11 deletions

View File

@ -49,6 +49,7 @@ type unexportedInterface interface {
DecrementFloat64(string, float64) (float64, error) DecrementFloat64(string, float64) (float64, error)
Delete(string) Delete(string)
DeleteExpired() DeleteExpired()
Items() map[string]*Item
ItemCount() int ItemCount() int
Flush() Flush()
Save(io.Writer) error Save(io.Writer) error
@ -57,17 +58,17 @@ type unexportedInterface interface {
LoadFile(io.Reader) error LoadFile(io.Reader) error
} }
type item struct { type Item struct {
Object interface{} Object interface{}
Expiration *time.Time Expiration *time.Time
} }
// Returns true if the item has expired. // Returns true if the item has expired.
func (i *item) Expired() bool { func (item *Item) Expired() bool {
if i.Expiration == nil { if item.Expiration == nil {
return false return false
} }
return i.Expiration.Before(time.Now()) return item.Expiration.Before(time.Now())
} }
type Cache struct { type Cache struct {
@ -78,7 +79,7 @@ type Cache struct {
type cache struct { type cache struct {
sync.RWMutex sync.RWMutex
defaultExpiration time.Duration defaultExpiration time.Duration
items map[string]*item items map[string]*Item
janitor *janitor janitor *janitor
} }
@ -102,7 +103,7 @@ func (c *cache) set(k string, x interface{}, d time.Duration) {
t := time.Now().Add(d) t := time.Now().Add(d)
e = &t e = &t
} }
c.items[k] = &item{ c.items[k] = &Item{
Object: x, Object: x,
Expiration: e, Expiration: e,
} }
@ -903,7 +904,7 @@ func (c *cache) SaveFile(fname string) error {
// keys that already exist (and haven't expired) in the current cache. // keys that already exist (and haven't expired) in the current cache.
func (c *cache) Load(r io.Reader) error { func (c *cache) Load(r io.Reader) error {
dec := gob.NewDecoder(r) dec := gob.NewDecoder(r)
items := map[string]*item{} items := map[string]*Item{}
err := dec.Decode(&items) err := dec.Decode(&items)
if err == nil { if err == nil {
c.Lock() c.Lock()
@ -933,8 +934,17 @@ func (c *cache) LoadFile(fname string) error {
return fp.Close() return fp.Close()
} }
// Returns the items in the cache. This may include items that have expired,
// but have not yet been cleaned up. If this is significant, the Expiration
// field of the items should be checked.
func (c *cache) Items() map[string]*Item {
c.RLock()
defer c.RUnlock()
return c.items
}
// Returns the number of items in the cache. This may include items that have // Returns the number of items in the cache. This may include items that have
// expired, but have not yet been cleaned up. // expired, but have not yet been cleaned up. Equivalent to len(c.Items).
func (c *cache) ItemCount() int { func (c *cache) ItemCount() int {
c.RLock() c.RLock()
n := len(c.items) n := len(c.items)
@ -945,7 +955,7 @@ func (c *cache) ItemCount() int {
// Delete all items from the cache. // Delete all items from the cache.
func (c *cache) Flush() { func (c *cache) Flush() {
c.Lock() c.Lock()
c.items = map[string]*item{} c.items = map[string]*Item{}
c.Unlock() c.Unlock()
} }
@ -985,7 +995,7 @@ func newCache(de time.Duration) *cache {
} }
c := &cache{ c := &cache{
defaultExpiration: de, defaultExpiration: de,
items: map[string]*item{}, items: map[string]*Item{},
} }
return c return c
} }
@ -1109,7 +1119,7 @@ func newShardedCache(n int, de time.Duration) *shardedCache {
for i := 0; i < n; i++ { for i := 0; i < n; i++ {
c := &cache{ c := &cache{
defaultExpiration: de, defaultExpiration: de,
items: map[string]*item{}, items: map[string]*Item{},
} }
sc.cs[i] = c sc.cs[i] = c
} }