structure

Mar 7, 2023

Changes in this version

+ type DelayQueue struct

+ Data chan interface{}

+ func NewDelayQueue(size int) *DelayQueue

+ func (dq *DelayQueue) Close()

+ func (dq *DelayQueue) Offer(elem interface{}, expiration int64)

+ func (dq *DelayQueue) Poll(nowF func() int64)

Jan 7, 2023

Changes in this version

+ type LockFreeMap struct

+ func NewLockFreeMap() *LockFreeMap[Key, T]

+ func (container *LockFreeMap[Key, T]) Del(key Key)

+ func (container *LockFreeMap[Key, T]) Find(key Key) (item T, err error)

+ func (container *LockFreeMap[Key, T]) Get(key Key) (item T, exist bool)

+ func (container *LockFreeMap[Key, T]) Iterator(fn func(key Key, val T))

+ func (container *LockFreeMap[Key, T]) Len() int

+ func (container *LockFreeMap[Key, T]) Set(key Key, value T)

+ type Map interface

+ Del func(key Key)

+ Get func(key Key) (item Val, exist bool)

+ Iterator func(fn func(key Key, val Val))

+ Len func() int

+ Set func(key Key, value Val)

Dec 4, 2022

Changes in this version

+ func InArray(arr []T, key T) bool

type ConcurrentMap

+ func (container *ConcurrentMap[Key, T]) Iterator(fn func(key Key, val T))

+ func (container *ConcurrentMap[Key, T]) Len() int

Nov 26, 2022

Changes in this version

+ type Queue struct

+ func NewQueue(size int) *Queue[T]

+ func (queue *Queue[T]) Empty() bool

+ func (queue *Queue[T]) Length() int

+ func (queue *Queue[T]) Offer(items ...T)

+ func (queue *Queue[T]) Polling(stopCh <-chan struct{}, handler func(item T))

+ type Sharding []T

+ func NewSharding(size int, constructor func() T) Sharding[T]

+ func (shard Sharding[T]) GetShard(num int) T

+ func (shard Sharding[T]) Iterator(iterator func(T))

+ type Singleton struct

+ func NewSingleton(constructor func() T) *Singleton[T]

+ func (s *Singleton[T]) Get() T

Nov 15, 2022

Changes in this version

type ConcurrentMap

+ func (container *ConcurrentMap[Key, T]) Del(key Key)

+ type KeyType interface

Oct 18, 2022

Changes in this version

+ type ConcurrentMap struct

+ func NewConcurrentMap() *ConcurrentMap[T]

+ func (container *ConcurrentMap[T]) Find(key string) (item T, err error)

+ func (container *ConcurrentMap[T]) Get(key string) (item T, exist bool)

+ func (container *ConcurrentMap[T]) Set(key string, value T) error