cache

Documentation

Index

• func DefaultOnExpire[D any](D)
• type Cache
  • func NewCache[K comparable, D any]() *Cache[K, D]
  • func (c *Cache[K, D]) CheckExpirations(now time.Time)
  • func (c *Cache[K, D]) Load(key K) (actual *Element[D])
  • func (c *Cache[K, D]) LoadOrStore(key K, e *Element[D]) (actual *Element[D], loaded bool)
• type Element
  • func NewElement[D any](data D, validUntil time.Time, onExpire func(d D)) *Element[D]
  • func (e *Element[D]) Data() D
  • func (e *Element[D]) IsExpired(now time.Time) bool

Functions

func DefaultOnExpire

func DefaultOnExpire[D any](D)

Types

type Cache

type Cache[K comparable, D any] struct {
	*sync.Map[K, *Element[D]]
}

func NewCache

func NewCache[K comparable, D any]() *Cache[K, D]

func (*Cache[K, D]) CheckExpirations

func (c *Cache[K, D]) CheckExpirations(now time.Time)

func (*Cache[K, D]) Load

func (c *Cache[K, D]) Load(key K) (actual *Element[D])

func (*Cache[K, D]) LoadOrStore

func (c *Cache[K, D]) LoadOrStore(key K, e *Element[D]) (actual *Element[D], loaded bool)

type Element

type Element[D any] struct {
	ValidUntil atomic.Time
	// contains filtered or unexported fields
}

func NewElement

func NewElement[D any](data D, validUntil time.Time, onExpire func(d D)) *Element[D]

func (*Element[D]) Data

func (e *Element[D]) Data() D

func (*Element[D]) IsExpired

func (e *Element[D]) IsExpired(now time.Time) bool