Versions in this module Expand all Collapse all v0 v0.2.9 Apr 9, 2021 Changes in this version + var NotExistErr = errors.New("not exist") + type BlockingKMapContainer struct + Tolerate float64 + func (bm *BlockingKMapContainer) Del(key MapKey, value interface{}) + func (bm *BlockingKMapContainer) Get(key MapKey) (interface{}, error) + func (bm *BlockingKMapContainer) Len() int + func (bm *BlockingKMapContainer) LoadBase(iterator DataIterator) error + func (bm *BlockingKMapContainer) LoadInc(iterator DataIterator) error + func (bm *BlockingKMapContainer) Range(f func(key, value interface{}) bool) + func (bm *BlockingKMapContainer) Set(key MapKey, value interface{}) error + type BlockingMapContainer struct + Tolerate float64 + func CreateBlockingKSetContainer(tolerate float64) *BlockingMapContainer + func CreateBlockingMapContainer(numPartision int, tolerate float64) *BlockingMapContainer + func (bm *BlockingMapContainer) Del(key MapKey, value interface{}) + func (bm *BlockingMapContainer) Get(key MapKey) (interface{}, error) + func (bm *BlockingMapContainer) Len() int + func (bm *BlockingMapContainer) LoadBase(iterator DataIterator) error + func (bm *BlockingMapContainer) LoadInc(iterator DataIterator) error + func (bm *BlockingMapContainer) Range(f func(key, value interface{}) bool) + func (bm *BlockingMapContainer) Set(key MapKey, value interface{}) error + type BufferedKListContainer struct + ErrorNum int + func CreateBufferedKListContainer() *BufferedKListContainer + func (bm *BufferedKListContainer) Del(key MapKey, value interface{}) + func (bm *BufferedKListContainer) Get(key MapKey) (interface{}, error) + func (bm *BufferedKListContainer) LoadBase(iterator DataIterator) error + func (bm *BufferedKListContainer) LoadInc(iterator DataIterator) error + func (bm *BufferedKListContainer) Set(key MapKey, value interface{}) error + type BufferedMapContainer struct + Tolerate float64 + func (bm *BufferedMapContainer) Del(key MapKey, value interface{}) + func (bm *BufferedMapContainer) Get(key MapKey) (interface{}, error) + func (bm *BufferedMapContainer) Len() int + func (bm *BufferedMapContainer) LoadBase(iterator DataIterator) error + func (bm *BufferedMapContainer) LoadInc(iterator DataIterator) error + func (bm *BufferedMapContainer) Range(f func(key, value interface{}) bool) + func (bm *BufferedMapContainer) Set(key MapKey, value interface{}) error + type Container interface + Del func(key MapKey, value interface{}) + Get func(key MapKey) (interface{}, error) + Len func() int + LoadBase func(dataIter DataIterator) error + LoadInc func(dataIter DataIterator) error + Range func(f func(key, value interface{}) bool) + Set func(key MapKey, value interface{}) error + type DataIterator interface + HasNext func() (bool, error) + Next func() (DataMode, MapKey, interface{}, error) + type DataMode int + const DataModeAdd + const DataModeDel + const DataModeUpdate + type Int64Key struct + Data int64 + func I64Key(key int64) *Int64Key + func (i *Int64Key) PartitionKey() int64 + func (i *Int64Key) Value() interface{} + type MapKey interface + PartitionKey func() int64 + Value func() interface{} + type StringKey struct + Data string + func StrKey(key string) *StringKey + func (s *StringKey) PartitionKey() int64 + func (s *StringKey) Value() interface{}