cache

package

v0.0.0-...-ec31716 Latest Latest Go to latest Published: Feb 26, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

View Source

const (
	MIN_CACHE_LIFESPAN     = 10 * time.Second
	DEFAULT_CACHE_LIFESPAN = 60 * time.Second
)

This section is empty.

This section is empty.

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

func NewCacheTable() *CacheTable

func (table *CacheTable) Add(key string, lifeSpan time.Duration, data interface{}) *CachedItem

func (table *CacheTable) Clear()

func (table *CacheTable) Delete(key string) (*CachedItem, error)

func (table *CacheTable) Fetch(key string, f func() (interface{}, error)) (interface{}, error)

func (table *CacheTable) Value(key string, args ...interface{}) (interface{}, error)

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

func NewCachedItem(key string, lifeSpan time.Duration, data interface{}, loader func(...interface{}) (interface{}, error)) *CachedItem

func (item *CachedItem) Fetch(f func() (interface{}, error)) (interface{}, error)

func (item *CachedItem) SetData(data interface{})

func (item *CachedItem) SetDataLoader(f func(...interface{}) (interface{}, error))

func (item *CachedItem) Stop()

func (item *CachedItem) Value(args ...interface{}) (interface{}, error)

type ErrNotFound string

func (e ErrNotFound) Error() string