Versions in this module Expand all Collapse all v1 v1.1.21 Jul 5, 2021 Changes in this version + func CalcChannelVersion(channel, version int32) int32 + func DecodeChannelVersion(channelVersion int32) (channel int32, version int32) + type Filterdata struct + func NewFilter(num int) *Filterdata + func (f *Filterdata) Add(key string, val interface{}) bool + func (f *Filterdata) AddWithCheckAtomic(key string, val interface{}) (exist bool) + func (f *Filterdata) Close() + func (f *Filterdata) Contains(key string) bool + func (f *Filterdata) Get(key string) (interface{}, bool) + func (f *Filterdata) GetAtomicLock() + func (f *Filterdata) ManageRecvFilter(tickTime time.Duration) + func (f *Filterdata) ReleaseAtomicLock() + func (f *Filterdata) Remove(key string) + type SpaceLimitCache struct + func NewSpaceLimitCache(num, maxByteSize int) *SpaceLimitCache + func (c *SpaceLimitCache) Add(key interface{}, val interface{}, size int) bool + func (c *SpaceLimitCache) Contains(key interface{}) bool + func (c *SpaceLimitCache) Get(key interface{}) interface{} + func (c *SpaceLimitCache) Remove(key interface{}) (interface{}, bool)