cache

package

v0.0.0-...-e2712e4 Latest Latest Go to latest Published: Feb 26, 2026 License: AGPL-3.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 any) *CachedItem

Add a CachedItem to the CacheTable without any specific loader

func (table *CacheTable) Clear()

Remove all CachedItems

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

Remove a specific CachedItem

func (table *CacheTable) Fetch(key string, f func() (any, error)) (any, error)

Get a CachedItem saved data or fetch it with the given func

func (table *CacheTable) Value(key string, args ...any) (any, error)

Get a CachedItem saved data or fetch it with its dataloader

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

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

func (item *CachedItem) Fetch(f func() (any, error)) (any, error)

Get the item saved data or fetch it with the given func

func (item *CachedItem) SetData(data any)

Unused for now: Manually set a cached item data.

func (item *CachedItem) SetDataLoader(f func(...any) (any, error))

Unused for now: Define a data loader for the item

func (item *CachedItem) Stop()

Thread safe stop the item cleanup Timer

func (item *CachedItem) Value(args ...any) (any, error)

Get the item saved data or fetch it with its dataloader

type ErrNotFound string

func (e ErrNotFound) Error() string