sm
/
cache
1
0
Fork 0
Code

Stay below 80 chars in width

This commit is contained in:
Patrick Mylund Nielsen 2012-06-22 03:56:12 +01:00
parent 724bd0e963
commit 026efae39f
1 changed files with 26 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
cache.go
View File

@ -28,7 +28,7 @@ func (i *Item) Expired() bool {
type Cache struct { type Cache struct {
*cache *cache
// If this is confusing, see the comment at the bottom of the New() function // If this is confusing, see the comment at the bottom of New()
} }
type cache struct { type cache struct {
@ -38,8 +38,9 @@ type cache struct {
janitor *janitor janitor *janitor
} }
// Adds an item to the cache, replacing any existing item. If the duration is 0, the // Adds an item to the cache, replacing any existing item. If the duration is 0,
// cache's default expiration time is used. If it is -1, the item never expires. // the cache's default expiration time is used. If it is -1, the item never
// expires.
func (c *cache) Set(k string, x interface{}, d time.Duration) { func (c *cache) Set(k string, x interface{}, d time.Duration) {
c.mu.Lock() c.mu.Lock()
c.set(k, x, d) c.set(k, x, d)
@ -63,8 +64,8 @@ func (c *cache) set(k string, x interface{}, d time.Duration) {
} }
} }
// Adds an item to the cache only if an item doesn't already exist for the given key, // Adds an item to the cache only if an item doesn't already exist for the given
// or if the existing item has expired. Returns an error if not. // key, or if the existing item has expired. Returns an error if not.
func (c *cache) Add(k string, x interface{}, d time.Duration) error { func (c *cache) Add(k string, x interface{}, d time.Duration) error {
c.mu.Lock() c.mu.Lock()
_, found := c.get(k) _, found := c.get(k)
@ -77,8 +78,8 @@ func (c *cache) Add(k string, x interface{}, d time.Duration) error {
return nil return nil
} }
// Sets a new value for the cache item only if it already exists. Returns an error if // Sets a new value for the cache item only if it already exists. Returns an
// it does not. // error if it does not.
func (c *cache) Replace(k string, x interface{}, d time.Duration) error { func (c *cache) Replace(k string, x interface{}, d time.Duration) error {
c.mu.Lock() c.mu.Lock()
_, found := c.get(k) _, found := c.get(k)
@ -91,8 +92,8 @@ func (c *cache) Replace(k string, x interface{}, d time.Duration) error {
return nil return nil
} }
// Gets an item from the cache. Returns the item or nil, and a bool indicating whether // Gets an item from the cache. Returns the item or nil, and a bool indicating
// the given key was found in the cache. // whether the given key was found in the cache.
func (c *cache) Get(k string) (interface{}, bool) { func (c *cache) Get(k string) (interface{}, bool) {
c.mu.Lock() c.mu.Lock()
x, found := c.get(k) x, found := c.get(k)
@ -112,10 +113,11 @@ func (c *cache) get(k string) (interface{}, bool) {
return item.Object, true return item.Object, true
} }
// Increment an item of type int, int8, int16, int32, int64, uintptr, uint, uint8, // Increment an item of type int, int8, int16, int32, int64, uintptr, uint,
// uint32, uint64, float32 or float64 by n. Returns an error if the item's value is // uint8, uint32, uint64, float32 or float64 by n. Returns an error if the
// not an integer, if it was not found, or if it is not possible to increment it by // item's value is not an integer, if it was not found, or if it is not
// n. Passing a negative number will cause the item to be decremented. // possible to increment it by n. Passing a negative number will cause the item
// to be decremented.
func (c *cache) IncrementFloat(k string, n float64) error { func (c *cache) IncrementFloat(k string, n float64) error {
c.mu.Lock() c.mu.Lock()
v, found := c.Items[k] v, found := c.Items[k]
@ -160,23 +162,25 @@ func (c *cache) IncrementFloat(k string, n float64) error {
return nil return nil
} }
// Increment an item of type int, int8, int16, int32, int64, uintptr, uint, uint8, // Increment an item of type int, int8, int16, int32, int64, uintptr, uint,
// uint32, or uint64, float32 or float64 by n. Returns an error if the item's value // uint8, uint32, or uint64, float32 or float64 by n. Returns an error if the
// is not an integer, if it was not found, or if it is not possible to increment it // item's value is not an integer, if it was not found, or if it is not
// by n. Passing a negative number will cause the item to be decremented. // possible to increment it by n. Passing a negative number will cause the item
// to be decremented.
func (c *cache) Increment(k string, n int64) error { func (c *cache) Increment(k string, n int64) error {
return c.IncrementFloat(k, float64(n)) return c.IncrementFloat(k, float64(n))
} }
// Decrement an item of type int, int8, int16, int32, int64, uintptr, uint, uint8, // Decrement an item of type int, int8, int16, int32, int64, uintptr, uint,
// uint32, or uint64, float32 or float64 by n. Returns an error if the item's value // uint8, uint32, or uint64, float32 or float64 by n. Returns an error if the
// is not an integer, if it was not found, or if it is not possible to decrement it // item's value is not an integer, if it was not found, or if it is not
// by n. // possible to decrement it by n.
func (c *cache) Decrement(k string, n int64) error { func (c *cache) Decrement(k string, n int64) error {
return c.Increment(k, n*-1) return c.Increment(k, n*-1)
} }
// Deletes an item from the cache. Does nothing if the item does not exist in the cache. // Deletes an item from the cache. Does nothing if the item does not exist in
// the cache.
func (c *cache) Delete(k string) { func (c *cache) Delete(k string) {
c.mu.Lock() c.mu.Lock()
c.delete(k) c.delete(k)