cache

Dec 25, 2023

Changes in this version

type InvalidationIndex

+ func (i *InvalidationIndex) AddCache(name string, deleter Deleter)

+ func (i *InvalidationIndex) AddLabels(cacheName string, key []byte, labels ...string)

Dec 22, 2022

Changes in this version

+ const MetricEvictionElapsedSeconds

type Config

+ EvictionNeeded func() bool

Dec 16, 2022

Changes in this version

type Config

+ SysMemSoftLimit uint64

Dec 15, 2022

Changes in this version

+ type InvalidationIndex struct

+ func NewInvalidationIndex(deleter Deleter) *InvalidationIndex

+ func (i *InvalidationIndex) AddInvalidationLabels(key []byte, labels ...string)

+ func (i *InvalidationIndex) InvalidateByLabels(ctx context.Context, labels ...string) (int, error)

Dec 7, 2022

Changes in this version

type Config

+ EvictionStrategy EvictionStrategy

+ type EvictionStrategy uint8

+ const EvictLeastFrequentlyUsed

+ const EvictLeastRecentlyUsed

+ const EvictMostExpired

type Trait

+ Evict func(fraction float64) int

type TraitEntry

+ C int64

type TraitEntryOf

+ C int64

Dec 5, 2022

Changes in this version

+ const UnlimitedTTL

May 13, 2022

Changes in this version

+ const ErrUnexpectedType

+ const MetricDelete

+ type BinaryEncoding interface

+ Decode func(ctx context.Context, buf []byte) (interface{}, error)

+ Encode func(ctx context.Context, value interface{}) ([]byte, error)

+ type BinaryUnmarshaler func(data []byte) (encoding.BinaryMarshaler, error)

+ func (f BinaryUnmarshaler) Decode(_ context.Context, buf []byte) (interface{}, error)

+ func (f BinaryUnmarshaler) Encode(_ context.Context, value interface{}) ([]byte, error)

+ type Key []byte

+ func (ks Key) MarshalText() ([]byte, error)

+ type Trait struct

+ Closed chan struct{}

+ Config Config

+ DeleteExpired func(before time.Time)

+ EvictOldest func(fraction float64) int

+ Len func() int

+ Log logTrait

+ Stat StatsTracker

+ func NewTrait(config Config, options ...func(t *Trait)) *Trait

+ func (c *Trait) NotifyDeleted(ctx context.Context, key []byte)

+ func (c *Trait) NotifyDeletedAll(ctx context.Context, start time.Time, cnt int)

+ func (c *Trait) NotifyExpiredAll(ctx context.Context, start time.Time, cnt int)

+ func (c *Trait) NotifyWritten(ctx context.Context, key []byte, value interface{}, ttl time.Duration)

+ func (c *Trait) PrepareRead(ctx context.Context, cacheEntry *TraitEntry, found bool) (interface{}, error)

+ func (c *Trait) TTL(ctx context.Context) time.Duration

+ type TraitEntry struct

+ E time.Time

+ K Key

+ V interface{}

+ func (e TraitEntry) ExpireAt() time.Time

+ func (e TraitEntry) Key() []byte

+ func (e TraitEntry) Value() interface{}

+ type TraitEntryOf struct

+ E time.Time

+ K Key

+ V V

+ func (e TraitEntryOf[V]) ExpireAt() time.Time

+ func (e TraitEntryOf[V]) Key() []byte

+ func (e TraitEntryOf[V]) Value() V

+ type TraitOf struct

+ func NewTraitOf(config Config, options ...func(t *Trait)) *TraitOf[V]

+ func (c *TraitOf[V]) NotifyWritten(ctx context.Context, key []byte, value V, ttl time.Duration)

+ func (c *TraitOf[V]) PrepareRead(ctx context.Context, cacheEntry *TraitEntryOf[V], found bool) (v V, err error)

May 9, 2022

Changes in this version

type HTTPTransfer

+ func (t *HTTPTransfer) CachesCount() int

type ShardedMapOf

+ func (c *ShardedMapOf[V]) WalkDumpRestorer() WalkDumpRestorer

Apr 24, 2022

Changes in this version

type Failover

+ func (lt Failover) Error(ctx context.Context, msg string, keysAndValues ...interface{})

type FailoverOf

+ func (lt FailoverOf) Error(ctx context.Context, msg string, keysAndValues ...interface{})

+ type Logger interface

+ Error func(ctx context.Context, msg string, keysAndValues ...interface{})

+ func NewLogger(...) Logger

+ type StatsTracker interface

+ Add func(ctx context.Context, name string, increment float64, labelsAndValues ...string)

+ Set func(ctx context.Context, name string, absolute float64, labelsAndValues ...string)

+ func NewStatsTracker(...) StatsTracker

Feb 19, 2022

Changes in this version

+ type EntryOf interface

+ ExpireAt func() time.Time

+ Key func() []byte

+ Value func() V

+ type ErrWithExpiredItemOf interface

+ ExpiredAt func() time.Time

+ Value func() V

+ type FailoverConfigOf struct

+ Backend ReadWriterOf[V]

+ BackendConfig Config

+ FailHard bool

+ FailedUpdateTTL time.Duration

+ Logger ctxd.Logger

+ MaxStaleness time.Duration

+ Name string

+ ObserveMutability bool

+ Stats stats.Tracker

+ SyncRead bool

+ SyncUpdate bool

+ UpdateTTL time.Duration

+ func (fc FailoverConfigOf[V]) Use(cfg *FailoverConfigOf[V])

+ type FailoverOf struct

+ Errors *ShardedMapOf[error]

+ func NewFailoverOf(options ...func(cfg *FailoverConfigOf[V])) *FailoverOf[V]

+ func (f *FailoverOf[V]) Get(ctx context.Context, key []byte, ...) (V, error)

+ type ReadWriterOf interface

+ type ReaderOf interface

+ Read func(ctx context.Context, key []byte) (V, error)

+ type ShardedMapOf struct

+ func NewShardedMapOf(options ...func(cfg *Config)) *ShardedMapOf[V]

+ func (c *ShardedMapOf[V]) Dump(w io.Writer) (int, error)

+ func (c *ShardedMapOf[V]) Restore(r io.Reader) (int, error)

+ func (c ShardedMapOf) Delete(ctx context.Context, key []byte) error

+ func (c ShardedMapOf) DeleteAll(ctx context.Context)

+ func (c ShardedMapOf) ExpireAll(ctx context.Context)

+ func (c ShardedMapOf) Len() int

+ func (c ShardedMapOf) Load(key []byte) (val V, loaded bool)

+ func (c ShardedMapOf) Read(ctx context.Context, key []byte) (val V, _ error)

+ func (c ShardedMapOf) Store(key []byte, val V)

+ func (c ShardedMapOf) Walk(walkFn func(e EntryOf[V]) error) (int, error)

+ func (c ShardedMapOf) Write(ctx context.Context, k []byte, v V) error

+ type WalkerOf interface

+ Walk func(func(entry EntryOf[V]) error) (int, error)

+ type WriterOf interface

+ Write func(ctx context.Context, key []byte, value V) error

Dec 17, 2021

Changes in this version

type ShardedMap

+ func (c ShardedMap) Load(key []byte) (interface{}, bool)

+ func (c ShardedMap) Store(key []byte, val interface{})

Aug 22, 2021

Changes in this version

+ type SyncMap struct

+ func NewSyncMap(options ...func(cfg *Config)) *SyncMap

+ func (c *SyncMap) Dump(w io.Writer) (int, error)

+ func (c *SyncMap) Restore(r io.Reader) (int, error)

+ func (c SyncMap) Delete(ctx context.Context, key []byte) error

+ func (c SyncMap) DeleteAll(ctx context.Context)

+ func (c SyncMap) ExpireAll(ctx context.Context)

+ func (c SyncMap) Len() int

+ func (c SyncMap) Read(ctx context.Context, key []byte) (interface{}, error)

+ func (c SyncMap) Walk(walkFn func(e Entry) error) (int, error)

+ func (c SyncMap) Write(ctx context.Context, k []byte, v interface{}) error

Aug 19, 2021

Changes in this version

type Entry

+ ExpireAt func() time.Time

type FailoverConfig

+ FailHard bool

+ type HTTPTransfer struct

+ Logger ctxd.Logger

+ Transport http.RoundTripper

+ func (t *HTTPTransfer) AddCache(name string, c WalkDumpRestorer)

+ func (t *HTTPTransfer) Export() http.Handler

+ func (t *HTTPTransfer) ExportJSONL() http.Handler

+ func (t *HTTPTransfer) Import(ctx context.Context, exportURL string) error

+ type WalkDumpRestorer interface

May 9, 2021

Changes in this version

+ const DefaultTTL

+ const ErrAlreadyInvalidated

+ const ErrExpired

+ const ErrNotFound

+ const ErrNothingToInvalidate

+ const MetricBuild

+ const MetricChanged

+ const MetricEvict

+ const MetricExpired

+ const MetricFailed

+ const MetricHit

+ const MetricItems

+ const MetricMiss

+ const MetricRefreshed

+ const MetricWrite

+ const SkipWriteTTL

+ func GobRegister(values ...interface{})

+ func GobTypesHash() uint64

+ func GobTypesHashReset()

+ func SkipRead(ctx context.Context) bool

+ func TTL(ctx context.Context) time.Duration

+ func WithSkipRead(ctx context.Context) context.Context

+ func WithTTL(ctx context.Context, ttl time.Duration, updateExisting bool) context.Context

+ type Config struct

+ CountSoftLimit uint64

+ DeleteExpiredAfter time.Duration

+ DeleteExpiredJobInterval time.Duration

+ EvictFraction float64

+ ExpirationJitter float64

+ HeapInUseSoftLimit uint64

+ ItemsCountReportInterval time.Duration

+ Logger ctxd.Logger

+ Name string

+ Stats stats.Tracker

+ TimeToLive time.Duration

+ func (c Config) Use(cfg *Config)

+ type Deleter interface

+ Delete func(ctx context.Context, key []byte) error

+ type Dumper interface

+ Dump func(w io.Writer) (int, error)

+ type Entry interface

+ Key func() []byte

+ Value func() interface{}

+ type ErrWithExpiredItem interface

+ ExpiredAt func() time.Time

+ Value func() interface{}

+ type Failover struct

+ Errors *ShardedMap

+ func NewFailover(options ...func(cfg *FailoverConfig)) *Failover

+ func (f *Failover) Get(ctx context.Context, key []byte, ...) (interface{}, error)

+ type FailoverConfig struct

+ Backend ReadWriter

+ BackendConfig Config

+ FailedUpdateTTL time.Duration

+ Logger ctxd.Logger

+ MaxStaleness time.Duration

+ Name string

+ ObserveMutability bool

+ Stats stats.Tracker

+ SyncRead bool

+ SyncUpdate bool

+ UpdateTTL time.Duration

+ func (fc FailoverConfig) Use(cfg *FailoverConfig)

+ type Invalidator struct

+ Callbacks []func(ctx context.Context)

+ SkipInterval time.Duration

+ func (i *Invalidator) Invalidate(ctx context.Context) error

+ type NoOp struct

+ func (NoOp) Delete(_ context.Context, _ []byte) error

+ func (NoOp) Read(_ context.Context, _ []byte) (interface{}, error)

+ func (NoOp) Write(_ context.Context, _ []byte, _ interface{}) error

+ type ReadWriter interface

+ type Reader interface

+ Read func(ctx context.Context, key []byte) (interface{}, error)

+ type Restorer interface

+ Restore func(r io.Reader) (int, error)

+ type SentinelError string

+ func (e SentinelError) Error() string

+ type ShardedMap struct

+ func NewShardedMap(options ...func(cfg *Config)) *ShardedMap

+ func (c *ShardedMap) Dump(w io.Writer) (int, error)

+ func (c *ShardedMap) Restore(r io.Reader) (int, error)

+ func (c ShardedMap) Delete(ctx context.Context, key []byte) error

+ func (c ShardedMap) DeleteAll(ctx context.Context)

+ func (c ShardedMap) ExpireAll(ctx context.Context)

+ func (c ShardedMap) Len() int

+ func (c ShardedMap) Read(ctx context.Context, key []byte) (interface{}, error)

+ func (c ShardedMap) Walk(walkFn func(e Entry) error) (int, error)

+ func (c ShardedMap) Write(ctx context.Context, k []byte, v interface{}) error

+ type Walker interface

+ Walk func(func(entry Entry) error) (int, error)

+ type Writer interface

+ Write func(ctx context.Context, key []byte, value interface{}) error