localcache

Documentation

Index

• func AnyValue[V any](v any, err error) (V, error)
• func GetPublishKeysByTopic(topics []string, keys []string) map[string][]string
• func InitLocalCache(localCache *config.LocalCache)
• func LRUStringHash(key string) uint64
• type Cache
  • func New[V any](opts ...Option) Cache[V]
• type EmptyTarget
  • func (e EmptyTarget) IncrDelHit()
  • func (e EmptyTarget) IncrDelNotFound()
  • func (e EmptyTarget) IncrGetFailed()
  • func (e EmptyTarget) IncrGetHit()
  • func (e EmptyTarget) IncrGetSuccess()
• type 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

Functions

func AnyValue

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

func GetPublishKeysByTopic

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

func InitLocalCache

func InitLocalCache(localCache *config.LocalCache)

func LRUStringHash

func LRUStringHash(key string) uint64

Types

type Cache

type Cache[V any] interface {
	Get(ctx context.Context, key string, fetch func(ctx context.Context) (V, error)) (V, error)
	GetLink(ctx context.Context, key string, fetch func(ctx context.Context) (V, error), link ...string) (V, error)
	Del(ctx context.Context, key ...string)
	DelLocal(ctx context.Context, key ...string)
	Stop()
}

func New

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

type EmptyTarget

type EmptyTarget struct{}

func (EmptyTarget) IncrDelHit

func (e EmptyTarget) IncrDelHit()

func (EmptyTarget) IncrDelNotFound

func (e EmptyTarget) IncrDelNotFound()

func (EmptyTarget) IncrGetFailed

func (e EmptyTarget) IncrGetFailed()

func (EmptyTarget) IncrGetHit

func (e EmptyTarget) IncrGetHit()

func (EmptyTarget) IncrGetSuccess

func (e EmptyTarget) IncrGetSuccess()

type Option

type Option func(o *option)

func WithDeleteKeyBefore

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

func WithExpirationEvict

func WithExpirationEvict() Option

func WithLazy

func WithLazy() Option

func WithLinkDisable

func WithLinkDisable() Option

func WithLinkSlotNum

func WithLinkSlotNum(linkSlotNum int) Option

func WithLocalDisable

func WithLocalDisable() Option

func WithLocalFailedTTL

func WithLocalFailedTTL(localFailedTTL time.Duration) Option

func WithLocalSlotNum

func WithLocalSlotNum(localSlotNum int) Option

func WithLocalSlotSize

func WithLocalSlotSize(localSlotSize int) Option

func WithLocalSuccessTTL

func WithLocalSuccessTTL(localSuccessTTL time.Duration) Option

func WithTarget

func WithTarget(target lru.Target) Option