internal

Dec 7, 2023

Changes in this version

+ type StringKey interface

+ StringKey func() string

Jun 11, 2023

Changes in this version

type CountMinSketch

+ func (s *CountMinSketch) EnsureCapacity(size uint)

type DataBlock

+ Index uint64

+ SecondaryType uint8

+ func (b *DataBlock[V]) MarkDirty()

+ func (b *DataBlock[V]) Save() error

+ func (b *DataBlock[V]) Write(item V) (full bool, err error)

+ type NotFound struct

+ func (e *NotFound) Error() string

+ type SecondaryCache interface

+ Delete func(key K) error

+ Get func(key K) (value V, cost int64, expire int64, ok bool, err error)

+ HandleAsyncError func(err error)

+ Set func(key K, value V, cost int64, expire int64) error

+ SetClock func(clock *clock.Clock)

+ type SecondaryCacheItem struct

+ type Serializer interface

+ Marshal func(v T) ([]byte, error)

+ Unmarshal func(raw []byte, v *T) error

type Store

+ func (s *Store[K, V]) DeleteWithSecondary(key K) error

+ func (s *Store[K, V]) GetWithSecodary(key K) (value V, ok bool, err error)

May 18, 2023

Changes in this version

+ const BlockBufferSize

+ var VersionMismatch = errors.New("version mismatch")

type CountMinSketch

+ Additions uint

+ BlockMask uint

+ SampleSize uint

+ Table []uint64

+ type DataBlock struct

+ CheckSum uint64

+ Data []byte

+ Type uint8

+ func NewBlock(tp uint8, buffer *bytes.Buffer, blockEncoder *gob.Encoder) *DataBlock[V]

type Group

+ func NewGroup() *Group[K, V]

type List

+ func (l *List[K, V]) Persist(writer io.Writer, blockEncoder *gob.Encoder, tp uint8) error

+ func (l *List[K, V]) PushBack(e *Entry[K, V]) *Entry[K, V]

+ type Pentry struct

+ Cost int64

+ Expire int64

+ Frequency int32

+ Key K

+ Removed bool

+ Value V

type Store

+ func (s *Store[K, V]) Persist(version uint64, writer io.Writer) error

+ func (s *Store[K, V]) Recover(version uint64, reader io.Reader) error

+ type StoreMeta struct

+ Sketch *CountMinSketch

+ StartNano int64

+ Version uint64

+ func (m *StoreMeta) Persist(writer io.Writer, blockEncoder *gob.Encoder) error

May 8, 2023

Changes in this version

type Store

+ func (s *Store[K, V]) Range(f func(key K, value V) bool)

Apr 26, 2023

Changes in this version

type Group

+ func (g *Group[K, V]) DoChan(key K, fn func() (V, error)) <-chan Result

Apr 16, 2023

Changes in this version

+ type Group struct

+ func (g *Group[K, V]) Do(key K, fn func() (V, error)) (v V, err error, shared bool)

+ func (g *Group[K, V]) Forget(key K)

+ type Loaded struct

+ Cost int64

+ TTL time.Duration

+ Value V

+ type LoadingStore struct

+ func NewLoadingStore(store *Store[K, V]) *LoadingStore[K, V]

+ func (s *LoadingStore[K, V]) Get(ctx context.Context, key K) (V, error)

+ func (s *LoadingStore[K, V]) Loader(loader func(ctx context.Context, key K) (Loaded[V], error))

+ type Result struct

+ Err error

+ Shared bool

+ Val interface{}

Apr 13, 2023

Changes in this version

+ type Metrics struct

+ type RemoveReason uint8

+ const EVICTED

+ const EXPIRED

+ const REMOVED

type Store

+ func (s *Store[K, V]) Cost(cost func(v V) int64)

+ func (s *Store[K, V]) Doorkeeper(enabled bool)

+ func (s *Store[K, V]) RemovalListener(listener func(key K, value V, reason RemoveReason))

Apr 11, 2023

Changes in this version

+ const LIST_PROBATION

+ const LIST_PROTECTED

+ const MAINTANCE

+ const MAX_READ_BUFF_SIZE

+ const MAX_WRITE_BUFF_SIZE

+ const MIN_WRITE_BUFF_SIZE

+ const NEW

+ const REMOVE

+ const UPDATE

+ const WHEEL_LIST

+ type Clock struct

+ type CountMinSketch struct

+ func NewCountMinSketch(size uint) *CountMinSketch

+ func (s *CountMinSketch) Add(h uint64) bool

+ func (s *CountMinSketch) Estimate(h uint64) uint

+ type Entry struct

+ func NewEntry(key K, value V, cost int64, expire int64) *Entry[K, V]

+ func (e *Entry[K, V]) Next(listType uint8) *Entry[K, V]

+ func (e *Entry[K, V]) Prev(listType uint8) *Entry[K, V]

+ type Hasher struct

+ func NewHasher() *Hasher[K]

+ type List struct

+ func NewList(size uint, listType uint8) *List[K, V]

+ func (l *List[K, V]) Back() *Entry[K, V]

+ func (l *List[K, V]) Contains(entry *Entry[K, V]) bool

+ func (l *List[K, V]) Front() *Entry[K, V]

+ func (l *List[K, V]) Len() int

+ func (l *List[K, V]) MoveAfter(e, mark *Entry[K, V])

+ func (l *List[K, V]) MoveBefore(e, mark *Entry[K, V])

+ func (l *List[K, V]) MoveToBack(e *Entry[K, V])

+ func (l *List[K, V]) MoveToFront(e *Entry[K, V])

+ func (l *List[K, V]) PopTail() *Entry[K, V]

+ func (l *List[K, V]) PushFront(e *Entry[K, V]) *Entry[K, V]

+ func (l *List[K, V]) Remove(e *Entry[K, V])

+ func (l *List[K, V]) Reset()

+ type MetaData struct

+ type OPCODE int8

+ type Queue struct

+ func NewQueue() *Queue[V]

+ func (q *Queue[V]) Empty() bool

+ func (q *Queue[V]) Pop() (V, bool)

+ func (q *Queue[V]) Push(x V)

+ type ReadBufItem struct

+ type Shard struct

+ func NewShard(size uint, qsize uint) *Shard[K, V]

+ type Slru struct

+ func NewSlru(size uint) *Slru[K, V]

+ type Store struct

+ func NewStore(maxsize int64) *Store[K, V]

+ func (s *Store[K, V]) Close()

+ func (s *Store[K, V]) Delete(key K)

+ func (s *Store[K, V]) Get(key K) (V, bool)

+ func (s *Store[K, V]) Len() int

+ func (s *Store[K, V]) Set(key K, value V, cost int64, ttl time.Duration) bool

+ func (s *Store[K, V]) SetCost(cost func(v V) int64)

+ func (s *Store[K, V]) SetDoorkeeper(enabled bool)

+ func (s *Store[K, V]) WriteBufLen() int

+ type TimerWheel struct

+ func NewTimerWheel(size uint) *TimerWheel[K, V]

+ type TinyLfu struct

+ func NewTinyLfu(size uint, hasher *Hasher[K]) *TinyLfu[K, V]

+ func (t *TinyLfu[K, V]) Access(item ReadBufItem[K, V])

+ func (t *TinyLfu[K, V]) EvictEntries() []*Entry[K, V]

+ func (t *TinyLfu[K, V]) Remove(entry *Entry[K, V])

+ func (t *TinyLfu[K, V]) Set(entry *Entry[K, V]) *Entry[K, V]

+ func (t *TinyLfu[K, V]) UpdateCost(entry *Entry[K, V], delta int64)

+ func (t *TinyLfu[K, V]) UpdateThreshold()

+ type WriteBufItem struct