Versions in this module Expand all Collapse all v1 v1.0.0 Mar 12, 2024 Changes in this version + var SHARD_COUNT = 32 + type ConcurrentMap []*ConcurrentMapShared + func New() ConcurrentMap + func (m *ConcurrentMap) Has(key string) bool + func (m *ConcurrentMap) IsEmpty() bool + func (m *ConcurrentMap) Remove(key string) + func (m *ConcurrentMap) Set(key string, value *mgo.Session) + func (m *ConcurrentMap) UnmarshalJSON(b []byte) (err error) + func (m ConcurrentMap) Count() int + func (m ConcurrentMap) Get(key string) (*mgo.Session, bool) + func (m ConcurrentMap) GetShard(key string) *ConcurrentMapShared + func (m ConcurrentMap) Iter() <-chan Tuple + func (m ConcurrentMap) IterBuffered() <-chan Tuple + func (m ConcurrentMap) MarshalJSON() ([]byte, error) + type ConcurrentMapShared struct + type Tuple struct + Key string + Val *mgo.Session