container

May 15, 2020

Changes in this version

+ 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

+ func CreateBlockingKSetContainer(tolerate float64) *BlockingMapContainer

type BufferedKListContainer

+ func CreateBufferedKListContainer() *BufferedKListContainer

Mar 21, 2020

Changes in this version

+ var NotExistErr = errors.New("not exist")

Jan 1, 2020

Changes in this version

type BlockingMapContainer

+ func (bm *BlockingMapContainer) Len() int

+ func (bm *BlockingMapContainer) Range(f func(key, value interface{}) bool)

type BufferedMapContainer

+ func (bm *BufferedMapContainer) Len() int

+ func (bm *BufferedMapContainer) Range(f func(key, value interface{}) bool)

type Container

+ Len func() int

+ Range func(f func(key, value interface{}) bool)

Sep 19, 2019

Changes in this version

+ type BlockingMapContainer struct

+ Tolerate float64

+ 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) LoadBase(iterator DataIterator) error

+ func (bm *BlockingMapContainer) LoadInc(iterator DataIterator) error

+ func (bm *BlockingMapContainer) Set(key MapKey, value interface{}) error

+ type BufferedKListContainer struct

+ ErrorNum int

+ 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) LoadBase(iterator DataIterator) error

+ func (bm *BufferedMapContainer) LoadInc(iterator DataIterator) error

+ func (bm *BufferedMapContainer) Set(key MapKey, value interface{}) error

+ type Container interface

+ Del func(key MapKey, value interface{})

+ Get func(key MapKey) (interface{}, error)

+ LoadBase func(dataIter DataIterator) error

+ LoadInc func(dataIter DataIterator) error

+ Set func(key MapKey, value interface{}) error

+ type DataIterator interface

+ HasNext func() bool

+ 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{}