Versions in this module Expand all Collapse all v0 v0.0.2 Oct 19, 2025 Changes in this version + type BlockingQueue interface + Empty func() bool + Pop func() (item T, shutdown bool) + Push func(T) + Shutdown func() + ShutdownWithDrained func() + Size func() int + func NewBlockingQueueWithConfig[T any](queue Queue[T]) BlockingQueue[T] + func NewBlockingQueue[T any]() BlockingQueue[T] + type DelayingQueue interface + PushAfter func(T, time.Duration) + Shutdown func() + func NewDelayingQueue[T any](blocking BlockingQueue[T], scheduler TimerScheduler) DelayingQueue[T] + type ExpirationMap interface + Destroy func() + SetExpired func(key K, val V, duration time.Duration) + func NewExpirationMap[K comparable, V any](opts ...ExpirationMapOption[K, V]) ExpirationMap[K, V] + type ExpirationMapOption func(c *expirationMap[K, V]) + func WithCleanDuration[K comparable, V any](duration time.Duration) ExpirationMapOption[K, V] + func WithConcurrentMap[K comparable, V any](cm ConcurrentMap[K, V]) ExpirationMapOption[K, V] + type Queue interface + Clear func() + Empty func() bool + Peek func() T + Pop func() T + Push func(T) + Size func() int + func NewPriorityQueue[T any](less func(a, b T) bool) Queue[T] + func NewQueue[T any]() Queue[T] + type Stack interface + type Timer interface + Reset func(duration time.Duration) + Stop func() + type TimerScheduler interface + IsShutdown func() bool + SetTimer func(duration time.Duration, fn func()) Timer + Shutdown func() v0.0.1 Jul 15, 2025 Changes in this version + func Keys[K comparable, V any](m map[K]V) []K + func ToMapP[K comparable, S, V any](s []S, conv func(*S) (K, V)) map[K]V + func ToMap[K comparable, S, V any](s []S, conv func(S) (K, V)) map[K]V + func Values[K comparable, V any](m map[K]V) []V + type ConcurrentMap interface + Clone func() ConcurrentMap[K, V] + Delete func(key K) + Get func(key K) (V, bool) + GetBatch func(keys []K) []V + Has func(key K) bool + Keys func() []K + KeysSet func() Set[K] + Len func() int + Merge func(ConcurrentMap[K, V]) + MergeMap func(map[K]V) + Set func(key K, v V) + ToMap func() map[K]V + Values func() []V + func NewConcurrentMapFromMap[K comparable, V any](m map[K]V) ConcurrentMap[K, V] + func NewConcurrentMap[K comparable, V any]() ConcurrentMap[K, V] + type PLM interface + InnerMap func() map[K]V + Pointer func() uintptr + RWLock func() *sync.RWMutex + type Set interface + Add func(v V) + AddSet func(s Set[V]) + Adds func(v ...V) + Any func([]V) bool + Delete func(v V) + Every func([]V) bool + ForEach func(func(v V)) + ForEachP func(func(v *V)) + Has func(v V) bool + Iterator func() iter.Seq[V] + Len func() int + Values func() []V + func NewSetFromSlice[V comparable](s []V) Set[V] + func NewSet[V comparable]() Set[V]
Go to main page