Documentation
¶
Index ¶
- type Cache
- type Hook
- type LookupCache
- type LookupCfg
- type LookupMap
- type TTLCache
- func (c *TTLCache) Clear()
- func (c *TTLCache) ClearUnsafe()
- func (c *TTLCache) Get(key string) (interface{}, bool)
- func (c *TTLCache) GetUnsafe(key string) (interface{}, bool)
- func (c *TTLCache) Has(key string) bool
- func (c *TTLCache) HasUnsafe(key string) bool
- func (c *TTLCache) Init()
- func (c *TTLCache) Invalidate(key string) bool
- func (c *TTLCache) InvalidateUnsafe(key string) bool
- func (c *TTLCache) Lock()
- func (c *TTLCache) Put(key string, value interface{}) bool
- func (c *TTLCache) PutUnsafe(key string, value interface{}) bool
- func (c *TTLCache) Set(key string, value interface{})
- func (c *TTLCache) SetEvictionCallback(hook Hook)
- func (c *TTLCache) SetInvalidateCallback(hook Hook)
- func (c *TTLCache) SetTTL(ttl time.Duration, update bool)
- func (c *TTLCache) SetUnsafe(key string, value interface{})
- func (c *TTLCache) Size() int
- func (c *TTLCache) SizeUnsafe() int
- func (c *TTLCache) Start(freq time.Duration) bool
- func (c *TTLCache) Stop() bool
- func (c *TTLCache) Unlock()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cache ¶
type Cache interface {
// Start will start the cache background eviction routine with given sweep frequency.
// If already running or a freq <= 0 provided, this is a no-op. This will block until
// the eviction routine has started
Start(freq time.Duration) bool
// Stop will stop cache background eviction routine. If not running this is a no-op. This
// will block until the eviction routine has stopped
Stop() bool
// SetEvictionCallback sets the eviction callback to the provided hook
SetEvictionCallback(hook Hook)
// SetInvalidateCallback sets the invalidate callback to the provided hook
SetInvalidateCallback(hook Hook)
// SetTTL sets the cache item TTL. Update can be specified to force updates of existing items in
// the cache, this will simply add the change in TTL to their current expiry time
SetTTL(ttl time.Duration, update bool)
// Get fetches the value with key from the cache, extending its TTL
Get(key string) (interface{}, bool)
// Put attempts to place the value at key in the cache, doing nothing if
// a value with this key already exists. Returned bool is success state
Put(key string, value interface{}) bool
// Set places the value at key in the cache. This will overwrite any
// existing value, and call the update callback so. Existing values
// will have their TTL extended upon update
Set(key string, value interface{})
// Has checks the cache for a value with key, this will not update TTL
Has(key string) bool
// Invalidate deletes a value from the cache, calling the invalidate callback
Invalidate(key string) bool
// Clear empties the cache, calling the invalidate callback
Clear()
// Size returns the current size of the cache
Size() int
}
Cache represents a TTL cache with customizable callbacks, it exists here to abstract away the "unsafe" methods in the case that you do not want your own implementation atop TTLCache{}.
type Hook ¶
type Hook func(key string, value interface{})
Hook defines a function hook that can be supplied as a callback.
type LookupCache ¶
type LookupCache interface {
Cache
// GetBy fetches a cached value by supplied lookup identifier and key
GetBy(lookup string, key string) (interface{}, bool)
// HasBy checks if a value is cached under supplied lookup identifier and key
HasBy(lookup string, key string) bool
// InvalidateBy invalidates a value by supplied lookup identifier and key
InvalidateBy(lookup string, key string) bool
}
LookupCache is a cache built on-top of TTLCache, providing multi-key lookups for items in the cache by means of additional lookup maps. These maps simply store additional keys => original key, with hook-ins to automatically call user supplied functions on adding an item, or on updating/deleting an item to keep the LookupMap up-to-date.
func NewLookup ¶
func NewLookup(cfg LookupCfg) LookupCache
NewLookup returns a new initialized LookupCache.
type LookupCfg ¶
type LookupCfg struct {
// RegisterLookups is called on init to register lookups
// within LookupCache's internal LookupMap
RegisterLookups func(*LookupMap)
// AddLookups is called on each addition to the cache, to
// set any required additional key lookups for supplied item
AddLookups func(*LookupMap, interface{})
// DeleteLookups is called on each eviction/invalidation of
// an item in the cache, to remove any unused key lookups
DeleteLookups func(*LookupMap, interface{})
}
LookupCfg is the LookupCache configuration.
type LookupMap ¶
type LookupMap struct {
// contains filtered or unexported fields
}
LookupMap is a structure that provides lookups for keys to primary keys under supplied lookup identifiers. This is essentially a wrapper around map[string](map[string]string).
func (*LookupMap) RegisterLookup ¶
RegisterLookup registers a lookup identifier in the LookupMap, note this can only be doing during the cfg.RegisterLookups() hook.
type TTLCache ¶
type TTLCache struct {
// contains filtered or unexported fields
}
TTLCache is the underlying Cache implementation, providing both the base Cache interface and access to "unsafe" methods so that you may build your customized caches ontop of this structure.
func (*TTLCache) ClearUnsafe ¶
func (c *TTLCache) ClearUnsafe()
ClearUnsafe is mutex-unprotected logic for Cache.Clean().
func (*TTLCache) Init ¶
func (c *TTLCache) Init()
Init performs Cache initialization, this MUST be called.
func (*TTLCache) Invalidate ¶
func (*TTLCache) InvalidateUnsafe ¶
InvalidateUnsafe is mutex-unprotected logic for Cache.Invalidate().
func (*TTLCache) SetEvictionCallback ¶
func (*TTLCache) SetInvalidateCallback ¶
func (*TTLCache) SetUnsafe ¶
SetUnsafe is the mutex-unprotected logic for Cache.Set(), it calls externally-set functions.
func (*TTLCache) SizeUnsafe ¶
SizeUnsafe is mutex unprotected logic for Cache.Size().