Versions in this module Expand all Collapse all v0 v0.1.1 Nov 27, 2021 v0.1.0 Nov 27, 2021 Changes in this version + type BatchError struct + func (be *BatchError) Add(err error) + func (be *BatchError) Err() error + func (be *BatchError) NotNil() bool + type Map struct + func (m *Map) ComputeIfAbsent(key interface{}, computeFunc func(key interface{}) interface{}) (actual interface{}, loaded bool) + func (m *Map) ComputeIfPresent(key interface{}, computeFunc func(key, value interface{}) interface{}) (actual interface{}, exist bool) + func (m *Map) Delete(key interface{}) + func (m *Map) Load(key interface{}) (value interface{}, ok bool) + func (m *Map) LoadAndDelete(key interface{}) (value interface{}, loaded bool) + func (m *Map) LoadOrStore(key, value interface{}) (actual interface{}, loaded bool) + func (m *Map) Range(f func(key, value interface{}) bool) + func (m *Map) Store(key, value interface{}) + type Queue struct + func NewQueue(opts ...QueueOption) *Queue + func (q *Queue) Cap(cap int) + func (q *Queue) Close() error + func (q *Queue) Read() interface{} + func (q *Queue) Remove(v interface{}) (ok bool) + func (q *Queue) Write(v interface{}) + type QueueMode byte + const MultiRead + const MultiReadWrite + const MultiWrite + type QueueOption func(opt *QueueOptions) + func WithQueueCap(cap int) QueueOption + func WithQueueMode(mode QueueMode) QueueOption + type QueueOptions struct + type ResourceManager struct + func NewResourceManager() *ResourceManager + func (m *ResourceManager) Close() error + func (m *ResourceManager) Get(key string, create func() (io.Closer, error)) (io.Closer, error) + func (m *ResourceManager) Remove(key string) (exist bool) + type Spinlock struct + func (lock *Spinlock) Lock() + func (lock *Spinlock) TryLock() bool + func (lock *Spinlock) Unlock()