expirationcache

type ExpiringCache[T any] interface {
	// Put adds the value to the cache unter the passed key with expiration. If expiration <=0, entry will NOT be cached
	Put(key string, val *T, expiration time.Duration)

	// Get returns the value of cached entry with remained TTL. If entry is not cached, returns nil
	Get(key string) (val *T, expiration time.Duration)

	// TotalCount returns the total count of valid (not expired) elements
	TotalCount() int

	// Clear removes all cache entries
	Clear()
}

type ExpiringLRUCache[T any] struct {
	// contains filtered or unexported fields
}

type OnAfterPutCallback func(newSize int)

type OnCacheHitCallback func(key string)

type OnCacheMissCallback func(key string)

type OnEntryReloadedCallback func(key string)

type OnExpirationCallback[T any] func(ctx context.Context, key string) (val *T, ttl time.Duration)

type Options struct {
	OnCacheHitFn    OnCacheHitCallback
	OnCacheMissFn   OnCacheMissCallback
	OnAfterPutFn    OnAfterPutCallback
	CleanupInterval time.Duration
	MaxSize         uint
}

type PrefetchingCacheOption[T any] func(c *PrefetchingExpiringLRUCache[cacheValue[T]])

type PrefetchingExpiringLRUCache[T any] struct {
	// contains filtered or unexported fields
}

type PrefetchingOptions[T any] struct {
	Options
	ReloadFn                ReloadEntryFn[T]
	PrefetchThreshold       int
	PrefetchExpires         time.Duration
	PrefetchMaxItemsCount   int
	OnPrefetchAfterPut      OnAfterPutCallback
	OnPrefetchEntryReloaded OnEntryReloadedCallback
	OnPrefetchCacheHit      OnCacheHitCallback
}

type ReloadEntryFn[T any] func(ctx context.Context, key string) (*T, time.Duration)