cache

Documentation

Index

• Constants
• Variables
• func Add(key string, value interface{}, expires time.Duration) error
• func Decrement(key string, n uint64) (newValue uint64, err error)
• func Delete(key string) error
• func Deserialize(byt []byte, ptr interface{}) (err error)
• func Flush() error
• func Get(key string, ptrValue interface{}) error
• func Increment(key string, n uint64) (newValue uint64, err error)
• func Replace(key string, value interface{}, expires time.Duration) error
• func Serialize(value interface{}) ([]byte, error)
• func Set(key string, value interface{}, expires time.Duration) error
• type Cache
• type Getter
  • func GetMulti(keys ...string) (Getter, error)
• type InMemoryCache
  • func NewInMemoryCache(defaultExpiration time.Duration) InMemoryCache
  • func (c InMemoryCache) Add(key string, value interface{}, expires time.Duration) error
  • func (c InMemoryCache) Decrement(key string, n uint64) (newValue uint64, err error)
  • func (c InMemoryCache) Delete(key string) error
  • func (c InMemoryCache) Flush() error
  • func (c InMemoryCache) Get(key string, ptrValue interface{}) error
  • func (c InMemoryCache) GetMulti(keys ...string) (Getter, error)
  • func (c InMemoryCache) Increment(key string, n uint64) (newValue uint64, err error)
  • func (c InMemoryCache) Replace(key string, value interface{}, expires time.Duration) error
  • func (c InMemoryCache) Set(key string, value interface{}, expires time.Duration) error
• type ItemMapGetter
  • func (g ItemMapGetter) Get(key string, ptrValue interface{}) error
• type MemcachedCache
  • func NewMemcachedCache(hostList []string, defaultExpiration time.Duration) MemcachedCache
  • func (c MemcachedCache) Add(key string, value interface{}, expires time.Duration) error
  • func (c MemcachedCache) Decrement(key string, delta uint64) (newValue uint64, err error)
  • func (c MemcachedCache) Delete(key string) error
  • func (c MemcachedCache) Flush() error
  • func (c MemcachedCache) Get(key string, ptrValue interface{}) error
  • func (c MemcachedCache) GetMulti(keys ...string) (Getter, error)
  • func (c MemcachedCache) Increment(key string, delta uint64) (newValue uint64, err error)
  • func (c MemcachedCache) Replace(key string, value interface{}, expires time.Duration) error
  • func (c MemcachedCache) Set(key string, value interface{}, expires time.Duration) error

Constants

const (
	DEFAULT = time.Duration(0)
	FOREVER = time.Duration(-1)
)

Length of time to cache an item.

Variables

var (
	Instance Cache

	ErrCacheMiss = errors.New("revel/cache: key not found.")
	ErrNotStored = errors.New("revel/cache: not stored.")
)

Functions

func Add

func Add(key string, value interface{}, expires time.Duration) error

func Decrement

func Decrement(key string, n uint64) (newValue uint64, err error)

func Delete

func Delete(key string) error

func Deserialize

func Deserialize(byt []byte, ptr interface{}) (err error)

Deserialize transforms bytes produced by Serialize back into a Go object, storing it into "ptr", which must be a pointer to the value type.

func Flush

func Flush() error

func Get

func Get(key string, ptrValue interface{}) error

func Increment

func Increment(key string, n uint64) (newValue uint64, err error)

func Replace

func Replace(key string, value interface{}, expires time.Duration) error

func Serialize

func Serialize(value interface{}) ([]byte, error)

Serialize transforms the given value into bytes following these rules:

• If value is a byte array, it is returned as-is.
• If value is an int or uint type, it is returned as the ASCII representation
• Else, encoding/gob is used to serialize

func Set

func Set(key string, value interface{}, expires time.Duration) error

Types

type Cache

type Cache interface {
	// The Cache implements a Getter.
	Getter

	// Set the given key/value in the cache, overwriting any existing value
	// associated with that key.  Keys may be at most 250 bytes in length.
	//
	// Returns:
	//   - nil on success
	//   - an implementation specific error otherwise
	Set(key string, value interface{}, expires time.Duration) error

	// Get the content associated multiple keys at once.  On success, the caller
	// may decode the values one at a time from the returned Getter.
	//
	// Returns:
	//   - the value getter, and a nil error if the operation completed.
	//   - an implementation specific error otherwise
	GetMulti(keys ...string) (Getter, error)

	// Delete the given key from the cache.
	//
	// Returns:
	//   - nil on a successful delete
	//   - ErrCacheMiss if the value was not in the cache
	//   - an implementation specific error otherwise
	Delete(key string) error

	// Add the given key/value to the cache ONLY IF the key does not already exist.
	//
	// Returns:
	//   - nil if the value was added to the cache
	//   - ErrNotStored if the key was already present in the cache
	//   - an implementation-specific error otherwise
	Add(key string, value interface{}, expires time.Duration) error

	// Set the given key/value in the cache ONLY IF the key already exists.
	//
	// Returns:
	//   - nil if the value was replaced
	//   - ErrNotStored if the key does not exist in the cache
	//   - an implementation specific error otherwise
	Replace(key string, value interface{}, expires time.Duration) error

	// Increment the value stored at the given key by the given amount.
	// The value silently wraps around upon exceeding the uint64 range.
	//
	// Returns the new counter value if the operation was successful, or:
	//   - ErrCacheMiss if the key was not found in the cache
	//   - an implementation specific error otherwise
	Increment(key string, n uint64) (newValue uint64, err error)

	// Decrement the value stored at the given key by the given amount.
	// The value is capped at 0 on underflow, with no error returned.
	//
	// Returns the new counter value if the operation was successful, or:
	//   - ErrCacheMiss if the key was not found in the cache
	//   - an implementation specific error otherwise
	Decrement(key string, n uint64) (newValue uint64, err error)

	// Expire all cache entries immediately.
	// This is not implemented for the memcached cache (intentionally).
	// Returns an implementation specific error if the operation failed.
	Flush() error
}

Cache is an interface to an expiring cache. It behaves (and is modeled) like the Memcached interface. It is keyed by strings (250 bytes at most).

Many callers will make exclusive use of Set and Get, but more exotic functions are also available.

Example

Here is a typical Get/Set interaction:

var items []*Item
if err := cache.Get("items", &items); err != nil {
  items = loadItems()
  go cache.Set("items", items, cache.DEFAULT)
}

Note that the caller will frequently not wait for Set() to complete.

Errors

It is assumed that callers will infrequently check returned errors, since any request should be fulfillable without finding anything in the cache. As a result, all errors other than ErrCacheMiss and ErrNotStored will be logged to revel.ERROR, so that the developer does not need to check the return value to discover things like deserialization or connection errors.

type Getter

type Getter interface {
	// Get the content associated with the given key. decoding it into the given
	// pointer.
	//
	// Returns:
	//   - nil if the value was successfully retrieved and ptrValue set
	//   - ErrCacheMiss if the value was not in the cache
	//   - an implementation specific error otherwise
	Get(key string, ptrValue interface{}) error
}

Getter is an interface for getting / decoding an element from a cache.

func GetMulti

func GetMulti(keys ...string) (Getter, error)

type InMemoryCache

type InMemoryCache struct {
	cache.Cache
}

func NewInMemoryCache

func NewInMemoryCache(defaultExpiration time.Duration) InMemoryCache

func (InMemoryCache) Add

func (c InMemoryCache) Add(key string, value interface{}, expires time.Duration) error

func (InMemoryCache) Decrement

func (c InMemoryCache) Decrement(key string, n uint64) (newValue uint64, err error)

func (InMemoryCache) Delete

func (c InMemoryCache) Delete(key string) error

func (InMemoryCache) Flush

func (c InMemoryCache) Flush() error

func (InMemoryCache) Get

func (c InMemoryCache) Get(key string, ptrValue interface{}) error

func (InMemoryCache) GetMulti

func (c InMemoryCache) GetMulti(keys ...string) (Getter, error)

func (InMemoryCache) Increment

func (c InMemoryCache) Increment(key string, n uint64) (newValue uint64, err error)

func (InMemoryCache) Replace

func (c InMemoryCache) Replace(key string, value interface{}, expires time.Duration) error

func (InMemoryCache) Set

func (c InMemoryCache) Set(key string, value interface{}, expires time.Duration) error

type ItemMapGetter

type ItemMapGetter map[string]*memcache.Item

Implement a Getter on top of the returned item map.

func (ItemMapGetter) Get

func (g ItemMapGetter) Get(key string, ptrValue interface{}) error

type MemcachedCache

type MemcachedCache struct {
	*memcache.Client
	// contains filtered or unexported fields
}

Wraps the Memcached client to meet the Cache interface.

func NewMemcachedCache

func NewMemcachedCache(hostList []string, defaultExpiration time.Duration) MemcachedCache

func (MemcachedCache) Add

func (c MemcachedCache) Add(key string, value interface{}, expires time.Duration) error

func (MemcachedCache) Decrement

func (c MemcachedCache) Decrement(key string, delta uint64) (newValue uint64, err error)

func (MemcachedCache) Delete

func (c MemcachedCache) Delete(key string) error

func (MemcachedCache) Flush

func (c MemcachedCache) Flush() error

func (MemcachedCache) Get

func (c MemcachedCache) Get(key string, ptrValue interface{}) error

func (MemcachedCache) GetMulti

func (c MemcachedCache) GetMulti(keys ...string) (Getter, error)

func (MemcachedCache) Increment

func (c MemcachedCache) Increment(key string, delta uint64) (newValue uint64, err error)

func (MemcachedCache) Replace

func (c MemcachedCache) Replace(key string, value interface{}, expires time.Duration) error

func (MemcachedCache) Set

func (c MemcachedCache) Set(key string, value interface{}, expires time.Duration) error