common

Sep 4, 2018

Changes in this version

+ func Is(err error, t StoreErrType) bool

+ func NewTestLogger(t testing.TB) *logrus.Logger

+ type EvictCallback func(key interface{}, value interface{})

+ type LRU struct

+ func NewLRU(size int, onEvict EvictCallback) *LRU

+ func (c *LRU) Add(key, value interface{}) bool

+ func (c *LRU) Contains(key interface{}) (ok bool)

+ func (c *LRU) Get(key interface{}) (value interface{}, ok bool)

+ func (c *LRU) GetOldest() (interface{}, interface{}, bool)

+ func (c *LRU) Keys() []interface{}

+ func (c *LRU) Len() int

+ func (c *LRU) Peek(key interface{}) (value interface{}, ok bool)

+ func (c *LRU) Purge()

+ func (c *LRU) Remove(key interface{}) bool

+ func (c *LRU) RemoveOldest() (interface{}, interface{}, bool)

+ type RollingIndex struct

+ func NewRollingIndex(name string, size int) *RollingIndex

+ func (r *RollingIndex) Get(skipIndex int) ([]interface{}, error)

+ func (r *RollingIndex) GetItem(index int) (interface{}, error)

+ func (r *RollingIndex) GetLastWindow() (lastWindow []interface{}, lastIndex int)

+ func (r *RollingIndex) Roll()

+ func (r *RollingIndex) Set(item interface{}, index int) error

+ type RollingIndexMap struct

+ func NewRollingIndexMap(name string, size int, keys []int) *RollingIndexMap

+ func (rim *RollingIndexMap) Get(key int, skipIndex int) ([]interface{}, error)

+ func (rim *RollingIndexMap) GetItem(key int, index int) (interface{}, error)

+ func (rim *RollingIndexMap) GetLast(key int) (interface{}, error)

+ func (rim *RollingIndexMap) Known() map[int]int

+ func (rim *RollingIndexMap) Reset() error

+ func (rim *RollingIndexMap) Set(key int, item interface{}, index int) error

+ type StoreErr struct

+ func NewStoreErr(dataType string, errType StoreErrType, key string) StoreErr

+ func (e StoreErr) Error() string

+ type StoreErrType uint32

+ const Empty

+ const KeyNotFound

+ const NoRoot

+ const PassedIndex

+ const SkippedIndex

+ const TooLate

+ const UnknownParticipant