localcache

Aug 2, 2024

Changes in this version

+ func GetPublishKeysByTopic(topics []string, keys []string) map[string][]string

+ func InitLocalCache(localCache *config.LocalCache)

+ func LRUStringHash(key string) uint64

+ type EmptyTarget struct

+ func (e EmptyTarget) IncrDelHit()

+ func (e EmptyTarget) IncrDelNotFound()

+ func (e EmptyTarget) IncrGetFailed()

+ func (e EmptyTarget) IncrGetHit()

+ func (e EmptyTarget) IncrGetSuccess()

May 15, 2024

Changes in this version

+ func AnyValue[V any](v any, err error) (V, error)

+ type Cache interface

+ Del func(ctx context.Context, key ...string)

+ DelLocal func(ctx context.Context, key ...string)

+ Get func(ctx context.Context, key string, fetch func(ctx context.Context) (V, error)) (V, error)

+ GetLink func(ctx context.Context, key string, fetch func(ctx context.Context) (V, error), ...) (V, error)

+ Stop func()

+ func New[V any](opts ...Option) Cache[V]

+ type Option func(o *option)

+ func WithDeleteKeyBefore(fn func(ctx context.Context, key ...string)) Option

+ func WithExpirationEvict() Option

+ func WithLazy() Option

+ func WithLinkDisable() Option

+ func WithLinkSlotNum(linkSlotNum int) Option

+ func WithLocalDisable() Option

+ func WithLocalFailedTTL(localFailedTTL time.Duration) Option

+ func WithLocalSlotNum(localSlotNum int) Option

+ func WithLocalSlotSize(localSlotSize int) Option

+ func WithLocalSuccessTTL(localSuccessTTL time.Duration) Option

+ func WithTarget(target lru.Target) Option