stores

Oct 6, 2022

retracted

Changes in this version

+ func ByteHash(b []byte) uint64

+ func NumberLess(a, b T) bool

+ func StringHash(s string) uint64

+ func StringLess(a, b string) bool

+ type HashFunc func(T) uint64

+ type Keyed interface

+ Key func() string

+ type LessFunc btree.LessFunc[T]

+ type MinMaxHeap struct

+ func NewMinMaxHeap(items ...T) *MinMaxHeap[T]

+ func (pq *MinMaxHeap[T]) Len() int

+ func (pq *MinMaxHeap[T]) Max() *PrioritizedItem[T]

+ func (pq *MinMaxHeap[T]) Min() *PrioritizedItem[T]

+ func (pq *MinMaxHeap[T]) PopMax() *PrioritizedItem[T]

+ func (pq *MinMaxHeap[T]) PopMin() *PrioritizedItem[T]

+ func (pq *MinMaxHeap[T]) Push(item *PrioritizedItem[T])

+ func (pq *MinMaxHeap[T]) Remove(item *PrioritizedItem[T])

+ func (pq *MinMaxHeap[T]) Update(item *PrioritizedItem[T])

+ type Prioritizable interface

+ HasPriorityOver func(item T) bool

+ type PrioritizedItem struct

+ Value T

+ type ShardedTree struct

+ func NewShardedTree(exponent int, hashFunc HashFunc[K], lessFunc LessFunc[T]) ShardedTree[K, T]

+ func (st ShardedTree[K, T]) For(key K) *btree.BTreeG[T]

+ func (st ShardedTree[K, T]) Len() (l int)

+ type SimpleStore struct

+ func NewJsonSimpleStore(tp streams.TopicPartition) *SimpleStore[T]

+ func NewSimpleStore(tp streams.TopicPartition, codec streams.Codec[T]) *SimpleStore[T]

+ func (s *SimpleStore[T]) Delete(item T) (cle streams.ChangeLogEntry, ok bool)

+ func (s *SimpleStore[T]) Get(id string) (val T, ok bool)

+ func (s *SimpleStore[T]) Put(item T) streams.ChangeLogEntry

+ func (s *SimpleStore[T]) ReceiveChange(record streams.IncomingRecord) (err error)

+ func (s *SimpleStore[T]) Revoked()

+ func (s *SimpleStore[T]) ToChangeLogEntry(item T) streams.ChangeLogEntry

+ type TransactonalTree struct

+ func NewTransactionalTree(degree int, lessFunc LessFunc[T], freeList *btree.FreeListG[T]) *TransactonalTree[T]

+ func (tt *TransactonalTree[T]) Abort()

+ func (tt *TransactonalTree[T]) Commit() error

+ func (tt *TransactonalTree[T]) CurrentTxn() *btree.BTreeG[T]

+ func (tt *TransactonalTree[T]) ForTxnContext(id uint64) (uint64, txn.Transactable)