zcache

Documentation

Overview

Package zcache cache operation

Index

• Variables
• func Clear()
• func Get(key interface{}) (value interface{}, err error)
• func GetInt(key interface{}) (value int, err error)
• func GetLocked(key interface{}) (interface{}, func(data interface{}, lifeSpan uint, interval ...bool))
• func GetString(key interface{}) (value string, err error)
• func Set(key, data interface{}, lifeSpan uint, interval ...bool)
• func SetDeleteCallback(f func(*Item) bool)
• func SetLogger(logger *zlog.Logger)
• type CacheItemPair
• type CacheItemPairList
  • func (p CacheItemPairList) Len() int
  • func (p CacheItemPairList) Less(i, j int) bool
  • func (p CacheItemPairList) Swap(i, j int)
• type Item
  • func Delete(key interface{}) (*Item, error)
  • func GetRaw(key interface{}) (*Item, error)
  • func NewCacheItem(key interface{}, data interface{}, lifeSpan time.Duration) *Item
  • func (item *Item) AccessCount() int64
  • func (item *Item) AccessedTime() time.Time
  • func (item *Item) CreatedTime() time.Time
  • func (item *Item) Data() interface{}
  • func (item *Item) Key() interface{}
  • func (item *Item) LifeSpan() time.Duration
  • func (item *Item) LifeSpanUint() uint
  • func (item *Item) RemainingLife() time.Duration
  • func (item *Item) SetDeleteCallback(fn func(item *Item) bool)
• type Table
  • func New(table string) *Table
  • func (table *Table) Add(key interface{}, data interface{}, lifeSpan time.Duration, ...) bool
  • func (table *Table) Clear()
  • func (table *Table) Count() int
  • func (table *Table) Delete(key interface{}) (*Item, error)
  • func (table *Table) Exists(key interface{}) bool
  • func (table *Table) ForEach(trans func(key, value interface{}))
  • func (table *Table) Get(key interface{}, args ...interface{}) (value interface{}, err error)
  • func (table *Table) GetInt(key interface{}, args ...interface{}) (value int, err error)
  • func (table *Table) GetLocked(key interface{}) (interface{}, func(data interface{}, lifeSpan uint, interval ...bool))
  • func (table *Table) GetRaw(key interface{}, args ...interface{}) (*Item, error)
  • func (table *Table) GetString(key interface{}, args ...interface{}) (value string, err error)
  • func (table *Table) MostAccessed(count int64) []*Item
  • func (table *Table) Set(key, data interface{}, lifeSpan uint, interval ...bool) *Item
  • func (table *Table) SetAddCallback(f func(*Item))
  • func (table *Table) SetDeleteCallback(f func(*Item) bool)
  • func (table *Table) SetLoadNotCallback(f func(key interface{}, args ...interface{}) *Item)
  • func (table *Table) SetLogger(logger *zlog.Logger)
  • func (table *Table) SetRaw(key, data interface{}, lifeSpan time.Duration, intervalLifeSpan ...bool) *Item

Variables

var (
	// ErrKeyNotFound ErrKeyNotFound
	ErrKeyNotFound = errors.New("key is not in cache")
	// ErrKeyNotFoundAndNotCallback ErrKeyNotFoundAndNotCallback
	ErrKeyNotFoundAndNotCallback = errors.New("key is not in cache and no callback is set")
)

Functions

func Clear

func Clear()

func Get

func Get(key interface{}) (value interface{}, err error)

func GetInt

func GetInt(key interface{}) (value int, err error)

func GetLocked

func GetLocked(key interface{}) (interface{}, func(data interface{}, lifeSpan uint, interval ...bool))

func GetString

func GetString(key interface{}) (value string, err error)

func Set

func Set(key, data interface{}, lifeSpan uint, interval ...bool)

func SetDeleteCallback

func SetDeleteCallback(f func(*Item) bool)

func SetLogger

func SetLogger(logger *zlog.Logger)

Types

type CacheItemPair

type CacheItemPair struct {
	Key         interface{}
	AccessCount int64
}

CacheItemPair maps key to access counter

type CacheItemPairList

type CacheItemPairList []CacheItemPair

CacheItemPairList CacheItemPairList

func (CacheItemPairList) Len

func (p CacheItemPairList) Len() int

func (CacheItemPairList) Less

func (p CacheItemPairList) Less(i, j int) bool

func (CacheItemPairList) Swap

func (p CacheItemPairList) Swap(i, j int)

type Item

type Item struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Item Item

func Delete

func Delete(key interface{}) (*Item, error)

func GetRaw

func GetRaw(key interface{}) (*Item, error)

func NewCacheItem

func NewCacheItem(key interface{}, data interface{}, lifeSpan time.Duration) *Item

NewCacheItem NewCacheItem

func (*Item) AccessCount

func (item *Item) AccessCount() int64

AccessCount AccessCount

func (*Item) AccessedTime

func (item *Item) AccessedTime() time.Time

AccessedTime AccessedTime

func (*Item) CreatedTime

func (item *Item) CreatedTime() time.Time

CreatedTime CreatedTime

func (*Item) Data

func (item *Item) Data() interface{}

Data data

func (*Item) Key

func (item *Item) Key() interface{}

Key item key

func (*Item) LifeSpan

func (item *Item) LifeSpan() time.Duration

LifeSpan LifeSpan

func (*Item) LifeSpanUint

func (item *Item) LifeSpanUint() uint

LifeSpanUint LifeSpanUint

func (*Item) RemainingLife

func (item *Item) RemainingLife() time.Duration

RemainingLife RemainingLife

func (*Item) SetDeleteCallback

func (item *Item) SetDeleteCallback(fn func(item *Item) bool)

SetDeleteCallback SetDeleteCallback

type Table

type Table struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Table Table

func New

func New(table string) *Table

New new cache

func (*Table) Add

func (table *Table) Add(key interface{}, data interface{}, lifeSpan time.Duration, intervalLifeSpan ...bool) bool

Add if the cache does not exist then adding does not take effect

func (*Table) Clear

func (table *Table) Clear()

Clear Clear

func (*Table) Count

func (table *Table) Count() int

Count get the number of caches

func (*Table) Delete

func (table *Table) Delete(key interface{}) (*Item, error)

Delete Delete cache

func (*Table) Exists

func (table *Table) Exists(key interface{}) bool

Exists Exists

func (*Table) ForEach

func (table *Table) ForEach(trans func(key, value interface{}))

ForEach traversing the cache

func (*Table) Get

func (table *Table) Get(key interface{}, args ...interface{}) (value interface{}, err error)

func (*Table) GetInt

func (table *Table) GetInt(key interface{}, args ...interface{}) (value int, err error)

func (*Table) GetLocked

func (table *Table) GetLocked(key interface{}) (interface{}, func(data interface{}, lifeSpan uint, interval ...bool))

GetLocked if the cache is not obtained, it will be locked directly

func (*Table) GetRaw

func (table *Table) GetRaw(key interface{}, args ...interface{}) (*Item, error)

GetRaw GetRaw

func (*Table) GetString

func (table *Table) GetString(key interface{}, args ...interface{}) (value string, err error)

func (*Table) MostAccessed

func (table *Table) MostAccessed(count int64) []*Item

MostAccessed MostAccessed

func (*Table) Set

func (table *Table) Set(key, data interface{}, lifeSpan uint, interval ...bool) *Item

Set set cache whether to automatically renew

func (*Table) SetAddCallback

func (table *Table) SetAddCallback(f func(*Item))

SetAddCallback SetAddCallback

func (*Table) SetDeleteCallback

func (table *Table) SetDeleteCallback(f func(*Item) bool)

SetDeleteCallback SetDeleteCallback

func (*Table) SetLoadNotCallback

func (table *Table) SetLoadNotCallback(f func(key interface{}, args ...interface{}) *Item)

SetLoadNotCallback SetLoadNotCallback

func (*Table) SetLogger

func (table *Table) SetLogger(logger *zlog.Logger)

SetLogger SetLogger

func (*Table) SetRaw

func (table *Table) SetRaw(key, data interface{}, lifeSpan time.Duration, intervalLifeSpan ...bool) *Item

SetRaw set cache