common

Oct 3, 2020

Changes in this version

+ func Median(input []int64) (median int64)

Nov 7, 2019

Changes in this version

+ var TestLogLevel = logrus.DebugLevel

Sep 13, 2019

Changes in this version

+ func IsStore(err error, t StoreErrType) bool

Aug 8, 2019

Changes in this version

+ func NewTestEntry(t testing.TB) *logrus.Entry

Jul 15, 2019

Changes in this version

+ func DecodeFromString(hexString string) ([]byte, error)

+ func EncodeToString(hexBytes []byte) string

+ type Trilean int

+ const False

+ const True

+ const Undefined

+ func (t Trilean) String() string

Jan 28, 2019

Changes in this version

type RollingIndexMap

+ func (rim *RollingIndexMap) AddKey(key uint32) error

type StoreErrType

+ const KeyAlreadyExists

+ const NoPeerSet

Oct 14, 2018

Changes in this version

+ func Hash32(data []byte) int

+ 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